Spring Boot集成RabbitMQ（一）

RabbitMQ是以AMQP协议实现的一种中间件产品，几乎覆盖主流的企业级技术平台。本文仅通过一个demo介绍生产者、消费者及消息队列。

一、安装Erland和RabbitMQ

  目前维护的RabbitMQ版本系列不支持早于19.3的 Erlang / OTP版本。3.7.7之前的 RabbitMQ 版本不支持Erlang / OTP 21或更新版本。

• Erland官网：http://www.erlang.org/downloads
• RabbitMQ官网：https://www.rabbitmq.com/download.html

二、引入maven依赖并配置连接信息

<dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-amqp</artifactId>
            <version>2.0.1.RELEASE</version>
        </dependency>

spring.rabbitmq.host=localhost
spring.rabbitmq.port=5672
spring.rabbitmq.username=guest
spring.rabbitmq.password=guest

三、构建生产者、消费者、消息队列

生产者：

@Component
public class Sender {

    @Autowired
    private AmqpTemplate rabbitTemplate;

    public void send() {
        String context = "hello " + new Date();
        System.out.println("Sender : " + context);
        this.rabbitTemplate.convertAndSend("hello", context);//指明要发送到的消息队列
    }
}

消费者：

@Component
@RabbitListener(queues = "hello")//指明接受消息的消息队列
public class Receiver {

    @RabbitHandler
    public void process(String hello) {
        System.out.println("Receiver : " + hello);
    }
}

消息队列：

@Configuration
public class RabbitConfig {

    @Bean
    public Queue helloQueue() {
        return new Queue("hello");
    }

}

只要执行生产者的send()，就可发送接受消息。