标签：单词 队列 绑定 RabbitMQ Topic Routing rabbit orange channel

Topic简介

Topic类型的Exchange与Direct相比，都是可以根据RoutingKey把消息路由到不同的队列。只不过Topic类型Exchange可以让队列在绑定Routing key 的时候使用通配符！这种模型Routingkey 一般都是由一个或多个单词组成，多个单词之间以”.”分割，例如： item.insert

Topic 的要求

发送到类型是 topic 交换机的消息的 routing_key 不能随意写，必须满足一定的要求，它必须是一个单词列表，以点号分隔开。这些单词可以是任意单词，比如说："stock.usd.nyse", "nyse.vmw","quick.orange.rabbit".这种类型的。当然这个单词列表最多不能超过 255 个字节。

在这个规则列表中，其中有两个替换符需要注意:

*(星号)可以代替一个单词
#(井号)可以替代零个或多个单词

Topic 匹配案例

下图绑定关系如下:
Q1-->绑定的是

• 中间带 orange 带 3 个单词的字符串(.orange.)

Q2-->绑定的是

• 最后一个单词是 rabbit 的 3 个单词(..rabbit)
• 第一个单词是 lazy 的多个单词(lazy.#)
  

上图是一个队列绑定关系图，我们来看看他们之间数据接收情况是怎么样的
quick.orange.rabbit------->被队列 Q1Q2 接收到
lazy.orange.elephant ------->被队列 Q1Q2 接收到
quick.orange.fox ------->被队列 Q1 接收到
lazy.brown.fox ------->被队列 Q2 接收到
lazy.pink.rabbit-------> 虽然满足两个绑定但只被队列 Q2 接收一次
quick.brown.fox ------->不匹配任何绑定不会被任何队列接收到会被丢弃
quick.orange.male.rabbit-------> 是四个单词不匹配任何绑定会被丢弃
lazy.orange.male.rabbit-------> 是四个单词但匹配 Q2

实战

消费者一

package com.study.rabbitmq.seven;

import com.rabbitmq.client.Channel;
import com.rabbitmq.client.DeliverCallback;
import com.study.rabbitmq.utils.RabbitMQUtils;

//消费者
public class ReceiveLogsTopic01 {
    //交换机名称
    public static final String EXCHANGE_NAME = "topic_logs";
    //接收消息
    public static void main(String[] args) throws Exception {
        Channel channel = RabbitMQUtils.getChannel();
        //声明交换机
        channel.exchangeDeclare(EXCHANGE_NAME,"topic");
        //声明队列
        String queueName = "Q1";
        channel.queueDeclare(queueName,false,false,false,null);
        //绑定信道
        channel.queueBind(queueName,EXCHANGE_NAME,"*.orange.*");
        System.out.println("等待接收消息.....");

        DeliverCallback deliverCallback = (consumerTag, message) ->{
            System.out.println(new String(message.getBody(),"UTF-8"));
            System.out.println("接收队列："+queueName + "绑定key：" + message.getEnvelope().getRoutingKey());
        };

        channel.basicConsume(queueName,true,deliverCallback,consumerTag -> {});
    }
}

消费者二

package com.study.rabbitmq.seven;

import com.rabbitmq.client.Channel;
import com.rabbitmq.client.DeliverCallback;
import com.study.rabbitmq.utils.RabbitMQUtils;

//消费者
public class ReceiveLogsTopic02 {
    //交换机名称
    public static final String EXCHANGE_NAME = "topic_logs";
    //接收消息
    public static void main(String[] args) throws Exception {
        Channel channel = RabbitMQUtils.getChannel();
        //声明交换机
        channel.exchangeDeclare(EXCHANGE_NAME,"topic");
        //声明队列
        String queueName = "Q2";

        channel.queueDeclare(queueName,false,false,false,null);
        //绑定信道
        channel.queueBind(queueName,EXCHANGE_NAME,"*.*.rabbit");
        channel.queueBind(queueName,EXCHANGE_NAME,"lazy.#");
        System.out.println("等待接收消息.....");

        DeliverCallback deliverCallback = (consumerTag, message) ->{
            System.out.println(new String(message.getBody(),"UTF-8"));
            System.out.println("接收队列："+queueName + "绑定key：" + message.getEnvelope().getRoutingKey());
        };

        channel.basicConsume(queueName,true,deliverCallback,consumerTag -> {});
    }
}

生产者

package com.study.rabbitmq.seven;

import com.rabbitmq.client.Channel;
import com.study.rabbitmq.utils.RabbitMQUtils;

import java.util.HashMap;
import java.util.Map;

//生产者
public class EmitLogTopic {
    //交换机名称
    public static final String EXCHANGE_NAME = "topic_logs";

    public static void main(String[] args) throws Exception {
        Channel channel = RabbitMQUtils.getChannel();
        /*
        * Q1-->绑定的是
        *           中间带orange的3个单词的信道(*.orange.*)
        * Q2-->绑定的是
        *           最后一个单词是rabbit的3个单词的信道(*.*.rabbit)
        *           第一个单词是lazy的多个单词的信道(lazy.#)
        * */
        HashMap<String, String> bindingKeymap = new HashMap<>();
        bindingKeymap.put("quick.orange.rabbit","被队列Q1Q2接收到");
        bindingKeymap.put("lazy.orange.elephant","被队列Q1Q2接收到");
        bindingKeymap.put("quick.orange.fox","被队列Q1接收到");
        bindingKeymap.put("lazy.brown.fox","被队列Q2接收到");
        bindingKeymap.put("lazy.pink.rabbit","虽然满足两个绑定，但只被队列Q2接收一次");
        bindingKeymap.put("quick.brown.fox","不匹配任何绑定不会被任何队列接收到，会被丢弃");
        bindingKeymap.put("quick.orange.male.rabbit","是四个单词不匹配任何绑定，会被丢弃");
        bindingKeymap.put("lazy.orange.male.rabbit","被Q2接收到");

        for (Map.Entry<String, String> bindingKeyEntry : bindingKeymap.entrySet()) {
            String routingKey = bindingKeyEntry.getKey();
            String message = bindingKeyEntry.getValue();
            channel.basicPublish(EXCHANGE_NAME,routingKey,null,message.getBytes("UTF-8"));
            System.out.println("生产者发出消息：" + message);
        }
    }
}

运行测试:

标签：单词,队列,绑定,RabbitMQ,Topic,Routing,rabbit,orange,channel
来源： https://www.cnblogs.com/luoxiao1104/p/15092487.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。