博客

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，监听队列



接受消息成功

博主的

坚持

离不开大家评论和点赞，感谢大家支持！！！