本文主要介紹RabbitMQ基礎組件和SpringBoot整合RabbitMQ簡單示例
交換器（Exchange）
交換器就像路由器，我們先是把消息發到交換器，然後交換器再根據綁定鍵（binding key）和生產者發送消息時的路由鍵routingKey，
按照交換類型Exchange Type(fanout，direct，topic)把消息投遞到對應的隊列。（明白這個概念很重要，後面的代碼裡面充分體現了這一點）。
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 方法就可以了。從下面的代碼裡也可以看出，我們不是把消息直接發送到隊列裡面的，而是先發送到了交換器，交換器再根據路由鍵把我們的消息投遞到對應的隊列。
@RestController
public class ProducerController {
@Autowired
private RabbitTemplate rabbitTemplate;
@GetMapping("/sendMessage")
public String 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 註解，指定需要監聽的隊列名稱即可。
運行項目
運行項目，然後打開瀏覽器，輸入 http://localhost:9999/sendMessage(具體地址根據服務器)。在控制檯就可以看到生產者在不停的的發送消息，消費者不斷的在消費消息。
控制檯
打開 RabbitMQ web 控制檯，也可以看到剛才我們在代碼裡面配置的交換器和隊列，以及綁定信息。
查看交換器的詳情
查看隊列
閱讀更多 Java資深研發 的文章
