整合rocketmq；

pom.xml

@@ -140,7 +140,17 @@
             <groupId>org.apache.commons</groupId>
             <artifactId>commons-lang3</artifactId>
         </dependency>
-
+<!--        springboot整合rocketmq-->
+        <dependency>
+            <groupId>org.apache.rocketmq</groupId>
+            <artifactId>rocketmq-spring-boot-starter</artifactId>
+            <version>2.2.1</version>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.rocketmq</groupId>
+            <artifactId>rocketmq-client</artifactId>
+            <version>4.9.3</version>
+        </dependency>
     </dependencies>
     <dependencyManagement>
         <dependencies>

src/main/java/com/unissoft/mqConsumer/TeDataConsumer.java

@@ -0,0 +1,45 @@
+package com.unissoft.mqConsumer;
+
+import com.alibaba.fastjson.JSON;
+import com.unissoft.interaction.entity.TeData;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.rocketmq.common.TopicConfig;
+import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
+import org.apache.rocketmq.spring.core.RocketMQListener;
+import org.springframework.stereotype.Component;
+import org.springframework.stereotype.Service;
+
+/**
+ * ClassName: ConService
+ * Package: com.unissoft.mqConsumer
+ * Description:
+ *
+ * @Author zlq
+ * @Create 2023/3/2 10:36
+ * @Version 1.0
+ */
+@Slf4j
+@Component
+@RocketMQMessageListener(topic = "TOPIC_LOCAL",consumerGroup = "${rocketmq.consumer.group}",selectorExpression = "teData")
+public class TeDataConsumer implements RocketMQListener<TeData> {
+
+    @Override
+    public void onMessage(TeData s) {
+        System.out.println("接收到的消息"+s.toString());
+    }
+//
+//    // topic需要和生产者的topic一致，consumerGroup属性是必须指定的，内容可以随意
+//    // selectorExpression的意思指的就是tag，默认为“*”，不设置的话会监听所有消息
+//    @Service
+//    @RocketMQMessageListener(topic = "TOPIC_1", selectorExpression = "tag1", consumerGroup = "Con_Group_One")
+//    public class ConsumerSend implements RocketMQListener<TeData> {
+//
+//        // 监听到消息就会执行此方法
+//        @Override
+//        public void onMessage(TeData teData) {
+//            System.out.println("接收到的消息"+teData.toString());
+//            log.info("监听到消息：user={}", JSON.toJSONString(teData));
+//        }
+//    }
+
+}

src/main/java/com/unissoft/systemManage/controller/UserInfoController.java

@@ -4,6 +4,7 @@ package com.unissoft.systemManage.controller;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.unissoft.common.*;
+import com.unissoft.mqProducer.Producer;
 import com.unissoft.systemManage.model.UserInfo;
 import com.unissoft.systemManage.service.UserInfoService;
 import com.unissoft.utils.JWTUtil;
@@ -38,6 +39,8 @@ import java.util.UUID;
 public class UserInfoController {
 
     private UserInfoService userInfoService;
+    @Autowired
+    private Producer producer;
 
     @Autowired
     public void setUserInfoController(UserInfoService userInfoService) {
@@ -72,6 +75,7 @@ public class UserInfoController {
         userInfo.setUserPassword(MD5Util.getMD5(userInfo.getUserPassword()));
         String s = UUID.randomUUID().toString().trim().replaceAll("_", "");
         userInfo.setUserId(s);
+        producer.send(userInfo,"userInfo");
         boolean save = userInfoService.save(userInfo);
         if (save)
             return ResultView.success();

src/main/resources/bootstrap.yml

@@ -13,11 +13,12 @@ spring:
     driver-class-name: com.mysql.cj.jdbc.Driver
     #username: root
     #password: 123456
-    #url: jdbc:mysql://127.0.0.1:3306/numberEC?characterEncoding=utf-8&useSSL=false&serverTimezone=Asia/Shanghai
+#    url: jdbc:mysql://127.0.0.1:3306/numberec?characterEncoding=utf-8&useSSL=false&serverTimezone=Asia/Shanghai
     username: root
     password: 123456
     # 06 to 02 可外网访问，不必vpn。
-    url: jdbc:mysql://101.36.160.140:31004/numberEC?characterEncoding=utf-8&useSSL=false&serverTimezone=UTC
+#    url: jdbc:mysql://101.36.160.140:31004/numberEC?characterEncoding=utf-8&useSSL=false&serverTimezone=UTC
+    url: jdbc:mysql://101.36.160.140:31004/numberEC?characterEncoding=utf-8&useSSL=false&serverTimezone=GMT%2B8
 
     # Hikari pool https://github.com/brettwooldridge/HikariCP
     type: com.zaxxer.hikari.HikariDataSource
@@ -57,7 +58,17 @@ spring:
     title: spring-boot-starter-swagger
     version: 1.1.0.RELEASE
 mybatis-plus:
-  # 如果是放在resource目录 classpath:/mapper/**.xml或(多包)classpath:/mapper/*/**.xml
-  mapper-locations: classpath:/mapper/*/**.xml
+#  # 如果是放在resource目录 classpath:/mapper/**.xml或(多包)classpath:/mapper/*/**.xml
+  mapper-locations: classpath:/mapper/*/*.xml
 # 操作日志版本号,或启动时写入
-version: 20121021
+version: 20121021
+
+rocketmq:
+  name-server: 192.168.8.142:9876 # 访问地址
+  consumer:
+    group: consumer_number
+  producer:
+    group: Group_local # 必须指定group
+    send-message-timeout: 3000 # 消息发送超时时长，默认3s
+    retry-times-when-send-failed: 3 # 同步发送消息失败重试次数，默认2
+    retry-times-when-send-async-failed: 3 # 异步发送消息失败重试次数，默认2