乡土文化网站怎么做,戴尔网站建设和维护,网页设计图片边框代码,南宁工程建设网站有哪些发布订阅模型:
MQ提供了很多交换机模型 其中常用的有下边三个:
Fanout:广播
Direct:路由
Topic:话题
转换器只负责消息路由#xff0c;不是存储#xff0c;路由失败则消息丢失 Fanout Exchange:会将接收到的消息路由导每一个跟其绑定的queue.
利用SpringAMQP演示Fanout…发布订阅模型:
MQ提供了很多交换机模型 其中常用的有下边三个:
Fanout:广播
Direct:路由
Topic:话题
转换器只负责消息路由不是存储路由失败则消息丢失 Fanout Exchange:会将接收到的消息路由导每一个跟其绑定的queue.
利用SpringAMQP演示FanoutExchange的使用: 实现代码:
在consumer编写工具类实现交换机和队列的绑定:
package cn.itcast.mq.configu;import org.springframework.amqp.core.Binding;
import org.springframework.amqp.core.BindingBuilder;
import org.springframework.amqp.core.FanoutExchange;
import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;/*** className:cn.itcast.mq.configu.BindExchangeToQueue* description:by-li* author:Administrator* create:2024-05-1116:33*/
Configuration
public class BindExchangeToQueue {//声明交换机Beanpublic FanoutExchange fanoutExchange() {return new FanoutExchange(itcast.fanout);}//生命queueBeanpublic Queue fanoutqueue1() {return new Queue(itcast.queue1);}Beanpublic Queue fanoutqueue2() {return new Queue(itcast.queue2);}//绑定交换机Beanpublic Binding fanoutExchangeToQueue1Bind(Queue fanoutqueue1, FanoutExchange fanoutExchange){return BindingBuilder.bind(fanoutqueue1).to(fanoutExchange);//绑定交换机和队列}Beanpublic Binding fanoutExchangeToQueue2Bind(Queue fanoutqueue2, FanoutExchange fanoutExchange){return BindingBuilder.bind(fanoutqueue2).to(fanoutExchange);//绑定交换机和队列}}在consumer实体类里编写接收两个队列请求的方法: RabbitListener(queues itcast.queue1)public void lintestFanoutExchangeToQueue1(String mes) throws InterruptedException {System.out.println(从队列1中获取到了消息:mes);Thread.sleep(200);}RabbitListener(queues itcast.queue2)public void lintestFanoutExchangeToQueue2(String mes) throws InterruptedException {System.out.println(从队列2中获取到了消息:mes);Thread.sleep(200);}
在publisher里编写测试方法 模拟给交换机发送消息:
//给FanoutExchange交换机发送消息Testpublic void testFanoutExchangeSend(){String FanoutChangeName itcast.fanout;String msg我是fannout发送的消息;rabbitTemplate.convertAndSend(FanoutChangeName,,msg);}
然后发送请求和启动consumer类在控制台查看: 这里看到我们只发送了一条消息但是两个consumer消费者都接收到了消息能看出来Fanout Exchange交换机将收到的消息发到了给他绑定的两个queue里了 总结
