整合rocketmq

dxcollect-controller/src/main/java/com/usky/controller/web/RocketMqController.java

@@ -0,0 +1,24 @@
+package com.usky.controller.web;
+
+import org.apache.rocketmq.spring.core.RocketMQTemplate;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
+
+@RestController
+@RequestMapping("/api")
+public class RocketMqController {
+
+    @Autowired
+    private RocketMQTemplate rocketMQTemplate;
+
+    @GetMapping("/pushMessage")
+    public String pushMessage(@RequestParam("str") String str) {
+
+        rocketMQTemplate.convertAndSend("first-topic","你好,RocketMq =>" + str);
+        return "success";
+    }
+
+}

dxcollect-controller/src/main/resources/application-dev.properties

@@ -2,7 +2,7 @@ debug=true
 spring.main.lazy-initialization=false
 spring.main.allow-bean-definition-overriding=true
 # application
-server.port=8084
+server.port=8087
 # mybatis-plus
 mybatis-plus.mapper-locations=classpath*:mapper/**/*.xml
 mybatis-plus.configuration.lazy-loading-enabled=true
@@ -16,7 +16,7 @@ mybatis.refresh.sleep-seconds=20
 # datasource
 spring.autoconfigure.exclude=com.alibaba.druid.spring.boot.autoconfigure.DruidDataSourceAutoConfigure
 spring.datasource.dynamic.primary=mast
-spring.datasource.dynamic.datasource.mast.url=jdbc:mysql://47.111.81.118:3306/dxcollect?useUnicode=true&useJDBCCompliantTimezoneShift=true&useLegacyDatetimeCode=false&serverTimezone=UTC
+spring.datasource.dynamic.datasource.mast.url=jdbc:mysql://47.111.81.118:3306/dm?useUnicode=true&useJDBCCompliantTimezoneShift=true&useLegacyDatetimeCode=false&serverTimezone=UTC
 spring.datasource.dynamic.datasource.mast.username=root
 spring.datasource.dynamic.datasource.mast.password=Yt2021
 spring.datasource.dynamic.druid.initial-size=5                                                                       
@@ -106,4 +106,7 @@ mqtt.completionTimeout=5000
 mqtt.keep-alive-interval=60
 mqtt.username=usky
 mqtt.password=usky
-mqtt.url=tcp://47.98.201.73:1883
+mqtt.url=tcp://47.98.201.73:1883
+
+rocketmq.name-server=101.133.214.75:9876
+rocketmq.producer.group=my-producer-group

dxcollect-controller/src/main/resources/application-prod.properties

@@ -2,7 +2,7 @@ debug=true
 spring.main.lazy-initialization=false
 spring.main.allow-bean-definition-overriding=true
 # application
-server.port=8084
+server.port=8087
 # mybatis-plus
 mybatis-plus.mapper-locations=classpath*:mapper/**/*.xml
 mybatis-plus.configuration.lazy-loading-enabled=true
@@ -16,7 +16,7 @@ mybatis.refresh.sleep-seconds=20
 # datasource
 spring.autoconfigure.exclude=com.alibaba.druid.spring.boot.autoconfigure.DruidDataSourceAutoConfigure
 spring.datasource.dynamic.primary=mast
-spring.datasource.dynamic.datasource.mast.url=jdbc:mysql://10.23.39.230:13306/dxcollect?useUnicode=true&useJDBCCompliantTimezoneShift=true&useLegacyDatetimeCode=false&serverTimezone=UTC
+spring.datasource.dynamic.datasource.mast.url=jdbc:mysql://10.23.39.230:13306/dm?useUnicode=true&useJDBCCompliantTimezoneShift=true&useLegacyDatetimeCode=false&serverTimezone=UTC
 spring.datasource.dynamic.datasource.mast.username=ytloT
 spring.datasource.dynamic.datasource.mast.password=E7c5azRq
 spring.datasource.dynamic.druid.initial-size=5                                                                       

dxcollect-controller/src/main/resources/application-test.properties

@@ -2,7 +2,7 @@ debug=true
 spring.main.lazy-initialization=false
 spring.main.allow-bean-definition-overriding=true
 # application
-server.port=8008
+server.port=8087
 # mybatis-plus
 mybatis-plus.mapper-locations=classpath*:mapper/**/*.xml
 mybatis-plus.configuration.lazy-loading-enabled=true

dxcollect-controller/src/test/java/com/usky/controller/DcsArchetypeApplicationTests.java

@@ -2,8 +2,6 @@ package com.usky.controller;
 
 import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
-import com.usky.model.DeviceStatus;
-import com.usky.service.DeviceStatusService;
 import org.junit.jupiter.api.Test;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.test.context.SpringBootTest;
@@ -11,15 +9,5 @@ import org.springframework.boot.test.context.SpringBootTest;
 @SpringBootTest
 class DcsArchetypeApplicationTests {
 
-    @Autowired
-    private DeviceStatusService deviceStatusService;
-
-    @Test
-    void contextLoads() {
-        LambdaUpdateWrapper<DeviceStatus> updateWrapper = Wrappers.lambdaUpdate();
-        updateWrapper.set(DeviceStatus::getDevicestatus,0)
-                .eq(DeviceStatus::getDeviceid,"90179");
-        deviceStatusService.update(updateWrapper);
-    }
 
 }

dxcollect-service/pom.xml

@@ -66,12 +66,6 @@
             <version>4.1.0</version>
         </dependency>
 
-        <!-- spring security 安全认证 -->
-        <dependency>
-            <groupId>org.springframework.boot</groupId>
-            <artifactId>spring-boot-starter-security</artifactId>
-        </dependency>
-
         <!-- 解析客户端操作系统、浏览器等 -->
         <dependency>
             <groupId>eu.bitwalker</groupId>
@@ -112,6 +106,12 @@
             <artifactId>spring-boot-starter-websocket</artifactId>
         </dependency>
 
+        <dependency>
+            <groupId>org.apache.rocketmq</groupId>
+            <artifactId>rocketmq-spring-boot-starter</artifactId>
+            <version>2.2.1</version>
+        </dependency>
+
     </dependencies>
 
 

dxcollect-service/src/main/java/com/usky/service/listener/RocketMqListener.java

@@ -0,0 +1,21 @@
+package com.usky.service.listener;
+
+
+import lombok.extern.slf4j.Slf4j;
+import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
+import org.apache.rocketmq.spring.core.RocketMQListener;
+import org.springframework.stereotype.Component;
+
+@Slf4j
+@Component
+@RocketMQMessageListener(topic = "first-topic",consumerGroup = "my-consumer-group")
+public class RocketMqListener  implements RocketMQListener<String> {
+
+    @Override
+    public void onMessage(String message) {
+
+        // 打印出消息内容
+        log.info("==============================================>");
+        System.out.println(message);
+    }
+}

dxcollect-service/src/main/java/com/usky/service/test.java

@@ -0,0 +1,4 @@
+package com.usky.service;
+
+public class test {
+}