RabbitMQ 實戰（二）Spring Boot 整合 RabbitMQ

時間 2019-11-10

標籤 rabbitmq 實戰 spring boot 整合欄目 RabbitMQ 简体版

原文原文鏈接

這篇文章主要講基本的整合。先把代碼跑起來，再說什麼高級特性。java

RabbitMQ 中的一些術語

若是你打開 RabbitMQ web 控制檯，你會發現其中有一個 Exhanges 很差理解。下面簡單說明一下。git

交換器（Exchange）

交換器就像路由器，咱們先是把消息發到交換器，而後交換器再根據路由鍵（routingKey）把消息投遞到對應的隊列。（明白這個概念很重要，後面的代碼裏面充分體現了這一點）github

隊列（Queue）

隊列很好理解，就不用解釋了。web

綁定（Binding）

交換器怎麼知道把這條消息投遞到哪一個隊列呢？這就須要用到綁定了。大概就是：使用某個路由鍵（routingKey）把某個隊列（Queue）綁定到某個交換器（Exchange），這樣交換器就知道根據路由鍵把這條消息投遞到哪一個隊列了。（後面的代碼裏面充分體現了這一點）spring

加入 RabbitMQ maven 依賴

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

再加入另一個依賴（這個依賴可省略，主要是用來簡化代碼）瀏覽器

<dependency>
    <groupId>cn.hutool</groupId>
    <artifactId>hutool-all</artifactId>
    <version>4.0.2</version>
</dependency>

RabbitMQConfig.java 配置

@Configuration
public class RabbitMQConfig {

    public final static String QUEUE_NAME = "spring-boot-queue";
    public final static String EXCHANGE_NAME = "spring-boot-exchange";
    public final static String ROUTING_KEY = "spring-boot-key";

    // 建立隊列
    @Bean
    public Queue queue() {
        return new Queue(QUEUE_NAME);
    }

    // 建立一個 topic 類型的交換器
    @Bean
    public TopicExchange exchange() {
        return new TopicExchange(EXCHANGE_NAME);
    }

    // 使用路由鍵（routingKey）把隊列（Queue）綁定到交換器（Exchange）
    @Bean
    public Binding binding(Queue queue, TopicExchange exchange) {
        return BindingBuilder.bind(queue).to(exchange).with(ROUTING_KEY);
    }

    @Bean
    public ConnectionFactory connectionFactory() {
        CachingConnectionFactory connectionFactory = new CachingConnectionFactory("127.0.0.1", 5672);
        connectionFactory.setUsername("guest");
        connectionFactory.setPassword("guest");
        return connectionFactory;
    }

    @Bean
    public RabbitTemplate rabbitTemplate(ConnectionFactory connectionFactory) {
        return new RabbitTemplate(connectionFactory);
    }

}

生產者

直接調用 rabbitTemplate 的 convertAndSend 方法就能夠了。從下面的代碼裏也能夠看出，咱們不是把消息直接發送到隊列裏面的，而是先發送到了交換器，交換器再根據路由鍵把咱們的消息投遞到對應的隊列。app

@RestController
public class ProducerController {

    @Autowired
    private RabbitTemplate rabbitTemplate;

    @GetMapping("/sendMessage")
    public Object sendMessage() {
        new Thread(() -> {
            for (int i = 0; i < 100; i++) {
                String value = new DateTime().toString("yyyy-MM-dd HH:mm:ss");
                Console.log("send message {}", value);
                rabbitTemplate.convertAndSend(RabbitMQConfig.EXCHANGE_NAME, RabbitMQConfig.ROUTING_KEY, value);
            }
        }).start();
        return "ok";
    }

}

消費者

消費者也很簡單，只須要對應的方法上加入 @RabbitListener 註解，指定須要監聽的隊列名稱便可。maven

@Component
public class Consumer {

    @RabbitListener(queues = RabbitMQConfig.QUEUE_NAME)
    public void consumeMessage(String message) {
        Console.log("consume message {}", message);
    }
}