diff --git a/driver/pom.xml b/driver/pom.xml
index 51057f2..2775104 100644
--- a/driver/pom.xml
+++ b/driver/pom.xml
@@ -21,10 +21,10 @@
org.springframework.boot
spring-boot-starter-actuator
-
-
-
-
+
+ org.springframework.boot
+ spring-boot-starter-amqp
+
net.coobird
thumbnailator
diff --git a/driver/src/main/java/xyz/longicorn/driver/config/RabbitConfig.java b/driver/src/main/java/xyz/longicorn/driver/config/RabbitConfig.java
new file mode 100644
index 0000000..1a73daf
--- /dev/null
+++ b/driver/src/main/java/xyz/longicorn/driver/config/RabbitConfig.java
@@ -0,0 +1,47 @@
+package xyz.longicorn.driver.config;
+
+import org.springframework.amqp.core.Binding;
+import org.springframework.amqp.core.BindingBuilder;
+import org.springframework.amqp.core.DirectExchange;
+import org.springframework.amqp.core.Queue;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+@Configuration
+public class RabbitConfig {
+ // 要订阅消息队列的主题
+ public static final String RABBITMQ_DEFAULT_TOPIC = "default_message_topic";
+ public static final String RABBITMQ_DEFAULT_DIRECT_EXCHANGE = "default_message_exchange";
+ public static final String RABBITMQ_DEFAULT_DIRECT_ROUTING = "default_message_routing";
+ // 队列
+ @Bean
+ public Queue rabbitmqDemoDirectQueue() {
+ /**
+ * 1、name: 队列名称
+ * 2、durable: 是否持久化
+ * 3、exclusive: 是否独享、排外的。如果设置为true，定义为排他队列。则只有创建者可以使用此队列。也就是private私有的。
+ * 4、autoDelete: 是否自动删除。也就是临时队列。当最后一个消费者断开连接后，会自动删除。
+ * */
+ return new Queue(RABBITMQ_DEFAULT_TOPIC, true, false, false);
+ }
+
+ // 交换机
+ @Bean
+ public DirectExchange rabbitmqDemoDirectExchange() {
+ //Direct交换机
+ return new DirectExchange(RABBITMQ_DEFAULT_DIRECT_EXCHANGE, true, false);
+ }
+
+ // 队列与交换机的绑定
+ @Bean
+ public Binding bindDirect() {
+ //链式写法，绑定交换机和队列，并设置匹配键
+ return BindingBuilder
+ //绑定队列
+ .bind(rabbitmqDemoDirectQueue())
+ //到交换机
+ .to(rabbitmqDemoDirectExchange())
+ //并设置匹配键
+ .with(RABBITMQ_DEFAULT_DIRECT_ROUTING);
+ }
+}
diff --git a/driver/src/main/java/xyz/longicorn/driver/consumer/RabbitMessageConsumer.java b/driver/src/main/java/xyz/longicorn/driver/consumer/RabbitMessageConsumer.java
new file mode 100644
index 0000000..b328bcb
--- /dev/null
+++ b/driver/src/main/java/xyz/longicorn/driver/consumer/RabbitMessageConsumer.java
@@ -0,0 +1,20 @@
+package xyz.longicorn.driver.consumer;
+
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.amqp.rabbit.annotation.RabbitHandler;
+import org.springframework.amqp.rabbit.annotation.RabbitListener;
+import org.springframework.stereotype.Component;
+import xyz.longicorn.driver.config.RabbitConfig;
+
+import java.util.Map;
+
+@Component
+@RabbitListener(queues = RabbitConfig.RABBITMQ_DEFAULT_TOPIC) // 设置要监听队列的主题名称
+@Slf4j
+public class RabbitMessageConsumer {
+ // 处理消息的方法 参数取决去发送消息的数据类型
+ @RabbitHandler
+ public void processMessage(Map map) {
+ log.info("获取到一条消息:" + map.toString());
+ }
+}
diff --git a/driver/src/main/java/xyz/longicorn/driver/controller/MessageQueueController.java b/driver/src/main/java/xyz/longicorn/driver/controller/MessageQueueController.java
new file mode 100644
index 0000000..61057f4
--- /dev/null
+++ b/driver/src/main/java/xyz/longicorn/driver/controller/MessageQueueController.java
@@ -0,0 +1,20 @@
+package xyz.longicorn.driver.controller;
+
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+import xyz.longicorn.driver.service.RabbitMQService;
+
+import javax.annotation.Resource;
+
+@RestController
+public class MessageQueueController {
+
+ @Resource
+ private RabbitMQService rabbitMQService;
+
+ @RequestMapping("/send-msg")
+ public String sendMessage(String message) {
+ rabbitMQService.sendMessage(message);
+ return "send message success";
+ }
+}
diff --git a/driver/src/main/java/xyz/longicorn/driver/service/RabbitMQService.java b/driver/src/main/java/xyz/longicorn/driver/service/RabbitMQService.java
new file mode 100644
index 0000000..e090611
--- /dev/null
+++ b/driver/src/main/java/xyz/longicorn/driver/service/RabbitMQService.java
@@ -0,0 +1,43 @@
+package xyz.longicorn.driver.service;
+
+import cn.hutool.core.lang.UUID;
+import org.springframework.amqp.rabbit.core.RabbitTemplate;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import xyz.longicorn.driver.config.RabbitConfig;
+
+import javax.annotation.Resource;
+import java.text.SimpleDateFormat;
+import java.util.Date;
+import java.util.HashMap;
+import java.util.Map;
+
+@Service
+public class RabbitMQService {
+
+ @Resource
+ private RabbitTemplate rabbitTemplate;
+
+ private static SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+
+ public boolean sendMessage(String message) {
+ try {
+ String msgId = UUID.fastUUID().toString();
+ String sendTime = sdf.format(new Date());
+ Map map = new HashMap<>();
+ map.put("id", msgId);
+ map.put("sendTime", sendTime);
+ map.put("message", message);
+
+ // 发送
+ rabbitTemplate.convertAndSend(
+ RabbitConfig.RABBITMQ_DEFAULT_DIRECT_EXCHANGE, // 接收消息的交换机
+ RabbitConfig.RABBITMQ_DEFAULT_DIRECT_ROUTING, // 发送消息的路由
+ map);
+ return true;
+ } catch (Exception e) {
+ e.printStackTrace();
+ return false;
+ }
+ }
+}
diff --git a/driver/src/main/resources/application.yml b/driver/src/main/resources/application.yml
index b5cce1a..5a901e4 100644
--- a/driver/src/main/resources/application.yml
+++ b/driver/src/main/resources/application.yml
@@ -61,7 +61,11 @@ spring:
# redis缓存
redis:
database: 1
-
+ rabbitmq:
+ host: 127.0.0.1
+ port: 5672
+ username: client
+ password: 123123
mvc:
pathmatch:
# 因为Springfox使用的路径匹配是基于AntPathMatcher的，而Spring Boot 2.6.X使用的是PathPatternMatcher。