时序图

判断hd:lock是否存在

写锁：rfid:pb:lock类型：string有效期：10s平板标识卡前缀：rfid:pb:tag类型：string废品已消费rfid：rfid:consumed:feipin:tag类型：string成品已消费rfid：rfid:consumed:chengping:tag类型：string半成品已消费rfid：rfid:consumed:half:tag类型：string

半成品/废品

监听topic：chengping

开始

3.2、返回重置信号

1.4、写状态

消息分发服务

消费消息

成品

是否修改成功

查询并修改平板标识卡

处理消息

web

智慧仓储架构

网关服务

kafka消息总线

是

否

rfid读写时序图

后台管理系统

RFID服务端

加锁

1.3、写入重置rfid数据，、循环监听结果

成品入库接口

是否成功

提交事务

建立连接

http

生成平板标识卡

rfid天线

判断当前rfid是否已消费

tcp三次握手

推送消息

RFID 读写设备

2.1、持续写入

监听topic：half

通过三种门的逻辑流程图

web层

废品：topic：feipin成品：topic：chengpin半成品：topic：half-chengpin

rfid存储键：hd:tag，有效期：10srfid重置锁：hd:lock，有效期：10s

抛出异常或回滚

数据回滚

保存拼版标识口令、保存重置rfid到redis（rfid存储键：hd:tag，有效期：10srfid重置锁：hd:lock，有效期：10s）

读写rfid服务

保存

入库成功

建立链接

结束

kafka

删除当前rfid队列（hd:list）

ws服务

redis服务

解锁

开启事务

3.3、重置

1.1查询

待重置键值：hd:tag，有效期：10srfid重置锁：hd:lock，有效期：10s当前rfid标签队列：hd:list有效期：10s

1.2 返回结果

webapi

客户端

3.1、查询重置信号

判断hd:list中是否只有写入标签