FanoutExchange交换机简单使用

1：首先呢，为什么要使用交换机？

我个人得想法是：当发布者将消息直接放入队列中以后，一旦消费者对此消息使用，则消息将会从队列中删除，导致其他消费者拿不到队列中得消息。

可以看到，在订阅模型中，多了一个exchange角色，而且过程略有变化：

Publisher：生产者，也就是要发送消息的程序，但是不再发送到队列中，而是发给交换机
Exchange：交换机。一方面，接收生产者发送的消息。另一方面，知道如何处理消息，例如递交给某个特别队列、递交给所有队列、或是将消息丢弃。到底如何操作，取决于Exchange的类型。Exchange有以下3种类型：
- Fanout：广播，将消息交给所有绑定到交换机的队列
- Direct：定向，把消息交给符合指定routing key 的队列
- Topic：通配符，把消息交给符合routing pattern（路由模式）的队列
Consumer：消费者，与以前一样，订阅队列，没有变化
Queue：消息队列也与以前一样，接收消息、缓存消息

2：简单得代码实现

（1）：在生产者中得代码与之前略有不同，要将消息发布到交换机中

在代码中交换机得名称为“xiaoze.fanout”,消息为：'hello,everyone'.

 //交换机测试@Testpublic void testFanoutExchange() {// 队列名称String exchangeName = "xiaoze.fanout";// 消息String message = "hello, everyone!";rabbitTemplate.convertAndSend(exchangeName, "", message);}

(2)：在消费者中配置交换机以及将交换机与队列进行绑定。

一：config中配置交换机。

@Configuration
public class FanoutConfig {/*** 声明交换机* @return Fanout类型交换机*/@Beanpublic FanoutExchange fanoutExchange(){return new FanoutExchange("xiaoze.fanout");}/*** 第1个队列*/@Beanpublic Queue fanoutQueue1(){return new Queue("fanout.queue1");}/*** 绑定队列1和交换机* @return*/@Beanpublic Binding bindingQueue1(Queue fanoutQueue1, FanoutExchange fanoutExchange){return BindingBuilder.bind(fanoutQueue1).to(fanoutExchange);}/*** 第2个队列*/@Beanpublic Queue fanoutQueue2(){return new Queue("fanout.queue2");}/*** 绑定队列2和交换机*/@Beanpublic Binding bindingQueue2(Queue fanoutQueue2, FanoutExchange fanoutExchange){return BindingBuilder.bind(fanoutQueue2).to(fanoutExchange);}
}

二：在监听器中对两个队列进行监听。

@Component
public class SpringRabbitListener {//使用交换机进行监听@RabbitListener(queues = "fanout.queue1")public void listenFanoutQueue1(String msg) {System.out.println("消费者1接收到Fanout消息：【" + msg + "】");}@RabbitListener(queues = "fanout.queue2")public void listenFanoutQueue2(String msg) {System.out.println("消费者2接收到Fanout消息：【" + msg + "】");}}

（3）：结果图。运行消费者服务，让他时刻处于监听状态，然后在生产者测试中运行测试，进行消息发布。

FanoutExchange交换机简单使用相关推荐

路由器和交换机简单总结（cisco设备）
路由器和交换机简单总结(cisco设备)
华三s5000配置镜像接口_H3C S5000交换机简单配置
H3C S5000 交换机简单配置常用命令 ------- 此状态下为用户模式, 只能查看交换机的配置, 不能进行具体配置 system view ---------- 由用户模式进入配置模式,可简 ...
华三S1824G、S1850V2-28P二层交换机简单配置步骤
交换机Vlan中 tagged和untagged的区别(引用知乎问答): 先说VLAN,一个VLAN就是一个广播域.一个设备连接到一个VLAN,如果这个设备往这个VLAN里发送帧,交换机会把这个帧群发 ...
交换机简单配置 SSH
配置 SSH 拓扑图如下: 1.是否快速配置,这里选择否,输入n 2.进入特权模型查看是否支持ssh加密模式 3.进入全局配置模式,设置域名 4.设置交换机名称和特权密码 5.开启ssh和生成rsa密 ...
aruba 交换机简单维护
一.操作权限级别 ">" 运维模式 "#" 管理模式 "(config)#" 配置模式二.模式进入 enable 进入管理模式(从' ...
锐捷交换机简单配置SNMP
要求:配置交换机的SNMP消息报告机制,向主机192.168.1.2发送Trap,消息版本采用V2C,读写的Community为"admin",只读的Community为" ...
锐捷（五）交换机简单网络管理协议(SNMP)的配置
要求: 在交换机上部署SNMP功能. 1.向主机 172.16.0.254 发送 Trap 消息,版本采用V2C. 2.读写的Community为"admin".只读的Commun ...
RabbitMQ之消息模式简单易懂，超详细分享
前言上一篇对RabbitMQ的流程和相关的理论进行初步的概述,如果小伙伴之前对消息队列不是很了解,那么在看理论时会有些困惑,这里以消息模式为切入点,结合理论细节和代码实践的方式一起来学习. 正文常 ...
RabbitMQ 服务异步通信 -- 入门案例（消息预存机制）、SpringAMQP、发布订阅模式（FanoutExchange、DirectExchange、TopicExchange）、消息转换器
文章目录 1. 入门案例 2. 完成官方Demo中的hello world案例 2.1 创建1个工程,2个模块 2.1.1 父工程的依赖,子工程不需要导入额外的依赖 2.1.2 配置子工程的配置文件( ...

FanoutExchange交换机简单使用

1：首先呢，为什么要使用交换机？

2：简单得代码实现

FanoutExchange交换机简单使用相关推荐

最新文章

热门文章