数据流向图

数据流向的架构流程描述，简单明了，容易查看

终端

• 道路流程
  • 1.道路项目主要围绕XreaMessageBean对象的填充展开
  • 2.XiotRoadParser对象初始化Jedis配置，Mysql配置，kafka配置
  • 3.XotRoadParser对象执行execute方法
    • 1.通过解析XreaMessageBean对象的MsgBody获得CMID （不同的CMID对应不同的解析指令对象DataProcess,协议决定）
    • 2.在redis中查询终端是否绑定，如果未绑定，则执行裸终端逻辑， 在mysql中查询终端信息，填充终端信息DeviceInfo,如果mysql 没有查到终端信息，则不执行余下操作直接return.
      • DataProce执行解析指令（对DeviceInfo对象和XreaMessageBean的操作）
        • 1.生成XreaBody对象（协议解析载体）
        • 2.解析协议填充XreaBody，xreaMessageBean填充context， 然后执行parseCMD 解析入库
          • 1.此部分主要围绕工况数据集，状态数据集，轨迹数据集，所有数据集 的填充展开。最后将4个数据集都填充到XreaBody对象的tlvMap属性中。 XreaMessage对象会根据XreaBody的数据判断条件填充上述4个数据集的内容到context属性中， 并在正常解析完成后再在XreaMessage对象中标记工况为有效工况
          • 2.有意思的解析操作有：状态位解析（获得相对应的状态），工况解析， can包的解析。
        • 3.天泽解决方案（非心跳包处理）
  • 4.数据写入kafka(XreaMessageBean对象，DeviceInfo对象)
    • 1.如果是未绑定车辆的终端，不写入到kafka
    • 2.如XreaMessageBean对象有轨迹数据，将轨迹数据处理后写入 到kafka（具体topic之类的，由Spring读取配置文件生成XreaProcessXmlBean 指定。若工况数据集符合条件处理后也写入到kafka中
  • 5.如指令ID为盲区数据，清空XreaMessageBean的context
• 网关流程
  • 1.decode解码 按照协议文档内容读字节，填充XreaMsg对象的deviceId,SystemId,cmdId,msgBody(数据包所有数据)属性 若数据包长度小于17或发生数据解析异常则返回XreaMsg的null对象
    • 2.channelRead（管道读取） 管道传输XreaMsg，将XreaMsg交付给业务模块处理
      • 3.Service处理（业务模块处理，应答给终端content） 1）获取不需要返回给终端的指令列表（cmdID列表 0x80,0x81,0x82,0x83）（Spring配置文件初始配置） 2）如果需要返回指令给终端:按特定的规则填充content 3) 适配部分cmId,不同的ID有不同的content填充规则（协议指定） 4）通用业务处理 ： 【1】若XreaMsg为null，直接返回false，不执行下列操作 【2】通过serverInfo(Spring初始XML填充)，获取到传输类型（UDP or TCP ）,获取生产项目类型（如XGIT_ROAD_XCMG）,获取服务网关代理地址，终端ID，adress 【3】设置当前连接终端标识为终端ID,并判断该终端设备是否在缓存中。如果不在缓存中，先判断设备是否在product表中，如果在producet表中，则更新连接池（一个map，存的是设备连接对象为value，设备编号为key，保持连接锚定），并执行登录操作。如果不在product表中，则直接将业务处理方法返回false。不执行余下操作，进而将content置为null。 如果在缓存中，则直接更新连接池。 【4】判断是否写入kafka（配置文件配置），如果需要写入kafka，则投递XreaMsg到kafka。判断是否转发到emp，如需，则转发。 5） content为null则不应答，content不为null则应答终端
• GateWay
• kafka topic