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

Gilbertat 發(fā)布于2019-08-15 13:28 / 1299人閱讀

摘要：推廣專(zhuān)題講座開(kāi)源項(xiàng)目我們利用消息隊(duì)列實(shí)現(xiàn)了分布式事務(wù)的最終一致性解決方案，請(qǐng)大家圍觀。主題交換機(jī)也可以當(dāng)成其它交換機(jī)來(lái)使用，假如隊(duì)列綁定到了那么它會(huì)接收所有的消息，就像廣播路由器一樣而如果未使用，那么就跟直達(dá)路由器一樣了。

推廣

RabbitMQ專(zhuān)題講座

https://segmentfault.com/l/15...

CoolMQ開(kāi)源項(xiàng)目

我們利用消息隊(duì)列實(shí)現(xiàn)了分布式事務(wù)的最終一致性解決方案，請(qǐng)大家圍觀?？梢詤⒖荚创a：https://github.com/vvsuperman…，項(xiàng)目支持網(wǎng)站: http://rabbitmq.org.cn，最新文章或?qū)崿F(xiàn)會(huì)更新在上面

前言

在之前的建立路由中我們改進(jìn)了日志系統(tǒng)。我們摒棄無(wú)腦發(fā)送消息的廣播路由器，而使用能夠根據(jù)綁定鍵(binding key)來(lái)發(fā)送消息的，從而能有有選擇的后去logs.

盡管使用直達(dá)路由器大大的改進(jìn)了我們系統(tǒng)，但也存在局限性 - 無(wú)法加入更多條件。比如我們希望能夠加入更多的維度，我們希望不僅是基于嚴(yán)重程度，而且是基于來(lái)源，如果你對(duì)linux tool工具有了解的話，它不僅僅是基于嚴(yán)重程度(info/warn/crit...) 而且有來(lái)源(auth/cron/kern...)，這個(gè)給到我們更大的靈活性-我們需要監(jiān)聽(tīng)所有來(lái)自"cron"的errors消息，以及來(lái)自"kern"的所有l(wèi)og。所以我們需要的是一個(gè)更復(fù)雜的主題交換機(jī)

主題交換機(jī)

發(fā)送到主題交換機(jī)的消息并不會(huì)有一個(gè)確定的路由鍵-而是一長(zhǎng)串字符列表，以"."來(lái)分割，而這個(gè)字符串列表表明了路由信息，比如"stock.usd.nyse"，"nyse.vmw"，"quick.orange.rabbit"，字符串的最大長(zhǎng)度限制在255bytes。

同時(shí)，在隊(duì)列綁定交換機(jī)時(shí)也需要指定模式，而符合模式的消息將會(huì)被發(fā)送至該隊(duì)列，模式可以由通配符組成：
"*" 可以表示一個(gè)詞
"#" 表示0個(gè)或多個(gè)詞
可以通過(guò)如下的例子來(lái)說(shuō)明

請(qǐng)看例子，以發(fā)送動(dòng)物的消息為例，我們會(huì)發(fā)送包含三個(gè)詞的路由鍵(兩個(gè)".")。第一個(gè)是速度，第二個(gè)是顏色，而第三個(gè)是種族

同時(shí)，我們建立了三個(gè)綁定，Q1綁定了鍵".orange."，Q2綁定了鍵"..rabbit"以及"lazy.#"?？梢宰鋈缦碌慕忉?zhuān)琎1用來(lái)接受所有orange的動(dòng)物，Q2用來(lái)接受所有rabbits，以及l(fā)azy的動(dòng)物

一個(gè)路由為"quick.orange.rabbit"的消息將會(huì)被同時(shí)發(fā)送給這兩個(gè)隊(duì)列，消息"lazy.orange.elephant"也會(huì)被同時(shí)發(fā)給它們；"quick.orange.fox"只會(huì)發(fā)給第一個(gè)隊(duì)列；"lazy.brown.fox"會(huì)發(fā)到第二個(gè)；"lazy.pink.rabbit"將只會(huì)發(fā)送給第二個(gè);"quick.brown.fox"會(huì)被丟棄因?yàn)槠ヅ洳簧先魏我粋€(gè)。

如果我們發(fā)送四個(gè)詞的呢？比如"oragne"或者"quick.orange.male.rabbit"?這些沒(méi)有任何匹配的隊(duì)列將會(huì)丟失。但比如"quick.orange.male.rabbit"會(huì)匹配到第二個(gè)隊(duì)列。

主題交換機(jī)也可以當(dāng)成其它交換機(jī)來(lái)使用，假如隊(duì)列綁定到了 "#",那么它會(huì)接收所有的消息，就像廣播路由器一樣；而如果未使用"*","#"，那么就跟直達(dá)路由器一樣了。

整合所有的代碼

我們用主題交換機(jī)替換掉之前的直達(dá)交換機(jī)，用如同"."的形式， EmitLogTopic.java

import com.rabbitmq.client.*;

import java.io.IOException;

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");
        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());
        System.out.println(" [x] Sent "" + routingKey + "":"" + message + """);

        connection.close();
    }
    //...
}

ReceiveLogsTopic.java的代碼片段

import com.rabbitmq.client.*;

import java.io.IOException;

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");

    Consumer consumer = new DefaultConsumer(channel) {
      @Override
      public void handleDelivery(String consumerTag, Envelope envelope,
                                 AMQP.BasicProperties properties, byte[] body) throws IOException {
        String message = new String(body, "UTF-8");
        System.out.println(" [x] Received "" + envelope.getRoutingKey() + "":"" + message + """);
      }
    };
    channel.basicConsume(queueName, true, consumer);
  }
}

編譯這段代碼

javac -cp $CP ReceiveLogsTopic.java EmitLogTopic.java

接受所有的logs

java -cp $CP ReceiveLogsTopic "#"

接受來(lái)自"kern"的消息

java -cp $CP ReceiveLogsTopic "kern.*"

接受來(lái)自"critical"的消息

java -cp $CP ReceiveLogsTopic "*.critical"

創(chuàng)建多個(gè)綁定

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

發(fā)送消息

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

你可以嘗試更多的參數(shù)，以此來(lái)熟悉這個(gè)知識(shí)

GPU云服務(wù)器云服務(wù)器 TOPIC 白話白話云計(jì)算白話區(qū)塊鏈

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

轉(zhuǎn)載請(qǐng)注明本文地址：http://m.hztianpu.com/yun/68117.html

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

登陸后可評(píng)論

0條評(píng)論

Gilbertat

男|高級(jí)講師

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

TA的文章

GigsGigsCloud：$16/月KVM-1GB/30GB/1TB/1.6T高防/洛杉磯CN2

閱讀 3213·2021-11-22 12:01
阿里云2021金秋上云季充值返券，最高返1800元優(yōu)惠券

閱讀 3833·2021-08-30 09:46
程序猿小白應(yīng)該注意什么

閱讀 834·2019-08-30 13:48
前端每日實(shí)戰(zhàn)：134# 視頻演示如何用 CSS 和 GSAP 創(chuàng)作一個(gè)樹(shù)枝發(fā)芽的 loader

閱讀 3275·2019-08-29 16:43
subline3 px轉(zhuǎn)rem插件（cssrem）

閱讀 1735·2019-08-29 16:33
簡(jiǎn)單說(shuō) JavaScript中的tostring( ) 與 valueOf( )方法

閱讀 1916·2019-08-29 13:44
通用的js前后端交互代碼

閱讀 1479·2019-08-26 13:45
notification(瀏覽器通知)

閱讀 2287·2019-08-26 11:44

成人无码视频,亚洲精品久久久久av无码,午夜精品久久久久久毛片,亚洲中文字幕日韩无码

資訊專(zhuān)欄INFORMATION COLUMN

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

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

RabbitMQ專(zhuān)題講座

CoolMQ開(kāi)源項(xiàng)目

相關(guān)文章

**白話RabbitMQ(三):發(fā)布/訂閱**

RabbitMQ+PHP 教程五（Topics）

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

簡(jiǎn)述消息隊(duì)列在電商系統(tǒng)使用場(chǎng)景以及工作模式

PHP RabbitMQ

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

0條評(píng)論

Gilbertat

男|高級(jí)講師

TA的文章

GigsGigsCloud：$16/月KVM-1GB/30GB/1TB/1.6T高防/洛杉磯CN2

阿里云2021金秋上云季充值返券，最高返1800元優(yōu)惠券

程序猿小白應(yīng)該注意什么

前端每日實(shí)戰(zhàn)：134# 視頻演示如何用 CSS 和 GSAP 創(chuàng)作一個(gè)樹(shù)枝發(fā)芽的 loader

subline3 px轉(zhuǎn)rem插件（cssrem）

簡(jiǎn)單說(shuō) JavaScript中的tostring( ) 與 valueOf( )方法

通用的js前后端交互代碼

notification(瀏覽器通知)

最新活動(dòng)

資訊專(zhuān)欄INFORMATION COLUMN

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

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

RabbitMQ專(zhuān)題講座

CoolMQ開(kāi)源項(xiàng)目

相關(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)！