模型
路由模式與發布訂閱模式非常相似,但是路由模式增加了路由鍵的配置,生產者在傳送訊息到交換機的時候會指定乙個routingkey,用於匹配佇列,同時佇列繫結到交換機時也會指定routingkey,交換機在向佇列傳送訊息時,會根據routingkey來匹配。
生產者
public
class
provider
}
channel.exchangedeclare(exchange_name, 「direct」),宣告交換機的時候direct說明使用路由模式,傳送訊息的時候指定routingkey。
消費者
public
class
reciver2};
channel.
basicconsume
(qunue_name,
true
, consumer);}
}
繫結到交換機的時候指明routingkey
從web頁面可以看到申明的交換機是direct模式
同時繫結到交換機上的佇列是否有routingkey
rabbitmq路由模式 訂閱 主題
1.依賴 junit junit 4.12 test com.rabbitmq amqp client 3.5.1 2.訊息提供者 public class test 4 direct provider 3.訊息接收者 public class test 4 direct consumer1 6,連...
RabbitMQ 04 訂閱模式 路由模式
即向多個消費者傳遞同一條資訊 1 exchanges 交換機 rabbitmq訊息傳遞模型的核心思想是,生產者永遠不會將任何訊息直接傳送到佇列。相反,生產者只能向交換機 exchange 傳送訊息。交換機是乙個非常簡單的東西。一邊接收來自生產者的訊息,另一邊將訊息推送到佇列。交換器必須確切地知道如何...
RabbitMQ六中工作模式 路由模式
在發布和訂閱模式中,我們構建了乙個簡單的日誌系統。我們能夠向多個接收者廣播日誌訊息。在路由模式,我們將向其新增乙個特性 我們將只訂閱所有訊息中的一部分。例如,我們只接收關鍵錯誤訊息並儲存到日誌檔案 以節省磁碟空間 同時仍然能夠在控制台上列印所有日誌訊息。在發布和訂閱模式中,我們已經建立了佇列與交換機...