Commit Graph

3 Commits (dev)

Author SHA1 Message Date
LQS 15bcd34b07 feat():修复MQTT连接,接收rabbitMq数据消费,拿到数据解析投递kafka 2024-10-11 21:56:22 +08:00
LQS 0d48eb2e34 feat():解析模块的日志记录 2024-10-10 12:28:38 +08:00
LQS f0f6cf006f feat():修改缓存实现类结构,
手动测试添加redis缓存数据(
CarMessageValueCacheService报文数据=》key(报文模版id(templateId)),value(查询到的数据集合List);
CarVehicleCacheService车辆信息=》key(VehicleVin车辆VIN码),value(Vehicle车辆实体类数据);
CarVehicleTypeCacheService车辆类型=》key(VehicleTypeId车辆类型ID),value(查询到的集合List)
)。
之后连接MQTT接收到车辆模拟传过来的数据--》查询redis--》解析数据--》传递kafka
2024-10-09 16:19:28 +08:00