這篇文章主要介紹了Spring Boot整合RabbitMQ開發(fā)的示例分析，具有一定借鑒價(jià)值，感興趣的朋友可以參考下，希望大家閱讀完這篇文章之后大有收獲，下面讓小編帶著大家一起了解一下。
RabbitMQ 中的一些術(shù)語
如果你打開 RabbitMQ web 控制臺(tái)，你會(huì)發(fā)現(xiàn)其中有一個(gè) Exhanges 不好理解。下面簡(jiǎn)單說明一下。
交換器（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 依賴
org.springframework.boot spring-boot-starter-amqp
再加入另外一個(gè)依賴（這個(gè)依賴可省略，主要是用來簡(jiǎn)化代碼）
cn.hutool hutool-all 4.0.2
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)聽的隊(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)目，然后打開瀏覽器，輸入 http://localhost:9999/sendMessage 。在控制臺(tái)就可以看到生產(chǎn)者在不停的的發(fā)送消息，消費(fèi)者不斷的在消費(fèi)消息。
打開 RabbitMQ web 控制臺(tái)，也可以看到剛才我們?cè)诖a里面配置的交換器和隊(duì)列，以及綁定信息。
點(diǎn)擊進(jìn)入交換器的詳情
感謝你能夠認(rèn)真閱讀完這篇文章，希望小編分享的“Spring Boot整合RabbitMQ開發(fā)的示例分析”這篇文章對(duì)大家有幫助，同時(shí)也希望大家多多支持創(chuàng)新互聯(lián)，關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道，更多相關(guān)知識(shí)等著你來學(xué)習(xí)!
