【譯】RabbitMQ系列（五） - 主題模式

pingan8787 發(fā)布于2019-08-16 16:07 / 1173人閱讀

摘要：主題模式在上一章我們改進(jìn)了我們的日志系統(tǒng)，如果使用我們只能簡(jiǎn)單進(jìn)行廣播，而使用則允許消費(fèi)者可以進(jìn)行一定程度的選擇。為的會(huì)同時(shí)發(fā)布到這兩個(gè)。當(dāng)為時(shí)，會(huì)接收所有的。當(dāng)中沒(méi)有使用通配符和時(shí)，的行為和一致。

主題模式

在上一章我們改進(jìn)了我們的日志系統(tǒng)，如果使用fanout我們只能簡(jiǎn)單進(jìn)行廣播，而使用direct則允許消費(fèi)者可以進(jìn)行一定程度的選擇。但是direct還是有其局限性，其路由不支持多個(gè)條件。

在我們的日志系統(tǒng)中，消費(fèi)者程序可能不止是基于日志的severity，同時(shí)也想基于發(fā)送日志的源系統(tǒng)。你可能知道linux的syslog工具，它就是同時(shí)基于severity(info/warn/crit...)和功能(auth/cron/kern...).

這就提供了很大的靈活性-我們想接收來(lái)自cron的嚴(yán)重錯(cuò)誤日志和kern的所有日志。

下面我們就使用更復(fù)雜的topic來(lái)改進(jìn)我們的日志系統(tǒng)。

Topic exchange

發(fā)送到topic類(lèi)型exchange的message不可以具有模糊的routing_key,它必須具有以冒號(hào)分割的詞。就像"stock.usd.nyse","nyse.vmw","quick.orange.rabbit"等，限制長(zhǎng)度255字節(jié)。

binding key也采用相似的形勢(shì)。topic exchange的邏輯和direct相似，通過(guò)比較message的routing key和bind的binding key，來(lái)匹配轉(zhuǎn)發(fā)的queue。但是topic的binding支持通配符：

” * “表示任何一個(gè)詞

” # “ 表示0或1個(gè)詞

通過(guò)上面圖示的場(chǎng)景來(lái)解釋會(huì)比較好理解。

例子中我們將發(fā)送描述動(dòng)物的message。message會(huì)攜帶routing key（包含三個(gè)詞），第一個(gè)詞表示speed，第二個(gè)表示color，第三個(gè)表示species"..".

創(chuàng)建了三個(gè)綁定：Q1的binding key是”*.orange.*" Q2的binding key是“*.*.rabbit”和 "lazy.#".

以文字表述便是：

Q1 關(guān)心所有橘色的動(dòng)物

Q2 關(guān)心所有的rabbit和所有的lazy動(dòng)物

routing key為“quick.orange.rabbit"的message會(huì)同時(shí)發(fā)布到這兩個(gè)queue。
routing key為"lazy.orange.elephant"的message會(huì)同時(shí)發(fā)布到這兩個(gè)queue。
routing key為”quick.orange.fox“只會(huì)發(fā)布到第一個(gè)queue.
routing key為”lazy.brown.fox"的message只會(huì)發(fā)布到第二個(gè)queue.
routing key為"lazy.pink.rabbit"的message雖然滿(mǎn)足Q2的兩個(gè)條件，但也只會(huì)發(fā)布到Q2一次。
routing key為"quick.brown.fox"的message沒(méi)有任何匹配，就會(huì)被丟失。

如果我們發(fā)送的message只有一個(gè)word或者多余三個(gè)word，如"orange"或者"quick.orange.male.rabbit"會(huì)發(fā)生什么呢？這些message不會(huì)匹配任何binding key，均會(huì)被丟棄掉。

另外"lazy.orange.male.rabbit"雖然具有四個(gè)詞，但是會(huì)匹配最后的binding key，而被發(fā)送到第二個(gè)queue。

Topic exhange非常強(qiáng)大，同時(shí)可以模仿其他兩種類(lèi)型的exchange。當(dāng)binding key為 # 時(shí)，queue會(huì)接收所有的message。當(dāng)binding key中沒(méi)有使用通配符(* 和 #)時(shí)，topic的行為和direct一致。

開(kāi)始執(zhí)行

我們將在日志系統(tǒng)中使用topic exchange。我們的routding key采用兩個(gè)詞 ".".
EmitLogTopic.java的代碼如下：

import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;

public class EmitLogTopic {

  private static final String EXCHANGE_NAME = "topic_logs";

  public static void main(String[] argv) throws Exception {
    ConnectionFactory factory = new ConnectionFactory();
    factory.setHost("localhost");
    try (Connection connection = factory.newConnection();
         Channel channel = connection.createChannel()) {

        channel.exchangeDeclare(EXCHANGE_NAME, "topic");

        String routingKey = getRouting(argv);
        String message = getMessage(argv);

        channel.basicPublish(EXCHANGE_NAME, routingKey, null, message.getBytes("UTF-8"));
        System.out.println(" [x] Sent "" + routingKey + "":"" + message + """);
    }
  }
  //..
}

ReceiveLogsTopic.java的代碼如下:

import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.DeliverCallback;

public class ReceiveLogsTopic {

  private static final String EXCHANGE_NAME = "topic_logs";

  public static void main(String[] argv) throws Exception {
    ConnectionFactory factory = new ConnectionFactory();
    factory.setHost("localhost");
    Connection connection = factory.newConnection();
    Channel channel = connection.createChannel();

    channel.exchangeDeclare(EXCHANGE_NAME, "topic");
    String queueName = channel.queueDeclare().getQueue();

    if (argv.length < 1) {
        System.err.println("Usage: ReceiveLogsTopic [binding_key]...");
        System.exit(1);
    }

    for (String bindingKey : argv) {
        channel.queueBind(queueName, EXCHANGE_NAME, bindingKey);
    }

    System.out.println(" [*] Waiting for messages. To exit press CTRL+C");

    DeliverCallback deliverCallback = (consumerTag, delivery) -> {
        String message = new String(delivery.getBody(), "UTF-8");
        System.out.println(" [x] Received "" +
            delivery.getEnvelope().getRoutingKey() + "":"" + message + """);
    };
    channel.basicConsume(queueName, true, deliverCallback, consumerTag -> { });
  }
}

編譯

javac -cp $CP ReceiveLogsTopic.java EmitLogTopic.java

接收所有日志

java -cp $CP ReceiveLogsTopic "#"

接收功能"kern"的日志

java -cp $CP ReceiveLogsTopic "kern.*"

接收嚴(yán)重級(jí)別日志

java -cp $CP ReceiveLogsTopic "*.critical"

接收者使用兩個(gè)綁定條件

java -cp $CP ReceiveLogsTopic "kern.*" "*.critical"

發(fā)送日志message

java -cp $CP EmitLogTopic "kern.critical" "A critical kernal error"

文章版權(quán)歸作者所有，未經(jīng)允許請(qǐng)勿轉(zhuǎn)載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。

轉(zhuǎn)載請(qǐng)注明本文地址：http://systransis.cn/yun/73916.html

發(fā)表評(píng)論

登陸后可評(píng)論

0條評(píng)論

pingan8787

男|高級(jí)講師

我要關(guān)注我要私信

TA的文章

查詢(xún)tensorflow版本

閱讀 727·2023-04-25 22:50
記錄不存在則插入，存在則更新 → MySQL 的實(shí)現(xiàn)方式有哪些？

閱讀 1581·2021-10-08 10:05
阿里云存儲(chǔ)，讓更多的創(chuàng)新在身邊發(fā)生

閱讀 1005·2021-09-30 09:47
自動(dòng)化測(cè)試系列（三）|UI測(cè)試

閱讀 1956·2021-09-28 09:35
C++入門(mén)—namespace的使用傻傻分不清楚&C++中函數(shù)的參數(shù)也可以配備胎&a

閱讀 857·2021-09-26 09:55
大數(shù)求余C++（超級(jí)牛逼）

閱讀 3452·2021-09-10 10:51
【C語(yǔ)言進(jìn)階】字符串&內(nèi)存函數(shù)

閱讀 3456·2021-09-02 15:15
80VPS：日本/香港CN2服務(wù)器首月420元(續(xù)費(fèi)600元),E5/16G/1TB/20M帶寬

閱讀 3323·2021-08-05 09:57

成人国产在线小视频_日韩寡妇人妻调教在线播放_色成人www永久在线观看_2018国产精品久久_亚洲欧美高清在线30p_亚洲少妇综合一区_黄色在线播放国产_亚洲另类技巧小说校园_国产主播xx日韩_a级毛片在线免费

資訊專(zhuān)欄INFORMATION COLUMN

上云采購(gòu)季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺(tái)、長(zhǎng)期優(yōu)惠，快來(lái)選購(gòu)！

【譯】RabbitMQ系列（五） - 主題模式

相關(guān)文章

**【譯】RabbitMQ系列（四） - 路由模式**

**白話(huà)RabbitMQ(五): 主題路由器(Topic Exchange)**

**【譯】RabbitMQ系列（二）-Work模式**

**【譯】RabbitMQ系列（三） - 發(fā)布/訂閱模式**

**【譯】RabbitMQ系列（六）-RPC模式**

發(fā)表評(píng)論

0條評(píng)論

pingan8787

男|高級(jí)講師

TA的文章

查詢(xún)tensorflow版本

記錄不存在則插入，存在則更新 → MySQL 的實(shí)現(xiàn)方式有哪些？

阿里云存儲(chǔ)，讓更多的創(chuàng)新在身邊發(fā)生

自動(dòng)化測(cè)試系列（三）|UI測(cè)試

C++入門(mén)—namespace的使用傻傻分不清楚&C++中函數(shù)的參數(shù)也可以配備胎&a

大數(shù)求余C++（超級(jí)牛逼）

【C語(yǔ)言進(jìn)階】字符串&內(nèi)存函數(shù)

80VPS：日本/香港CN2服務(wù)器首月420元(續(xù)費(fèi)600元),E5/16G/1TB/20M帶寬

最新活動(dòng)

資訊專(zhuān)欄INFORMATION COLUMN

上云采購(gòu)季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺(tái)、長(zhǎng)期優(yōu)惠，快來(lái)選購(gòu)！

【譯】RabbitMQ系列（五） - 主題模式

相關(guān)文章

發(fā)表評(píng)論

0條評(píng)論

男|高級(jí)講師

TA的文章

最新活動(dòng)

上云采購(gòu)季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺(tái)、長(zhǎng)期優(yōu)惠，快來(lái)選購(gòu)！