前言
本系列Demo均以SpringBoot快速構建，基本包使用到lombok（一個便捷的對象構造工具 get/set）、spring-boot-starter-web，使用SpringBoot僅為了快速構建Sample項目，對于學習Spring的對應功能無影響。
我們希望你已經有一定的java基礎與了解一個自己喜歡的IDEA功能，謝謝。
GitHub
地址：https://github.com/UncleCatMySelf/Spring-Tutorial
學習
完成設置發布和訂閱消息的RabbitMQ AMQP服務器的過程。
構建
構建一個使用Spring AMQP發布消息的應用程序，RabbitTemplate并使用POJO訂閱消息MessageListenerAdapter。
創建Rabbit MQ消息接收器
使用任何基于消息傳遞的應用程序，您需要創建一個響應已發布消息的接收器。
@Slf4j@Componentpublic class Receiver { private CountDownLatch latch = new CountDownLatch(1); public void receiveMessage(String message){ log.info("Received < " + message + " >"); latch.countDown(); } public CountDownLatch getLatch(){ return latch; }}Receiver是一個簡單的POJO，它定義了一種接收消息的方法。當您注冊它以接收消息時，您可以將其命名為任何您想要的名稱。
為方便起見，這個POJO也有一個CountDownLatch。這允許它發信號通知接收到消息。這是您不太可能在生產應用程序中實現的。
注冊監聽器并發送消息
Spring AMQP RabbitTemplate 提供了使用RabbitMQ發送和接收消息所需的一切。具體來說，你需要配置：
Spring Boot會自動創建連接工廠和RabbitTemplate，從而減少您必須編寫的代碼量。
您將使用RabbitTemplate發送消息，并將Receiver使用消息偵聽器容器注冊，以接收消息。連接工廠驅動兩者，允許它們連接到RabbitMQ服務器。
@SpringBootApplicationpublic class RabbitmqApplication { static final String topicExchangeName = "spring-boot-exchange"; static final String queueName = "spring-boot"; @Bean Queue queue(){ return new Queue(queueName, false); } @Bean TopicExchange exchange(){ return new TopicExchange(topicExchangeName); } @Bean Binding binding(Queue queue,TopicExchange exchange){ return BindingBuilder.bind(queue).to(exchange).with("foo.bar.#"); } @Bean SimpleMessageListenerContainer container(ConnectionFactory connectionFactory, MessageListenerAdapter listenerAdapter){ SimpleMessageListenerContainer container = new SimpleMessageListenerContainer(); container.setConnectionFactory(connectionFactory); container.setQueueNames(queueName); container.setMessageListener(listenerAdapter); return container; } @Bean MessageListenerAdapter listenerAdapter(Receiver receiver){ return new MessageListenerAdapter(receiver, "receiveMessage"); } public static void main(String[] args) { SpringApplication.run(RabbitmqApplication.class, args).close(); }}@SpringBootApplication 是一個便利注釋，添加了以下所有內容：
該main()方法使用Spring Boot的SpringApplication.run()方法來啟動應用程序。您是否注意到沒有一行XML？也沒有web.xml文件。此Web應用程序是100％純Java，您無需處理配置任何管道或基礎結構。
listenerAdapter()方法中定義的bean在定義的容器中注冊為消息偵聽器container()。它將偵聽“spring-boot”隊列中的消息。因為Receiver該類是POJO，所以需要將其包裝在MessageListenerAdapter指定要調用的位置receiveMessage。
JMS隊列和AMQP隊列具有不同的語義。例如，JMS僅向一個使用者發送排隊的消息。雖然AMQP隊列執行相同的操作，但AMQP生成器不會直接向隊列發送消息。相反，消息被發送到交換機，交換機可以轉到單個隊列，或扇出到多個隊列，模仿JMS主題的概念。
消息監聽器容器和接收器bean是您監聽消息所需的全部內容。要發送消息，您還需要一個Rabbit模板。
該queue()方法創建AMQP隊列。該exchange()方法創建主題交換。該binding()方法將這兩者綁定在一起，定義RabbitTemplate發布到交換時發生的行為。
Spring AMQP要求將the Queue，the TopicExchange，和Binding聲明為頂級Spring bean才能正確設置。
在這種情況下，我們使用主題交換，并且隊列與路由密鑰綁定，foo.bar.#這意味著使用以路由鍵開頭的任何消息foo.bar.將被路由到隊列。
發送測試消息
測試消息由CommandLineRunner,他還等待接收器中的鎖存器并關閉應用程序上下文：
@Slf4j@Componentpublic class Runner implements CommandLineRunner { private final RabbitTemplate rabbitTemplate; private final Receiver receiver; public Runner(Receiver receiver, RabbitTemplate rabbitTemplate){ this.receiver = receiver; this.rabbitTemplate = rabbitTemplate; } @Override public void run(String... strings) throws Exception { log.info("Sending message...."); rabbitTemplate.convertAndSend(RabbitmqApplication.topicExchangeName,"foo.bar.baz","Hello from RabbitMQ!"); receiver.getLatch().await(10000, TimeUnit.MILLISECONDS); }}請注意，模板將消息路由到交換機，其路由密鑰foo.bar.baz與綁定匹配。
可以在測試中模擬出運行器，以便可以單獨測試接收器。
運行程序，你應該看到如下輸出：
2018-12-03 10:23:46.779 INFO 10828 --- [ main] o.s.b.w.embedded.tomcat.TomcatWebServer : Tomcat started on port(s): 8080 (http) with context path ''2018-12-03 10:23:46.782 INFO 10828 --- [ main] c.g.unclecatmyself.RabbitmqApplication : Started RabbitmqApplication in 3.61 seconds (JVM running for 4.288)2018-12-03 10:23:46.784 INFO 10828 --- [ main] com.github.unclecatmyself.Runner : Sending message....2018-12-03 10:23:46.793 INFO 10828 --- [ container-1] com.github.unclecatmyself.Receiver : Received < Hello from RabbitMQ! >2018-12-03 10:23:46.799 INFO 10828 --- [ main] o.s.a.r.l.SimpleMessageListenerContainer : Waiting for workers to finish.2018-12-03 10:23:47.813 INFO 10828 --- [ main] o.s.a.r.l.SimpleMessageListenerContainer : Successfully waited for workers to finish.2018-12-03 10:23:47.815 INFO 10828 --- [ main] o.s.s.concurrent.ThreadPoolTaskExecutor : Shutting down ExecutorService 'applicationTaskExecutor'2018-12-03 10:23:47.816 INFO 10828 --- [ main] o.s.a.r.l.SimpleMessageListenerContainer : Shutdown ignored - container is not active already
結尾
恭喜！您剛剛使用Spring和RabbitMQ開發了一個簡單的發布 - 訂閱應用程序。
以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支持VeVb武林網。
新聞熱點
疑難解答
圖片精選
