RocketMQ(03) 通過Tag對訊息分類

2021-10-01 19:00:38 字數 1105 閱讀 3215

rocketmq建議乙個業務系統只使用乙個topic,不同型別的訊息通過tag來區分。tag可以在構造message的時候指定,下面**就指定了傳送的訊息的tag都為tag0。

@test

public

void

sendwithtag()

throws exception

else

} producer.

shutdown()

;}

也可以通過message的settags()進行指定。

@test

public

void

sendwithtag()

throws exception

else

} producer.

shutdown()

;}

雖然引數名叫tags,但是一條訊息只能指定乙個tag。消費者進行消費的時候也可以指定需要消費的訊息對應的tag,比如下面就指定了需要消費的訊息對應的topic是topic1,tag是tag0。

@test

public

void

testconsumebytag()

throws exception })

; consumer.

start()

; timeunit.seconds.

sleep

(120);

}

同一消費者也可以同時訂閱同乙個topic的多個tag,多個tag之間通過||進行分隔。比如下面**就同時訂閱了tag0、tag1和tag2。

@test

public

void

testconsumebytag()

throws exception })

; consumer.

start()

; timeunit.seconds.

sleep

(120);

}

(注:本文基於rocketmq4.5.0所寫)

03 通過docker安裝nginx

nginx是一款高效能的伺服器,常用作反向 正向 動靜分離以及負載均衡。本文將闡述使用docker安裝nginx伺服器,並通過nginx訪問之前fastdfs上傳的檔案。docker pull nginxmkdir p root nginx conf touch root nginx conf ng...

100 通過zookeeper面試

1 zookeeper 的資料模型 zookeeper 的資料模型是什麼樣子呢?它很像資料結構當中的樹,也很像檔案系統的目錄。樹是由節點所組成,zookeeper 的資料儲存也同樣是基於節點,這種節點叫做 znode。但是,不同於樹的節點,znode 的引用方式是路徑引用,類似於檔案路徑 動物 倉鼠...

OCA 052 通過總結

2011 4 27 成功通過oca 052。成績 98 pass。今天去考的oca 052,去考場路上不知為何臨時來了場雷雨,把我澆的渾身都溼了,竟然這麼不走運。吸取上一門考試的教訓,總共通讀教材兩遍,並結合題庫,最後順利通過考試。現特將備考過程分享出來,希望能夠幫助同我一樣有考證需求的人。這一門的...