9.2.跟我学SpringBoot-接收rabbitmq消息

日常开发中都是新建一个应用来单独接收rabbitmq的消息。

1.maven依赖

<dependency>
     <groupId>org.springframework.boot</groupId>
     <artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-amqp</artifactId>
</dependency>

2.application.ymd配置

spring:
  rabbitmq:
    host: localhost
    port: 5672
    username: test1
    password: 123
    virtualHost: /

3.监听器接收消息队列RabbitmqListener.java

@Component
public class RabbitmqListener {

    /**
     * 接收消息
     *
     * @param message
     */
    @RabbitListener(queues = "test_mq")
    @RabbitHandler
    public void process(String message) {
        System.out.println("接收到消息：" + message);
    }
}

非常简单，只需要@RabbitListener(queues = "test_mq")定义接收哪个队列，@RabbitHandler作为监听执行即可。

源码下载

本例子详细源码