基于RabbitMQ几种Exchange 模式详解
短信预约 -IT技能 免费直播动态提醒
AMQP协议中的核心思想就是生产者和消费者隔离，生产者从不直接将消息发送给队列。生产者通常不知道是否一个消息会被发送到队列中，只是将消息发送到一个交换机。先由Exchange来接收，然后Exchange按照特定的策略转发到Queue进行存储。同理，消费者也是如此。Exchange 就类似于一个交换机，转发各个消息分发到相应的队列中。
RabbitMQ提供了四种Exchange模式：fanout,direct,topic,header 。 header模式在实际使用中较少，本文只对前三种模式进行比较。
一. Fanout Exchange
所有发送到Fanout Exchange的消息都会被转发到与该Exchange 绑定(Binding)的所有Queue上。
Fanout Exchange 不需要处理RouteKey 。只需要简单的将队列绑定到exchange 上。这样发送到exchange的消息都会被转发到与该交换机绑定的所有队列上。类似子网广播，每台子网内的主机都获得了一份复制的消息。
所以，Fanout Exchange 转发消息是最快的。
/// <summary> /// 生产者 /// </summary> /// <param name="change"></param> private static void ProducerMessage(MyMessage msg) { var advancedBus = CreateAdvancedBus(); if (advancedBus.IsConnected) { var exchange = advancedBus.ExchangeDeclare("user", ExchangeType.Fanout); advancedBus.Publish(exchange, "", false, new Message<MyMessage>(msg)); } else { Console.WriteLine("Can't connect"); } } /// <summary> /// 消费者 /// </summary> private static void ConsumeMessage() { var advancedBus = CreateAdvancedBus(); var exchange = advancedBus.ExchangeDeclare("user", ExchangeType.Fanout); var queue = advancedBus.QueueDeclare("user.notice.wangwu"); advancedBus.Bind(exchange, queue, "user.notice.wangwu"); advancedBus.Consume(queue, registration => { registration.Add<MyMessage>((message, info) => { Console.WriteLine("Body: {0}", message.Body); }); }); }免责声明：
① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的，并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据，供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。
② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341
基于RabbitMQ几种Exchange 模式详解
下载Word文档到电脑，方便收藏和打印～
下载Word文档
猜你喜欢
基于RabbitMQ几种Exchange 模式详解
AMQP协议中的核心思想就是生产者和消费者隔离，生产者从不直接将消息发送给队列。生产者通常不知道是否一个消息会被发送到队列中，只是将消息发送到一个交换机。先由Exchange来接收，然后Exchange按照特定的策略转发到Queue进行存储
2023-05-30
2024-04-02
2024-04-02
2024-04-02
2024-04-02
2024-04-02
基于Android设计模式之--SDK源码之策略模式的详解
策略模式其实特别简单（听到这句话，大家是不是心里一下子放松了？）。比如排序，官方告诉大家我这里有一个排序的接口ISort的sort()方法,然后民间各尽其能，实现这个排序的方法：冒泡，快速，堆等等。这些方法就是“不同的策略”。然后，某个模块
2022-06-06
一文详解Python中实现单例模式的几种常见方式
这篇文章主要为大家介绍了Python中实现单例模式的几种常见方式示例详解，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪
2023-03-22
一文详解基于k8s部署Session模式Flink集群
这篇文章主要为大家介绍了基于k8s部署Session模式Flink集群详解，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪
2023-03-15
以PHP代码为实例详解RabbitMQ消息队列中间件的6种模式
这篇文章主要介绍了以PHP代码为实例详解RabbitMQ消息队列中间件的6种模式，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪
2023-05-19
