✨Feat: 实现消息发送方法

src/main/java/cn/hezhaohui/rabbitmq/amqp/MessageConsumer.java

@@ -14,8 +14,8 @@ public class MessageConsumer {
     // TODO: 定义队列名称常量
     // TODO: 可能需要添加日志记录
 
-    @RabbitListener(queues = "test.queue")
+//    @RabbitListener(queues = "test.queue")
-    public void receiveMessage(Message message) {
+//    public void receiveMessage(Message message) {
-        // TODO: 实现消息处理逻辑
+//        // TODO: 实现消息处理逻辑
-    }
+//    }
 }

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: 定义队列名称常量
+    public void sendEmailMessage(Message message) {
-    // TODO: 可能需要添加日志记录
+        rabbitTemplate.convertAndSend(EXCHANGE_NAME, ROUTING_KEY_EMAIL, message);
+        log.info("发送邮件消息:{}", message);
+    }
 
-    public void sendMessage(Message message) {
+    public void sendSmsMessage(Message message) {
-        // TODO: 实现发送逻辑
+        rabbitTemplate.convertAndSend(EXCHANGE_NAME, ROUTING_KEY_SMS, message);
+        log.info("发送短信消息:{}", message);
     }
 }