rabbitmq

4dkankan-center-scene/pom.xml

@@ -109,6 +109,11 @@
             <version>2.3.1</version>
         </dependency>
 
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-amqp</artifactId>
+        </dependency>
+
 
     </dependencies>
 

4dkankan-center-scene/src/main/java/com/fdkankan/scene/config/RabbitMqConfig.java

@@ -0,0 +1,30 @@
+package com.fdkankan.scene.config;
+
+import org.springframework.amqp.core.Queue;
+import org.springframework.amqp.support.converter.Jackson2JsonMessageConverter;
+import org.springframework.boot.SpringBootConfiguration;
+import org.springframework.context.annotation.Bean;
+
+/**
+ * <p>
+ * TODO
+ * </p>
+ *
+ * @author dengsixing
+ * @since 2022/4/19
+ **/
+@SpringBootConfiguration
+public class RabbitMqConfig {
+
+    // 配置一个工作模型队列
+    @Bean
+    public Queue queueWork() {
+        return new Queue("queue_work_dsx");
+    }
+
+    @Bean
+    public Jackson2JsonMessageConverter messageConverter(){
+        return new Jackson2JsonMessageConverter();
+    }
+
+}

4dkankan-center-scene/src/main/java/com/fdkankan/scene/controller/TestController.java

@@ -1,11 +1,13 @@
 package com.fdkankan.scene.controller;
 
+import cn.hutool.core.date.DateUtil;
 import com.alibaba.druid.pool.DruidDataSource;
 import com.alibaba.fastjson.JSONObject;
 import com.fdkankan.common.constant.ErrorCode;
 import com.fdkankan.common.controller.BaseController;
 import com.fdkankan.common.exception.BusinessException;
 import com.fdkankan.common.response.ResultData;
+import com.fdkankan.common.util.DateExtUtil;
 import com.fdkankan.common.util.SpringUtil;
 import com.fdkankan.mq.message.BuildSceneMqMessage;
 import com.fdkankan.mq.util.RocketMQProducer;
@@ -29,6 +31,7 @@ import com.yomahub.tlog.core.mq.TLogMqWrapBean;
 import com.yomahub.tlog.id.TLogIdGenerator;
 import com.yomahub.tlog.task.spring.SpringScheduledTaskAop;
 import java.util.ArrayList;
+import java.util.Calendar;
 import java.util.Enumeration;
 import java.util.concurrent.Callable;
 import java.util.concurrent.ExecutorService;
@@ -37,6 +40,7 @@ import java.util.concurrent.Future;
 import javax.swing.Spring;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.rocketmq.client.producer.MQProducer;
+import org.springframework.amqp.rabbit.core.RabbitTemplate;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.cloud.context.config.annotation.RefreshScope;
@@ -92,6 +96,10 @@ public class TestController extends BaseController {
     @Autowired
     RedisLockUtil redisLockUtil;
 
+    @Autowired
+    private RabbitTemplate rabbitTemplate;
+
+
 
     @PostMapping("/test")
     public ResultData test(String aaa) throws Exception {
@@ -142,6 +150,12 @@ public class TestController extends BaseController {
 //        TLogIdGenerator bean = SpringUtil.getBean(TLogIdGenerator.class);
 //        log.info(bean.generateTraceId());
 
+        for(int i=0; i<1; i++){
+            BuildSceneMqMessage message = new BuildSceneMqMessage();
+            message.setFileId("hhjjS鬼地方个" + "-" + i);
+            rabbitTemplate.convertAndSend("queue_work_dsx", message);
+        }
+
         return ResultData.ok();
 
     }

4dkankan-center-scene/src/main/java/com/fdkankan/scene/listener/RabbitMqListener.java

@@ -0,0 +1,34 @@
+package com.fdkankan.scene.listener;
+
+import com.rabbitmq.client.Channel;
+import java.io.IOException;
+import java.nio.charset.StandardCharsets;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.amqp.core.Message;
+import org.springframework.amqp.rabbit.annotation.RabbitListener;
+import org.springframework.stereotype.Component;
+
+/**
+ * <p>
+ * TODO
+ * </p>
+ *
+ * @author dengsixing
+ * @since 2022/4/19
+ **/
+@Slf4j
+@Component
+public class RabbitMqListener {
+
+    @RabbitListener(queues = "queue_work_dsx",)
+    public void receiveMessageDsx(Channel channel, Message message) throws IOException {
+        String msg = new String(message.getBody(), StandardCharsets.UTF_8);
+        log.info("消费消息--------" + msg);
+        String test = null;
+        test.equals("123");
+        channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
+        log.info("接收消息");
+    }
+
+
+}

4dkankan-center-scene/src/main/resources/bootstrap-dev.yml

@@ -1,4 +1,4 @@
-+-spring:
+spring:
 #  jackson:
 #    serialization:
 #      #关闭jackson转换 实体属性空值校验
@@ -47,7 +47,7 @@
             refresh: true
       discovery:
         server-addr: 192.168.0.47:8848
-        namespace: 4dkankan-dev
+        namespace: 4dkankan-test
     sentinel:
       transport:
         dashboard: 192.168.0.47:8888
@@ -73,6 +73,19 @@
             groupId: SENTINEL_GROUP
             namespace: 4dkankan-dev
             rule-type: degrade
+  rabbitmq:
+    host: 120.25.146.52
+    port: 5672
+    username: guest
+    password: 4dagecui2019$
+    virtual-host: /
+    listener:
+      direct:
+        acknowledge-mode: manual
+      simple:
+        retry:
+          max-attempts: 3
+          enabled: true
 #      log:
 #        dir: ./logs # 默认值${home}/logs/csp/
 #        switch-pid: true # 日志带上线程id

4dkankan-center-scene/src/main/resources/bootstrap-test.yml

@@ -18,7 +18,7 @@ spring:
   cloud:
     nacos:
       config:
-        server-addr: 172.18.156.39:8848
+        server-addr: 120.24.144.164:8848
         file-extension: yaml
         namespace: 4dkankan-test
         extension-configs:
@@ -46,7 +46,7 @@ spring:
             group: DEFAULT_GROUP
             refresh: true
       discovery:
-        server-addr: 172.18.156.39:8848
+        server-addr: 120.24.144.164:8848
         namespace: 4dkankan-test
     sentinel:
       transport:
@@ -73,6 +73,15 @@ spring:
             groupId: SENTINEL_GROUP
             namespace: 4dkankan-test
             rule-type: degrade
+  rabbitmq:
+    host: 120.25.146.52
+    port: 5672
+    username: guest
+    password: 4dagecui2019$
+    virtual-host: /
+    listener:
+      direct:
+        acknowledge-mode: manual
 #      log:
 #        dir: ./logs # 默认值${home}/logs/csp/
 #        switch-pid: true # 日志带上线程id
@@ -89,3 +98,6 @@ feign:
 
 
 
+
+
+