代码更新

src/main/java/com/god/data/queue/MessageProcessor.java

@@ -80,9 +80,6 @@ public class MessageProcessor {
      * @param carMessage
      */
     private void eventProducer(CarMessage carMessage){
-        if (!redisService.hasKey("event" + carMessage.getVin())){
-            redisService.setCacheList("event" + carMessage.getVin(),null);
-        }
         // 根据对象车辆vin获取事件集合，从redis中获取
         List<String> eventList = redisService.getCacheList("event" + carMessage.getVin());
         log.info("当前车辆 vin：{} 绑定事件：{}",carMessage.getVin(),eventList.toString());
@@ -95,6 +92,10 @@ public class MessageProcessor {
         }
     }
 
+    private void creatRedisKey(String vin){
+        redisService.setCacheList("event" + vin,null);
+    }
+
     /**
      * 向队列A中添加消息 如果阻塞，则去B添加消息
      * @param message