RabbitMQ3.7 研究-工作模式之Topics通配符模式

向右看齐 2022-04-08 16:43 261阅读 0赞

### 目录 ###

*   *  3.4 Topics通配符模式
     *   *  3.4.1统配符模式介绍
         *  3.4.2生产者
         *  3.4.3 消费端
         *  3.4.4 测试
         *  3.4.5 小结

## 3.4 Topics通配符模式 ##

### 3.4.1统配符模式介绍 ###

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDA2MjMzOQ_size_16_color_FFFFFF_t_70]

路由模式：

1、每个消费者监听自己的队列，并且设置带统配符的routingkey。

2、生产者将消息发给broker，由交换机根据routingkey来转发消息到指定的队列。

### 3.4.2生产者 ###

案例：

根据用户的通知设置去通知用户，设置接收Email的用户只接收Email，设置接收sms的用户只接收sms，设置两种通知类型都接收的则两种通知都有效。

生产者代码如下：

声明交换机，指定topic类型：

/**
     * 声明交换机
     * param1：交换机名称
     * param2:交换机类型 四种交换机类型：direct、fanout、topic、headers
     */
     channel.exchangeDeclare(EXCHANGE_TOPICS_INFORM, BuiltinExchangeType.TOPIC);
    //Email通知
    channel.basicPublish(EXCHANGE_TOPICS_INFORM, "inform.email", null, message.getBytes());
    //sms通知
    channel.basicPublish(EXCHANGE_TOPICS_INFORM, "inform.sms", null, message.getBytes());
    //两种都通知
    channel.basicPublish(EXCHANGE_TOPICS_INFORM, "inform.sms.email", null, message.getBytes());

完整代码：

package com.xc.test.rabbitmq;
    
    import com.rabbitmq.client.BuiltinExchangeType;
    import com.rabbitmq.client.Channel;
    import com.rabbitmq.client.Connection;
    import com.rabbitmq.client.ConnectionFactory;
    
    import java.io.IOException;
    import java.util.concurrent.TimeoutException;
    
    public class Producer04_topics {
        //队列名称
        private static final String QUEUE_INFORM_EMAIL = "queue_inform_email";
        private static final String QUEUE_INFORM_SMS = "queue_inform_sms";
        private static final String EXCHANGE_TOPICS_INFORM="exchange_topics_inform";
        public static void main(String[] args) {
            Connection connection = null;
            Channel channel = null;
            try {
                //创建一个与MQ的连接
                ConnectionFactory factory = new ConnectionFactory();
                factory.setHost("127.0.0.1");
                factory.setPort(5672);
                factory.setUsername("guest");
                factory.setPassword("guest");
                factory.setVirtualHost("/");//rabbitmq默认虚拟机名称为“/”，虚拟机相当于一个独立的mq服务器
    
                //创建一个连接
                connection = factory.newConnection();
                //创建与交换机的通道，每个通道代表一个会话
                channel = connection.createChannel();
                //声明交换机 String exchange, BuiltinExchangeType type
                /**
                 * 参数明细
                 * 1、交换机名称
                 * 2、交换机类型，fanout、topic、direct、headers
                 */
                channel.exchangeDeclare(EXCHANGE_TOPICS_INFORM, BuiltinExchangeType.TOPIC);
                //声明队列
                /**
                 * 参数明细：
                 * 1、队列名称
                 * 2、是否持久化
                 * 3、是否独占此队列
                 * 4、队列不用是否自动删除
                 * 5、参数
                 */
                channel.queueDeclare(QUEUE_INFORM_EMAIL, true, false, false, null);
                channel.queueDeclare(QUEUE_INFORM_SMS, true, false, false, null);
    
                //发送邮件消息
                for (int i=0;i<10;i++){
                    String message = "email inform to user"+i;
                    //向交换机发送消息 String exchange, String routingKey, BasicProperties props, byte[] body
                    /**
                     * 参数明细
                     * 1、交换机名称，不指令使用默认交换机名称 Default Exchange
                     * 2、routingKey（路由key），根据key名称将消息转发到具体的队列，这里填写队列名称表示消息将发到此队列
                     * 3、消息属性
                     * 4、消息内容
                     */
                    channel.basicPublish(EXCHANGE_TOPICS_INFORM, "inform.email", null, message.getBytes());
                    System.out.println("Send Message is:'" + message + "'");
                }
                //发送短信消息
                for (int i=0;i<10;i++){
                    String message = "sms inform to user"+i;
                    channel.basicPublish(EXCHANGE_TOPICS_INFORM, "inform.sms", null, message.getBytes());
                    System.out.println("Send Message is:'" + message + "'");
                }
                //发送短信和邮件消息
                for (int i=0;i<10;i++){
                    String message = "sms and email inform to user"+i;
                    channel.basicPublish(EXCHANGE_TOPICS_INFORM, "inform.sms.email", null, message.getBytes());
                    System.out.println("Send Message is:'" + message + "'");
                }
    
            } catch (IOException e) {
                e.printStackTrace();
            } catch (TimeoutException e) {
                e.printStackTrace();
            }finally{
                if(channel!=null){
                    try {
                        channel.close();
                    } catch (IOException e) {
                        e.printStackTrace();
                    } catch (TimeoutException e) {
                        e.printStackTrace();
                    }
                }
                if(connection!=null){
                    try {
                        connection.close();
                    } catch (IOException e) {
                        e.printStackTrace();
                    }
                }
    
            }
    
    
        }
    }

### 3.4.3 消费端 ###

队列绑定交换机指定通配符：

统配符规则：

中间以“.”分隔。

符号\#可以匹配多个词，符号\*可以匹配一个词语。

//声明队列
    channel.queueDeclare(QUEUE_INFORM_EMAIL, true, false, false, null);
    channel.queueDeclare(QUEUE_INFORM_SMS, true, false, false, null);
    //声明交换机
    channel.exchangeDeclare(EXCHANGE_TOPICS_INFORM, BuiltinExchangeType.TOPIC);
    //绑定email通知队列
    channel.queueBind(QUEUE_INFORM_EMAIL,EXCHANGE_TOPICS_INFORM,"inform.#.email.#");
    //绑定sms通知队列
     channel.queueBind(QUEUE_INFORM_SMS,EXCHANGE_TOPICS_INFORM,"inform.#.sms.#");

### 3.4.4 测试 ###

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDA2MjMzOQ_size_16_color_FFFFFF_t_70 1]

使用生产者发送若干条消息，交换机根据routingkey统配符匹配并转发消息到指定的队列。

### 3.4.5 小结 ###

1、本案例的需求使用Routing工作模式能否实现？

使用Routing模式也可以实现本案例，共设置三个 routingkey，分别是email、sms、all，email队列绑定email和all，sms队列绑定sms和all，这样就可以实现上边案例的功能，实现过程比topics复杂。

Topic模式更多加强大，它可以实现Routing、publish/subscirbe模式的功能。

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDA2MjMzOQ_size_16_color_FFFFFF_t_70]: /images/20220404/2854da44a4a64a57b991cce7aec37860.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDA2MjMzOQ_size_16_color_FFFFFF_t_70 1]: /images/20220404/270b5ac41fc4485295434d7a662636a9.png