RabbitMQ direct交换机

在上面这张图中，我们可以看到 X 绑定了两个队列，绑定类型是 direct。队列 Q1 绑定键为 orange，队列 Q2 绑定键有两个:一个绑定键为 black，另一个绑定键为 green.

在这种绑定情况下，生产者发布消息到 exchange 上，绑定键为 orange 的消息会被发布到队列
Q1。绑定键为 blackgreen 和的消息会被发布到队列 Q2，其他消息类型的消息将被丢弃。

多重绑定

当然如果 exchange 的绑定类型是direct，但是它绑定的多个队列的 key 如果都相同，在这种情况下虽然绑定类型是 direct 但是它表现的就和 fanout 有点类似了，就跟广播差不多，如上图所示。

实战

生产者

public class DirectLogs {// 交换机的名称public  static  final String EXCHANGE_NAME = "direct_logs";public static void main(String[] args) throws  Exception{Channel channel = RabbitMqUtils.getChannel();channel.exchangeDeclare(EXCHANGE_NAME, BuiltinExchangeType.DIRECT);Scanner scanner = new Scanner(System.in);while (scanner.hasNext()){String message = scanner.next();channel.basicPublish(EXCHANGE_NAME,"info",null,message.getBytes(StandardCharsets.UTF_8));System.out.println("生产者发出的消息："+ message);}}
}

消费者

public class ReceiveLogsDirect01 {public static final String EXCHANGE_NAME = "direct_logs";public static void main(String[] args) throws Exception {Channel channel = RabbitMqUtils.getChannel();//声明一个队列channel.queueDeclare("console",false,false,false,null);//绑定交换机与队列channel.queueBind("console",EXCHANGE_NAME,"info");channel.queueBind("console",EXCHANGE_NAME,"warning");DeliverCallback deliverCallback = (consumerTag, message) -> {System.out.println("ReceiveLogsDirect01控制台打印接受到的消息：" + new String(message.getBody()));};channel.basicConsume("console",true,deliverCallback,consumerTag -> {});}
}

public class ReceiveLogsDirect02 {public static final String EXCHANGE_NAME = "direct_logs";public static void main(String[] args) throws Exception {Channel channel = RabbitMqUtils.getChannel();//声明一个队列channel.queueDeclare("disk",false,false,false,null);//绑定交换机与队列channel.queueBind("disk",EXCHANGE_NAME,"error");DeliverCallback deliverCallback = (consumerTag, message) -> {System.out.println("ReceiveLogsDirect02控制台打印接受到的消息：" + new String(message.getBody()));};channel.basicConsume("disk",true,deliverCallback,consumerTag -> {});}
}

RabbitMQ direct交换机相关推荐

RabbitMQ的交换机类型和工作模式
RabbitMQ的交换机类型有四种 1.direct 直流交换机: 根据消息的路由键routingkey,将消息以完全匹配的方式路由到指定的队列中. 这里的匹配指的是消息本身携带的路由键和队列与交换机 ...
RabbitMQ之交换机的讲解
一.交换机 1.Exchange 在RabbitMQ中,生产者发送消息不会直接将消息投递到队列中,而是先将消息投递到交换机中, 在由交换机转发到具体的队列, 队列再将消息以推送或者拉取方式给消费者进行 ...
RabbitMQ之交换机的四种类型和属性
交换机主要包括如下4种类型: Direct exchange(直连交换机) Fanout exchange(扇型交换机) Topic exchange(主题交换机) Headers exchange( ...
003 Rabbitmq中交换机的类型
一注意点在Rabbitmq之中,存在绑定键和路由键的概念. [1]绑定键 : 交换机和队列关系的一种描述. [2]路由键: 消息之中消息标签的内容,描述了消息最终到达哪些队列之中. 在Rabbit ...
rabbitmq direct 多个消费者_一文解析 RabbitMQ 最常用的三大模式
Direct 模式所有发送到 Direct Exchange 的消息被转发到 RouteKey 中指定的 Queue. Direct 模式可以使用 RabbitMQ 自带的 Exchange: de ...
RabbitMQ exchange交换机机制
目录 RabbitMQ 概念 exchange交换机机制什么是交换机 binding? Direct Exchange交换机 Topic Exchange交换机 Fanout Exchange交换机 ...
rabbitmq direct 多个消费者_RabbitMQ实战应用技巧
1. RabbitMQ实战应用技巧 1.1. 前言由于项目原因,之后会和RabbitMQ比较多的打交道,所以让我们来好好整理下RabbitMQ的应用实战技巧,尽量避免日后的采坑 1.2. 概述 Ra ...
RabbitMQ中交换机的几种模式
目录简述交换机模式 Fanout模式 Direct模式 Topic模式 Headers模式简述生产者不直接跟队列打交道,而是通过交换机.交换机类似于生产者和队列直接的一个管理者,它将生产的消息 ...
RabbitMq Direct exchange路由模型
官网就是最好的文档上一篇文章RabbitMq Publish/Subscribe消息发布订阅模式消息发布订阅模式中,就是通过广播来实现分发的.所有的customer都能够收到全部的消息.实际业务场 ...

RabbitMQ direct交换机

RabbitMQ direct交换机相关推荐

最新文章

热门文章