手动测试添加redis缓存数据( CarMessageValueCacheService报文数据=》key(报文模版id(templateId)),value(查询到的数据集合List); CarVehicleCacheService车辆信息=》key(VehicleVin车辆VIN码),value(Vehicle车辆实体类数据); CarVehicleTypeCacheService车辆类型=》key(VehicleTypeId车辆类型ID),value(查询到的集合List) )。 之后连接MQTT接收到车辆模拟传过来的数据--》查询redis--》解析数据--》传递kafka |
||
---|---|---|
.. | ||
src/main/java/com/muyu/common/cache/config | ||
pom.xml |