? ? ? ? 之前幾節(jié)已經(jīng)學(xué)習(xí)過(guò)fanout exchange,direct exchange的使用，并用他們構(gòu)建了一個(gè)日志系統(tǒng)，盡管direct exchange使得我們的日志系統(tǒng)更實(shí)用化，但是仍然有局限性，因?yàn)槲覀冎皇歉鶕?jù)了日志的嚴(yán)重等級(jí)（info,warning,error）進(jìn)行了分發(fā)肾砂，但是沒(méi)關(guān)心日志的來(lái)源（auth / cron / kern ...）啃勉。但是Topic exchange更加靈活罕拂，能滿足我們的需求仰剿，如：我們想監(jiān)聽(tīng)來(lái)自cron的重要錯(cuò)誤卧须，同時(shí)也可以監(jiān)聽(tīng)來(lái)自kern的所有日志另绩。

Topic exchange

發(fā)送到topic exchange的消息不會(huì)擁有一個(gè)特定的routing key——它可能有一系列由點(diǎn)分隔的詞組成儒陨。這些詞可以是任意值，但是通常將它設(shè)置為與message有一定的聯(lián)系的單詞笋籽。就像"stock.usd.nyse", "nyse.vmw", "quick.orange.rabbit"之類的蹦漠，你喜歡多少個(gè)詞組合就設(shè)計(jì)多少個(gè)，routing key最多可達(dá)255 bytes车海。

binding key也必須用如上的routing key的形式笛园。topic exchange背后的邏輯和direct exchange的邏輯很相似——一個(gè)包含routing key的message將會(huì)被分發(fā)到所有匹配的binding key后的queue中。但是侍芝，這里有兩點(diǎn)需要注意的地方：

*(star)可以替換為任一一個(gè)詞研铆。

#(hash)可以替換0個(gè)或多個(gè)詞。

如下例子中簡(jiǎn)單解釋一下：

在上圖例子中州叠，我們可以發(fā)送描述animals的消息到x exchange中棵红，message將使用有3個(gè)單詞（兩個(gè)點(diǎn)分隔）組成的routing key進(jìn)行發(fā)送，第一個(gè)單詞描述的是speed咧栗，第二個(gè)描述colour逆甜，第三個(gè)描述species："<speed>.<colour>.<species>"。

同時(shí)創(chuàng)建3條bindings：Q1的binding key為"*.orange.*"楼熄，Q2的binding key為"*.*.rabbit"和"lazy.#"

這些bindings總結(jié)如下：

Q1對(duì)animals顏色為orange的感興趣忆绰。

Q2會(huì)接收所有關(guān)于rabbits和lazy的animals。

message的routing key設(shè)置為"quick.orange.rabbit"則會(huì)被分發(fā)到這兩個(gè)queue中可岂；設(shè)置為"lazy.orange.elephant"也會(huì)被分發(fā)到兩個(gè)queue中错敢；設(shè)置為"quick.orange.fox"則只會(huì)分發(fā)到Q1中；設(shè)置為"lazy.brown.fox"則只會(huì)分發(fā)到Q2中缕粹；設(shè)置為"lazy.pink.rabbit"也只會(huì)分發(fā)一次到Q2中稚茅，盡管這個(gè)routing key匹配兩個(gè)bindings；設(shè)置為"quick.brown.fox"的消息由于不匹配任何的binding key平斩，因此該message會(huì)被丟棄亚享。

同樣，如果我們發(fā)送只有一個(gè)詞或者四個(gè)詞的routing key绘面，像"orange" 或"quick.orange.male.rabbit"這樣的會(huì)是什么結(jié)果欺税？結(jié)果是，同樣不匹配揭璃，message會(huì)被丟棄晚凿。像"lazy.orange.male.rabbit"這樣的，盡管有四個(gè)詞組成瘦馍，但是它匹配"lazy.#"歼秽，所以會(huì)被分發(fā)到Q2中。

注：topic exchange非常強(qiáng)大并且可以實(shí)現(xiàn)其他exchange的功能情组。

（1）當(dāng)一個(gè)queue的binding key是"#"(hash)時(shí)燥筷，這個(gè)queue將會(huì)接收所有的message箩祥，就像fanout exchange一樣。

（2）當(dāng)特殊字符*(start)和#(hash)在binding key中都不使用時(shí)肆氓，topic exchange 的功能就和direct exchange的功能一樣袍祖。

實(shí)現(xiàn)

topic exchange的用法和direct exchange的用法大同小異。

同樣做院，先看看sender.go

函數(shù)severityFrom()進(jìn)行了調(diào)整盲泛，即發(fā)送message時(shí)必須設(shè)置routing key的值。

在看看receiver.go

聲明exchange和queue

根據(jù)命令行參數(shù)設(shè)置binding key

從queue中接收消息

現(xiàn)在運(yùn)行兩個(gè)consumer

在producer端發(fā)送消息

有點(diǎn)亂键耕，整理下發(fā)送的消息：

（1）producer.exe bad.orange.black 初級(jí)賽亞人

（2）producer.exe lazy.orange.* 黑色賽亞人

（3）producer.exe lazy.xxx.xxx 懶人賽亞人

看看兩個(gè)consumer分別收到了哪些消息

再看看RabbitMQ Server的web監(jiān)控頁(yè)面：

這樣就可以實(shí)現(xiàn)日志不僅按嚴(yán)重等級(jí)進(jìn)行劃分寺滚，還可以按日志來(lái)源，用戶等等進(jìn)行劃分屈雄。