Spring Boot整合RabbitMQ開(kāi)發(fā)實(shí)戰(zhàn)詳解

更新時(shí)間：2018年02月05日 11:24:46 作者：皂白

這篇文章主要介紹了Spring Boot整合RabbitMQ開(kāi)發(fā)實(shí)戰(zhàn)，小編覺(jué)得挺不錯(cuò)的，現(xiàn)在分享給大家，也給大家做個(gè)參考。一起跟隨小編過(guò)來(lái)看看吧

這篇文章主要講基本的整合。先把代碼跑起來(lái)，再說(shuō)什么高級(jí)特性。

RabbitMQ 中的一些術(shù)語(yǔ)

如果你打開(kāi) RabbitMQ web 控制臺(tái)，你會(huì)發(fā)現(xiàn)其中有一個(gè) Exhanges 不好理解。下面簡(jiǎn)單說(shuō)明一下。

交換器（Exchange）

交換器就像路由器，我們先是把消息發(fā)到交換器，然后交換器再根據(jù)路由鍵（routingKey）把消息投遞到對(duì)應(yīng)的隊(duì)列。（明白這個(gè)概念很重要，后面的代碼里面充分體現(xiàn)了這一點(diǎn)）

隊(duì)列（Queue）

隊(duì)列很好理解，就不用解釋了。

綁定（Binding）

交換器怎么知道把這條消息投遞到哪個(gè)隊(duì)列呢？這就需要用到綁定了。大概就是：使用某個(gè)路由鍵（routingKey）把某個(gè)隊(duì)列（Queue）綁定到某個(gè)交換器（Exchange），這樣交換器就知道根據(jù)路由鍵把這條消息投遞到哪個(gè)隊(duì)列了。（后面的代碼里面充分體現(xiàn)了這一點(diǎn)）

加入 RabbitMQ maven 依賴

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

再加入另外一個(gè)依賴（這個(gè)依賴可省略，主要是用來(lái)簡(jiǎn)化代碼）

<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";

 // 創(chuàng)建隊(duì)列
 @Bean
 public Queue queue() {
 return new Queue(QUEUE_NAME);
 }

 // 創(chuàng)建一個(gè) topic 類型的交換器
 @Bean
 public TopicExchange exchange() {
 return new TopicExchange(EXCHANGE_NAME);
 }

 // 使用路由鍵（routingKey）把隊(duì)列（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);
 }

}

生產(chǎn)者

直接調(diào)用 rabbitTemplate 的 convertAndSend 方法就可以了。從下面的代碼里也可以看出，我們不是把消息直接發(fā)送到隊(duì)列里面的，而是先發(fā)送到了交換器，交換器再根據(jù)路由鍵把我們的消息投遞到對(duì)應(yīng)的隊(duì)列。

@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";
 }

}

消費(fèi)者

消費(fèi)者也很簡(jiǎn)單，只需要對(duì)應(yīng)的方法上加入 @RabbitListener 注解，指定需要監(jiān)聽(tīng)的隊(duì)列名稱即可。

@Component
public class Consumer {

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

運(yùn)行項(xiàng)目

運(yùn)行項(xiàng)目，然后打開(kāi)瀏覽器，輸入 http://localhost:9999/sendMessage 。在控制臺(tái)就可以看到生產(chǎn)者在不停的的發(fā)送消息，消費(fèi)者不斷的在消費(fèi)消息。