俄羅斯：將審查iPhone等外國公司設備 保數據安全
iPhone和特斯拉都屬于在各自領域領頭羊的品牌，推出的產品也也都是數一數二的，但對于一些國家而言，它們的產品可靠性和安全性還是在限制范圍內。近日，俄羅斯聯邦通信、信息技術
環境：Spring Boot2.3.10 + RabbitMQ 3.8.12 + Erlang 23.2.5
RabbitMQ是實現了高級消息隊列協議（AMQP）的開源消息代理軟件（亦稱面向消息的中間件）。RabbitMQ服務器是用Erlang語言編寫的。所有主要的編程語言均有與代理接口通訊的客戶端庫。
Server：又稱Broker, 接受客戶端的連接，實現AMQP實體服務，這里指RabbitMQ 服務器
Connection：連接，應用程序與Broker的網絡連接。
Channel：通信通道，幾乎所有的操作都在 Channel 中進行，Channel是進行消息讀寫的通道?？蛻舳丝山⒍鄠€Channel:，每個Channel代表一個會話任務。（一個Socket連接可以創建多個Channel）
Virtual Host：虛擬主機，用于邏輯隔離，是最上層的消息路由。一個 Virtual Host 里面可以有若干個 Exchange（交換機）和 Queue（隊列）。
Binding：Exchange 和 Queue 之間的虛擬綁定關系。
Routing key：一 個路由規則，虛擬機可用它來確定如何路由一個特定消息，即交換機綁定到 Queue 的鍵。支持模式匹配，* 和#，*用來匹配一個單詞，#用來匹配多個單詞（可以是0個）這里的通配符只有在exchange的類型為topic才有效。
Queue：也稱為Message Queue,消息隊列，保存消息并將它們轉發給消費者。（接收端通過監聽Queue來接受消息）。
Message：消息，服務器和應用程序之間傳送的數據，由 Properties 和 Body 組成。Properties 可以對消息進行修飾，比如消息的優先級、延遲，過期時間，消息大小等高級特性;，Body 則就 是消息體內容。
Exchange類型：如下四種類型：fanout，headers，direct，topic。
圖片
圖片
按照上面的方式分別建立3個隊列。
圖片
將3個隊列分別于fanout-exchange進行綁定，這里在綁定時分別設定了不同的路由key，就是為了驗證fanout類型的交換機是否與routing key有關系。
發送接口：
@RestController@RequestMapping("/messages")public class MessageController { @Resource private MessageSend ms ; @GetMapping("/sendFanout") public Object send(String msg) { ms.send(msg) ; return "success" ;}}@Resourceprivate RabbitTemplate rabbitTemplate ;public void send(String msg) { logger.info("準備發送消息：{}", msg); rabbitTemplate.convertAndSend("fanout-exchange", "rk.1.2", msg) ;}這里故意設置了路由key 就是為了看fanout類型的交換機是否與routing key 有關系。
圖片
3個隊列都收到了消息，說明fanout類型的交換機與綁定queue時routing key是沒有關系的，只要綁定了該類型的交換機都會收到消息。
2、headers類型交換機
圖片
圖片
圖片
發送接口
@GetMapping("/sendHeaders")public Object sendHeaders(String msg) { ms.sendHeaders(msg) ; return "success" ;}public void sendHeaders(String msg) { logger.info("準備發送消息：{}", msg); Message message = MessageBuilder.withBody(msg.getBytes()).setHeader("a", "b").setHeader("pack", "xg").build() ; rabbitTemplate.send("headers-exchange", "rk.1.2", message) ;}注意：這里設置了Header信息與headers-exchange和headers-queue1綁定時設置的參數完全相同。
圖片
headers-queue2就沒有收到消息。如果在進行綁定時沒有設置x-match參數默認是完全要匹配綁定時設定的參數，也就是x-match:all。如下，如果不配置x-match也就相當于：
圖片
兩個隊列都收到了消息。
3、direct類型交換機
圖片
圖片
2個隊列都收到了消息。
4、topic類型交換機
圖片
圖片
圖片
兩個隊列都收到了消息。
修改發送消息的routing key
rabbitTemplate.convertAndSend("topic-exchange", "te.2.ok", msg) ;圖片
只有topic-queue2收到了消息，因為綁定時設置的routing-key 是：
圖片
能夠匹配多個單詞。
以上就介紹完了rabbitmq的四種交換機類型。
本文鏈接：http://www.tebozhan.com/showinfo-26-5752-0.htmlSpringBoot整合RabbitMQ四種交換機類型詳解
聲明：本網頁內容旨在傳播知識，若有侵權等問題請及時與本網聯系，我們將在第一時間刪除處理。郵件：2376512515@qq.com
Copyright ? 2016-2023 天津谷騏科技有限公司 版權所有 sitemap.xml
違法及侵權請聯系：2376512515@qq.com 津ICP備18001702號
津公網安備 12010102000574號