SpringBoot整合RabbitMQ-消费者
主要流程是：
1.创建Springboot工程
2.依赖引入
3.编写yml配置
4.编写监听类，使用@RabbitListener完成队列监听
1.略
2.依赖引入
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-amqp</artifactId>
</dependency>
</dependencies>
3.yml配置
# 配置RabbitMQ的基本信息
spring:
rabbitmq:
host: 127.0.0.1
port: 5672
username: guest
password: guest
virtual-host: /
4.编写监听类
package cn.sysu.listener;
import org.springframework.amqp.core.Message;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;
@Component
public class RabbitMQListener {
public static final String QUEUE_NAME1 = "ming-queue1";
public static final String QUEUE_NAME2 = "ming-queue2";
@RabbitListener(queues = QUEUE_NAME1)
public void getMessageFromQueue1(Message message){
System.out.println(message);
System.out.println(new String(message.getBody()));
}
@RabbitListener(queues = QUEUE_NAME2)
public void getMessageFromQueue2(Message message){
System.out.println(message);
System.out.println(new String(message.getBody()));
}
}
启动Springboot，监听队列
接受消息成功
博主的坚持 离不开大家评论和点赞，感谢大家支持！！！
