RabbitMQ之訂閱模式

2021-09-24 04:18:38 字數 991 閱讀 4465

rabbitmq之訂閱模式簡介

乙個生產者,多個消費者

每乙個消費者都有自己的佇列

生產者沒有直接將訊息傳送到佇列中去,而是傳送到了交換機或者**器(exchange)中

每個佇列都要繫結到交換機上

生產者傳送的訊息,經過互動機到達佇列就能實現乙個訊息被多個消費者消費

**參考

生產者

/**

* 訂閱模式

* * @author zhang

* * 乙個生產者,多個消費者 每乙個消費者都有自己的佇列 生產者沒有直接將訊息傳送到佇列中去,而是傳送到了交換機或者**器(exchange)中

* 每個佇列都要繫結到交換機上 生產者傳送的訊息,經過互動機到達佇列就能實現乙個訊息被多個消費者消費

* **/public class subscribesend

}

消費者1

/**

* 訂閱 消費者1

* * @author zhang

* */

public class subscriberec1

};// 監聽資料

channel.basicconsume(queue_name, false, consumer);

}}

消費者2

/**

* 訂閱 消費者1

* * @author zhang

* */

public class subscriberec2

};// 監聽資料

channel.basicconsume(queue_name, false, consumer);

}}

rabbitmq 發布訂閱模式

上篇我們已經講過了工作模式和簡單模式的用法。而這節我們就要開始講一下後面三種的第一種,在我們平常開發中,其實用的比較多的是後面的這三種。發布訂閱模式 英文叫publish subscribe,發布訂閱模式也稱為廣播模式,在exchange下屬於fanout模式。廣播,大家應該都知道吧,在mq中,其實...

RabbitMQ發布 訂閱模式

1 生產者 package com.ys.ps import com.rabbitmq.client.channel import com.rabbitmq.client.connection import com.ys.utils.connectionutil create by ysocean ...

RabbitMQ 三 訊息訂閱模式

佇列1繫結 user.表示其只關注使用者相關的訊息。佇列2繫結 order 表示其只關注訂單相關的訊息。佇列3繫結 svip.表示其只關注svip使用者相關的訊息。當傳送訊息指定 vip.user.order 時,因為佇列1與佇列2能匹配,所以會被傳送到佇列1 2中。如果傳送資訊為 common.u...