RabbitMQ的基礎使用 Topic模式

2021-10-07 06:22:18 字數 1350 閱讀 1569

我們在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...