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,去考場路上不知為何臨時來了場雷雨,把我澆的渾身都溼了,竟然這麼不走運。吸取上一門考試的教訓,總共通讀教材兩遍,並結合題庫,最後順利通過考試。現特將備考過程分享出來,希望能夠幫助同我一樣有考證需求的人。這一門的...