 张腾
|
2864df2549
|
重构车辆数据处理模块
- 新增 CacheUtil 类用于缓存管理
- 添加车辆上线和下线的 RabbitMQ 消息消费者- 实现基于事件的 IoTDB 数据持久化逻辑
- 重构 Kafka 消费者，支持多线程处理
- 移除多个不再使用的类和接口
|
2024-10-08 11:51:39 +08:00 |
 Aaaaaaaa
|
9486710ae8
|
美化代码和注释
删除了 CarMessageServiceImpl 中未使用的 RedisTemplate 注释。
|
2024-10-07 21:54:32 +08:00 |
|
Aaaaaaaa
|
e6e7e58f95
|
移除冗余代码并优化Kafka配置
- 删除了KafkaConstants、KafkaConsumerConfig和KafkaProviderConfig类，这些类已被移动到其他项目中
-简化了KafkaConfig类，移除了其中的kafkaProducer方法，该方法已被移动到其他类中
- 在MqttTest类中更新了Kafka主题的硬编码值
- 移除了oneMse类，该类用于测试，目前不再需要
- 在ProtocolApplication的main方法中添加了一个空的System.out.println语句，用于调试或日志记录
|
2024-10-07 14:22:46 +08:00 |
|
Aaaaaaaa
|
00d1eb18d1
|
新增本地缓存工具类和缓存实体类，优化报文解析服务
- 新增 CacheUtill 工具类，实现本地缓存功能，包括添加、获取、移除缓存和定时清理过期缓存
- 新增 MyCache 实体类，用于缓存键值对数据及过期时间
- 新增 oneMse测试类（具体用途待明确）- 在 CarMessageServiceImpl 中注释掉未使用的 RedisTemplate 相关代码
- 在 pom.xml 中添加 caffeine 依赖，用于本地缓存
- 移除 Demo 类中关于 MQTT 和 Kafka 的测试代码- 在 MqttTest 类中简化 Kafka 生产者发送消息的逻辑
|
2024-10-06 16:31:26 +08:00 |
|
Aaaaaaaa
|
f3c90ada2a
|
新增bootstrap.yml配置文件
添加了bootstrap.yml配置文件，包含了服务器端口、Nacos配置、Spring应用配置等。这个新文件将有助于应用在启动时读取必要的配置信息，从而与Nacos进行服务注册和配置管理。
|
2024-10-02 10:37:56 +08:00 |
|
Aaaaaaaa
|
6c2daa0d7e
|
Merge branch 'master' into xxy
# Conflicts:
# cloud-modules/cloud-modules-protocolparsing/src/main/java/com/muyu/mqtt/Demo.java
|
2024-10-02 10:23:47 +08:00 |
|
Aaaaaaaa
|
735e7f56e0
|
协议解析:完成解析方法实现kafka的投产,并拆入自己的模块
|
2024-09-30 20:58:08 +08:00 |