From 0eeee6ba1f493efc33ede00b7a0f9f1f3bbbb3c7 Mon Sep 17 00:00:00 2001
From: Wonder <hezhaohui0807@163.com>
Date: Wed, 15 Oct 2025 12:24:04 +0800
Subject: [PATCH] =?UTF-8?q?=20=E2=9C=A8Feat:=20=E5=AE=9E=E7=8E=B0=E6=B6=88?=
 =?UTF-8?q?=E6=81=AF=E5=8F=91=E9=80=81=E6=96=B9=E6=B3=95?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../rabbitmq/amqp/MessageConsumer.java        |  8 +++----
 .../rabbitmq/amqp/MessageProducer.java        | 21 ++++++++++++-------
 2 files changed, 18 insertions(+), 11 deletions(-)

diff --git a/src/main/java/cn/hezhaohui/rabbitmq/amqp/MessageConsumer.java b/src/main/java/cn/hezhaohui/rabbitmq/amqp/MessageConsumer.java
index 358d2fc..40f7fa5 100644
--- a/src/main/java/cn/hezhaohui/rabbitmq/amqp/MessageConsumer.java
+++ b/src/main/java/cn/hezhaohui/rabbitmq/amqp/MessageConsumer.java
@@ -14,8 +14,8 @@ public class MessageConsumer {
     // TODO: 定义队列名称常量
     // TODO: 可能需要添加日志记录
 
-    @RabbitListener(queues = "test.queue")
-    public void receiveMessage(Message message) {
-        // TODO: 实现消息处理逻辑
-    }
+//    @RabbitListener(queues = "test.queue")
+//    public void receiveMessage(Message message) {
+//        // TODO: 实现消息处理逻辑
+//    }
 }
diff --git a/src/main/java/cn/hezhaohui/rabbitmq/amqp/MessageProducer.java b/src/main/java/cn/hezhaohui/rabbitmq/amqp/MessageProducer.java
index ec21e03..ec245d4 100644
--- a/src/main/java/cn/hezhaohui/rabbitmq/amqp/MessageProducer.java
+++ b/src/main/java/cn/hezhaohui/rabbitmq/amqp/MessageProducer.java
@@ -3,24 +3,31 @@ package cn.hezhaohui.rabbitmq.amqp;
 import cn.hezhaohui.rabbitmq.entity.Message;
 import jakarta.annotation.Resource;
 import lombok.Data;
-import org.springframework.amqp.core.AmqpTemplate;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.amqp.rabbit.core.RabbitTemplate;
 import org.springframework.stereotype.Component;
 
+import static cn.hezhaohui.rabbitmq.constant.RabbitmqConstant.*;
+
 /**
  * 消息生产者
  */
 @Component
 @Data
+@Slf4j
 public class MessageProducer {
 
     @Resource
-    private AmqpTemplate amqpTemplate;
+    private RabbitTemplate rabbitTemplate;
 
-    // TODO: 实现发送消息的方法
-    // TODO: 定义队列名称常量
-    // TODO: 可能需要添加日志记录
+    // 实现发送消息的方法
+    public void sendEmailMessage(Message message) {
+        rabbitTemplate.convertAndSend(EXCHANGE_NAME, ROUTING_KEY_EMAIL, message);
+        log.info("发送邮件消息:{}", message);
+    }
 
-    public void sendMessage(Message message) {
-        // TODO: 实现发送逻辑
+    public void sendSmsMessage(Message message) {
+        rabbitTemplate.convertAndSend(EXCHANGE_NAME, ROUTING_KEY_SMS, message);
+        log.info("发送短信消息:{}", message);
     }
 }