RabbitMQ路由模式的用法

小冷

发布于 2023-05-24 17:47:58

2150

发布于 2023-05-24 17:47:58

文章被收录于专栏：小冷coding小冷coding

上一篇梳理了RabbitMQ消费模式有多种模式。分别是简单模式，工作模式，发布/订阅模式，路由（direct）模式，主题（topic）模式，参数模式等等。

接下来就仔细总结下RabbitMQ路由模式的用法。话不多说，直接开始。

路由模式和订阅模式的区别？

路由模式跟发布订阅模式类似。订阅模式是分发到所有绑定到交换机的队列，路由模式只是分发到绑定在交换机上面指定的路由队列，它们的type类型不同，订阅模式是fanout类型，而路由模式是direct类型。看下图就理解了。不同日志消息级别指向不同队列，然后对应的消费者消费。

路由模式（direct）

路由模式：一个生产者P,一个direct类型交换机，多个队列，交换机和队列通过routing-key进行关联绑定，多个消费者C1，C2...。生产者发送消息到交换机并指定routing-key，接着消息就根据绑定规则进行路由发给指定的消费者消费消息。只有将消费者发送消息的交换器、路由与生产者指定的交换器、路由一致，消费者才能接收到生产者向指定路由的消费者发送的消息。

路由模式代码实现

生产者：

通过本地编写代码实现进行测试：

public class Producer {
    public static String DIRECT_EXCHANGE = " direct_exchange";
    public static String DIRECT_QUEUE_1 = "direct_queue_1";
    public static String DIRECT_QUEUE_2 = "direct_queue_2";

    public static void main(String[] args) {
        try {
            Channel channel = ConnectUtil.getChannel();
            //声明交换机(交换机名称，交换机类型)
            channel.exchangeDeclare(DIRECT_EXCHANGE, BuiltinExchangeType.DIRECT);
            //声明队列
            channel.queueDeclare(DIRECT_QUEUE_1,true,false,false,null);
            channel.queueDeclare(DIRECT_QUEUE_2,true,false,false,null);
            //把交换机和队列1进行绑定
            channel.queueBind(DIRECT_QUEUE_1,DIRECT_EXCHANGE,"error");
            //把交换机和队列2进行绑定
            channel.queueBind(DIRECT_QUEUE_2,DIRECT_EXCHANGE,"info");
            channel.queueBind(DIRECT_QUEUE_2,DIRECT_EXCHANGE,"error");
            channel.queueBind(DIRECT_QUEUE_2,DIRECT_EXCHANGE,"warning");
            //发送消息
            String msg="日志信息:调用了xxx方法，日志级别是info";
             channel.basicPublish(DIRECT_EXCHANGE,"info",null,msg.getBytes());
            System.out.println("消息发送成功");
        } catch (IOException e) {
            e.printStackTrace();
        } catch (TimeoutException e) {
            e.printStackTrace();
        }
    }
}

消费者：

public class Consumer1 {
    public static void main(String[] args) {
        try {
            //获取信道对象
            Channel channel = ConnectUtil.getChannel();
            //消费消息
            DefaultConsumer consumer=new DefaultConsumer(channel){
                @Override
                public void handleDelivery(String consumerTag, 
                Envelope envelope, AMQP.BasicProperties properties,
                 byte[] body) throws IOException
                    System.out.println("消费者C1接收到消息:"+new String(body,"UTF-8"));
                    System.out.println("消费者C1把日志信息保存到数据库");
                }
            };
            channel.basicConsume(Producer.DIRECT_QUEUE_1,true,consumer);
        } catch (IOException e) {
            e.printStackTrace();
        } catch (TimeoutException e) {
            e.printStackTrace();
        }
    }
}

RabbitMQ使用场景主要有异步任务，服务间异步通信，应用解耦，顺序消费，定时任务，请求削峰等。不同模式的使用要根据业务需求来做选择，前提是要熟悉每个模式的用法才能做更优的选择。看了这一篇文章是不是更好的理解路由模式的用法。

它是在订阅模式基础上做了扩展，允许设置订阅的条件。所以在业务上有这个需求的可以选择路由模式实现。

本文参与腾讯云自媒体分享计划，分享自微信公众号。

原始发表：2023-03-10，如有侵权请联系 cloudcommunity@tencent.com 删除

rabbitmq