wksw-protocol-type
MessageSWDecoder（解决分包粘包）
队列数据分类到各自的集合中（雨量，河道，水库）
反控流程
单个集合进行增量算法处理
平台后台服务
RsvrPacketParseImpl（水库）
接收流程
PacketEndResolve（报文解析后逻辑处理）
批量入库
是
解析数据入队列
否
批量获取队列数据
反控操作
查询端发送反控指令
指令报文
成果队列服务
平台库
平台前台服务
WkswConsum（平台库入库处理程序）
StcdCheckHandler（过滤测站点）
平台队列服务
缓存站点通道
缓存反控端通道
回复查询端
HeartBeatSWHandler（心跳包处理）
进行Nack数据重新入到队列中
RiverPacketParseImpl（河道）
ServerSWHandler(报文解析)
响应报文
RTU
rtu-parsed-data
........
处理程序是否发生异常？
TCPServer（将ServerBootstrap绑定端口并启动，RTU上报数据端口，反控指令控制端口）
进行ack表示数据已经被消费
SwParse（解析报文基础数据）
是否是反控后设备回复的报文？
分类解析具体数据，并返回数据
成果中间库
处理过程中会将每个站点最新(时间最大)上报的部分数据存入redis，这样在处理程序过程中只需要读取缓存就知道其时间点的上一条数据的值，计算增量
.......
PptnPacketParseImpl（雨量）
StcdRegisterHander（缓存测站点通道）
ServerBootstrapConfig（反控指令，绑定通道和处理器）
RabbitMQ
ControlHandler(反控)
redis缓存
ServerBootstrapConfig（报文接收，绑定通道和处理器）
