久久国产精品一区二区三区四区,久色婷婷小香蕉久久,国产日韩欧美在线播放不卡,另类av一区二区

【資料圖】

大家好，我是指北君。

今天指北君帶領大家接著學習RabbitMQ，了解RabbitMQ的五大通信模型之一的發布訂閱模型；接下來還會有關于RabbitMQ的系列教程，對你有幫助的話記得關注哦~

發布訂閱模型

上一篇文章中，簡單的介紹了一下RabbitMQ的work模型。這篇文章來學習一下RabbitMQ中的發布訂閱模型。

發布訂閱模型(Publish/Subscribe)：簡單的說就是隊列里面的消息會被多個消費者同時接受到，消費者接收到的信息一致。

發布訂閱模型適合于做模塊之間的異步通信。

適用場景發送并記錄日志信息springcloud的config組件里面通知配置自動更新緩存同步微信訂閱號演示生產者

public class Producer { private static final String EXCHANGE_NAME = "exchange_publish_1"; public static void main(String[] args) throws IOException, TimeoutException { Connection connection = ConnectionUtils.getConnection(); Channel channel = connection.createChannel(); // 聲明交換機 channel.exchangeDeclare(EXCHANGE_NAME, "fanout"); // 發送消息到交換機 for (int i = 0; i < 100; i++) { channel.basicPublish(EXCHANGE_NAME, "", null, ("發布訂閱模型的第 " + i + " 條消息").getBytes()); } // 關閉資源 channel.close(); connection.close(); }}消費者

// 消費者1public class Consumer { private static final String QUEUE_NAME = "queue_publish_1"; private static final String EXCHANGE_NAME = "exchange_publish_1"; public static void main(String[] args) throws IOException, TimeoutException { Connection connection = ConnectionUtils.getConnection(); Channel channel = connection.createChannel(); // 聲明隊列 channel.queueDeclare(QUEUE_NAME, false, false, false, null); // 聲明交換機 channel.exchangeDeclare(EXCHANGE_NAME, "fanout"); // 將隊列綁定到交換機 channel.queueBind(QUEUE_NAME, EXCHANGE_NAME, ""); DefaultConsumer defaultConsumer = new DefaultConsumer(channel) { @Override public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException { System.out.println("隊列1接收到的消息是：" + new String(body)); } }; channel.basicConsume(QUEUE_NAME, true, defaultConsumer); }}

// 消費者2public class Consumer2 { private static final String QUEUE_NAME = "queue_publish_2"; private static final String EXCHANGE_NAME = "exchange_publish_1"; public static void main(String[] args) throws IOException, TimeoutException { Connection connection = ConnectionUtils.getConnection(); Channel channel = connection.createChannel(); // 聲明隊列 channel.queueDeclare(QUEUE_NAME, false, false, false, null); // 聲明交換機 channel.exchangeDeclare(EXCHANGE_NAME, "fanout"); // 將隊列綁定到交換機 channel.queueBind(QUEUE_NAME, EXCHANGE_NAME, ""); DefaultConsumer defaultConsumer = new DefaultConsumer(channel) { @Override public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException { System.out.println("隊列2接收到的消息是：" + new String(body)); } }; channel.basicConsume(QUEUE_NAME, true, defaultConsumer); }}測試

先啟動2個消費者，再啟動生產者

?可以看出來消費者1和消費者2接收到的消息是一模一樣的，每個消費者都收到了生產者發送的消息；

發布訂閱模型，用到了一個新的東西-交換機，這里也解釋一下相關方法的參數：

// 聲明交換機channel.exchangeDeclare(EXCHANGE_NAME, "fanout");// 該方法的最多參數的重載方法是：Exchange.DeclareOk exchangeDeclare(String exchange, BuiltinExchangeType type, boolean durable, boolean autoDelete, boolean internal, Map arguments) throws IOException;/** * param1：exchange，交換機名稱 * param2：type，交換機類型；直接寫 string效果一致；內置了4種交換機類型： * direct（路由模式）、fanout（發布訂閱模式）、 * topic（topic模式-模糊匹配）、headers（標頭交換，由Headers的參數分配，不常用） * param3：durable，是否持久化交換機 false：默認值，不持久化 * param4：autoDelete，沒有消費者使用時，是否自動刪除交換機 false：默認值，不刪除 * param5：internal，是否內置,如果設置 為true,則表示是內置的交換器, 客戶端程序無法直接發送消息到這個交換器中, 只能通過交換器路由到交換器的方式 false：默認值，允許外部直接訪問 * param6：arguments，交換機的一些其他屬性，默認值為 null */

// 將隊列綁定到交換機channel.queueBind(QUEUE_NAME, EXCHANGE_NAME, "");/** * param1：destination，目的地，隊列的名字 * param2：source，資源，交換機的名字 * param3：routingKey，路由鍵（目前沒有用到routingKey，填 "" 即可） */小結

本文到這里就結束了，介紹了RabbitMQ通信模型中的發布訂閱模型，適合于做模塊之間的異步通信。

關鍵詞： 通信模型 異步通信 其他屬性 直接發送