我們在amqp及rabbitmq概論中,介紹交換器型別的時候,就曾提到過topic模式,該模式其實和activemq萬用字元式訂閱非常的類似,所以這裡我們就不過於詳細介紹了,直接來簡單看一下小例子吧。
和rabbitmq中的direct、fanout模式類似,在使用時,我們只需將交換器的型別修改為topic
即可,然後我們通過生產者來發布訊息,這裡我們就一共發布了9條測試訊息,如下:
public
class
topicproducer
;for
(int i =
0; i < loglevels.length; i++
) channel.
close()
; connection.
close();}}
然後我們來看一看消費者是如何通過#
、*
來獲取指定的訊息的,這裡我們先來獲取所有的訊息,如下:
public
class
topicconsumer};
//消費者正式開始在指定佇列上消費訊息
上述我們使用了#
就獲取到了所有的訊息,但是我們現在有改變需求了,只想獲取所有的error訊息,那麼該如何進行處理呢?如下
那麼我們再來看看*
的用法,這裡再來獲取所有service的資訊,如下:
看完上述的例子後,我們就可以更加容易理解amqp及rabbitmq概論中介紹的了,和activemq萬用字元式訂閱是介紹的只是符號存在差異而已。
RabbitMQ的基礎概念
目錄 什麼是rabbitmq rabbitmq 管理命令列 rabbitmq的web管理介面介紹 rabbimq訊息傳送流程 一款基於amqp通訊協議,erlang語言開發的,部署及其廣泛的訊息中介軟體 1.服務啟動相關 systemctl start restart stop status rab...
RabbitMQ基礎理解
rabbitmq基本理解 1 rabbitmq簡介 mq全稱為message queue,訊息佇列 mq 是一種應用程式對應用程式的通訊方法。應用程式通過讀寫出入佇列的訊息 針對應用程式的資料 來通訊,而無需專用連線來鏈結它們。訊息傳遞指的是程式之間通過在訊息中傳送資料進行通訊,而不是通過直接呼叫彼...
rabbitMQ的簡單使用
交換機模式 交換機模式2 fanout模式 交換機模式3 headers模式,總結 生產者 製造訊息 消費者 獲取訊息,處理訊息 路由機制 中轉訊息 四種模式 後三種是交換機模式 direct 不需要交換機,直接傳送到指定佇列,一對一 topic 需要key fanout 廣播模式,不需要key h...