微服务框架 SpringCloud微服务架构 16 SpringAMQP 16.3 入门案例的消息接收

微服务框架

【SpringCloud+RabbitMQ+Docker+Redis+搜索+分布式，系统详解springcloud微服务技术栈课程|黑马程序员Java微服务】

SpringCloud微服务架构

16 SpringAMQP

16.3 入门案例的消息接收

16.3.1 直接开干

步骤3：在consumer中编写消费逻辑，监听simple.queue

1. 在consumer服务中编写application.yml，添加mq连接信息：

logging:
  pattern:
    dateformat: MM-dd HH:mm:ss:SSS

spring:
  rabbitmq:
    host: 1.13.13.44 # rabbitMQ 的服务IP地址
    port: 5672 # 端口
    username: itcast
    password: 123321
    virtual-host: /
1
2
3
4
5
6
7
8
9
10
11

2. 在consumer服务中新建一个类，编写消费逻辑：

package cn.itcast.mq.listener;

import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;


/**
 * ClassName: SpringRabbitListener
 * date: 2022/10/31 10:16
 *
 * @author DingJiaxiong
 */

@Component
public class SpringRabbitListener {

    @RabbitListener(queues = "simple.queue")
    public void listenerSimpleQueue(String msg){
        System.out.println("消费者接收到simple.queue的消息：【" + msg + "】");
    }
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

’

直接运行消费者的启动main 函数

效果很明显，直接把队列中那条之前发的消息消费掉了

查看控制台

再运行一次测试类，发一个不同的消息

OK，发送成功

直接查看那边的日志

这就是一直在监听，消息一生产，这边消费者就马上消费了

16.3.2 总结

SpringAMQP如何接收消息？

• 引入amqp的starter依赖
• 配置RabbitMQ地址
• 定义类，添加@Component注解
• 类中声明方法，添加@RabbitListener注解，方法参数就时消息

注意：消息一旦消费就会从队列删除，RabbitMQ没有消息回溯功能