防止重复数据 入队列

src/main/java/com/cn/esermis/config/MyBatisPlusConfig.java

@@ -1,6 +1,7 @@
 package com.cn.esermis.config;
 
 import com.baomidou.mybatisplus.extension.plugins.PaginationInterceptor;
+import com.baomidou.mybatisplus.extension.plugins.PerformanceInterceptor;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 
@@ -11,4 +12,11 @@ public class MyBatisPlusConfig {
         PaginationInterceptor page = new PaginationInterceptor();
         return page;
     }
+    @Bean
+    public PerformanceInterceptor performanceInterceptor() {
+        PerformanceInterceptor performanceInterceptor = new PerformanceInterceptor();
+        performanceInterceptor.setWriteInLog(true);
+        return performanceInterceptor;
+    }
+
 }

src/main/java/com/cn/esermis/netty/BootNettyChannelInboundHandlerAdapter.java

@@ -23,6 +23,7 @@ import java.net.InetSocketAddress;
 import java.util.Date;
 import java.util.HashMap;
 import java.util.Map;
+import java.util.UUID;
 import java.util.concurrent.TimeUnit;
 
 @Log4j2
@@ -225,4 +226,8 @@ public class BootNettyChannelInboundHandlerAdapter extends ChannelInboundHandler
             ctx.channel().close();
         }
     }
+
+    public static void main(String[] args) {
+        System.out.println(UUID.randomUUID().toString().replaceAll("-", "").substring(0, 2));
+    }
 }

src/main/java/com/cn/esermis/server/Consumer.java

@@ -52,6 +52,10 @@ public class Consumer {
             }else{
                 tolot++;
                 int finalTolot = tolot;
+//                System.out.println("消费消息------------：第（"+ finalTolot+"）条");
+//                JSONObject jsonObject = (JSONObject) JSON.toJSON(message);
+//                monitorBusiness.inboundOperations(jsonObject);
+
                 executorService.submit(new Runnable() {
                     @Override
                     public void run() {

src/main/resources/application.yml

@@ -56,18 +56,18 @@ spring:
         # 比如我的scs_product_1  和 scs_product_2  那就写scs_product好区分
         # 当执行sql中出现scs_product，sharding-jdbc会将其操作到对应的表
         air_monitor_minute_record:
-          actual-data-nodes: scy.air_monitor_minute_record_$->{1..2}
+          actual-data-nodes: scy.air_monitor_minute_record_$->{0..1}
           # 指定主键生成策略为雪花id,全局主键
           key-generator:
             column: id
-            type: SNOWFLAKE
+            type: UUID
           #指定scs_product表的分片策略，  分片键和分片算法 用于计算真正的表名
           table-strategy:
             inline:
               # 偶数进到scs_product_1  奇数进到scs_product_2
               # 对于根据分片字段为条件的，会先判断是否涉及两张表，
               # 如何是两张表则会两个表都查，如果只涉及单表，则只查询一张表。
-              algorithm-expression: air_monitor_minute_record_$->{id % 2 + 1}
+              algorithm-expression: air_monitor_minute_record_$->{new java.util.Random().nextInt(9) % 2}
               # 指定分片键为PRODUCT_ID
               sharding-column: id
   # Redis 配置
@@ -90,4 +90,8 @@ spring:
 mybatis-plus:
   mapper-locations: classpath:static/**/*.xml
   configuration:
-    log-impl: org.apache.ibatis.logging.slf4j.Slf4jImpl # 指定 MyBatis 使用 SLF4J 日志实现
+    call-setters-on-nulls: on
+    log-impl: org.apache.ibatis.logging.slf4j.Slf4jImpl # 指定 MyBatis 使用 SLF4J 日志实现
+logging:
+  level:
+    com.example.classroomrealtimefeedback.mapper: debug