RabbitMQ實戰（一）Spring Boot 整合 RabbitMQ

本文主要介紹RabbitMQ基礎組件和SpringBoot整合RabbitMQ簡單示例

交換器（Exchange）

交換器就像路由器，我們先是把消息發到交換器，然后交換器再根據綁定鍵（binding key）和生產者發送消息時的路由鍵routingKey，

按照交換類型Exchange Type(fanout，direct，topic)把消息投遞到對應的隊列。（明白這個概念很重要，后面的代碼里面充分體現了這一點）。

RabbitMQ基礎知識可查看消息隊列RabbitMQ基礎知識詳解

隊列（Queue）

存放消息的隊列。

綁定（Binding）

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

加入 RabbitMQ maven 依賴

 

配置

application.yaml文件中配置

 

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 BINDING_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(BINDING_KEY);

    }

}

 

注：上面配置的是TopicExchange

實際業務中，可以配置多個隊列和binding來滿足需求。

生產者

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

 

消費者

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

 

運行項目

    運行項目，然后打開瀏覽器，輸入 http://localhost:9999/sendMessage(具體地址根據服務器)。在控制台就可以看到生產者在不停的的發送消息，消費者不斷的在消費消息。