RabbitMQ 实在一共有六种工作模式：简单模式（Simple）、工作队列模式（Work Queue）、发布订阅模式（Publish/Subscribe）、路由模式（Routing）、通配符模式（Topic）、远程调用模式（RPC)。其中发布订阅模式、路由模式、通配符模式这三种模型都属于订阅模式，只不过它们之间举行路由的方式不同罢了。远程调用模式是 RPC 不属于MQ，以是最终统计下来就是五种工作模式。
1.简单模式（Simple）
RabbitMQ 的简单模式提供了一种根本的消息传递机制，适合初学者和简单应用。通过了解生产者、消费者、队列和互换机的根本概念，您可以快速上手并实现根本的消息传递功能，其详细流程如下：
留意：生产者到队列之间是有互换机的，一样平常接纳的默认互换机，此处省略了。
联合表示图案例分析： RabbitMQ是一个消息代理，它担当和转发消息。我们可以把它抽象成一个货运仓库，当商家把商品打包放进仓库后，可以确定快递员末了一定会把快递送到收件人手里。
表示图解释： P（Producer / Publisher）:生产者， 一个发送消息的用户应用程序。 C（Consumer）: 消费者，一个用来等候接收消息的用户应用程序。 Queue（赤色区域）：消息队列，作用是接收消息、缓存消息，队列只受主机的内存和磁盘限定。生产者将消息发送到队列，队列是存储消息的缓冲区，消费者从队列中获取消息。 应用场景： 简单的发送与接收，没有特殊的处理。
简单模式特点： 1、一个生产者对应一个消费者，通过队列举行消息传递。 2、利用默认的direct互换机。
2.工作队列模式（Work Queue）
与简单模式相比，工作队列模式(Work Queue)多了一些消费者，该模式也利用direct互换机，应用于处理消息较多的情况。 留意：下面的三种订阅模式中，再后半部门的消费中，我们都可以引用工作模式中的多消费者机制，详细如下图：
特点： 一个队列对应多个消费者，通过队列举行消息传递 一条消息同一时刻只会被一个消费者消费 消息队列默认接纳轮询的方式将消息均匀发送给消费者 利用Rabbitmq默认互换机direct。
应用场景： 对于使命过重或使命较多情况利用工作队列可以提高使命处理的速度。
存在问题：（1） 工作队列模式 利用了MessageProperties.PERSISTENT_TEXT_PLAIN 来设置消息持久化，目的是为了保证数据安全可靠不丢失。但是，事与愿违。消息虽然被标记为持久化却并不能完全保证消息不会丢失。尽管MessageProperties.PERSISTENT_TEXT_PLAIN 告诉 RabbitMQ 将消息生存到磁盘，但是这里依然存在当消息刚准备存储在磁盘的时间；可能存在还没有存储完的情况，消息还在缓存的一个间隔点。此时并没有真正写入磁盘。因此持久性保证并不强，进而需要引入发布确认、ACK来解决该问题。
（2） 多个消费者举行消息消费，由于消息是轮询均匀发送给消费者。可能会有某个消费者Slow；由于要处理其他复杂的业务逻辑，其消费的效率相对其他消费者比较慢，这个就会造成当其他消费者已经消费完处于空闲状态时，因均匀分配原则，队列任会继续把消息发给 Slow 处于繁忙状态，大大降低了体系的性能。正确的做法的是“能劳者多劳；消费越快的，让其消费的越多”。
解决方案：（1）设置预取计数：在消费者中设置预取计数，以控制未确认消息的数目 （2）启用手动确认：关闭自动确认，手动确认每条处理完的消息。
原生态中通过在代码中利用int prefetchCount = 1; channel.basicQos(prefetchCount); 举行解决。
Springboot整合版通过在配置文件中利用spring.rabbitmq.listener.simple.acknowledge-mode: manual spring.rabbitmq.listener.simple.prefetch: 1 举行解决。
3.发布订阅模式（Publish/Subscribe）
生产者将消息发送给互换机，互换机将消息转发到绑定此互换机的每个队列中；工作队列模式的互换机只能将消息发送给一个队列（路由键匹配的队列），发布订阅模式的互换性能将消息发送给多个队列。发布订阅模式利用 fanout 互换机。
假如此时每个队列中的使命比较多，此时我们可以界说多个消费者绑定同一个队列，此时就形成了前半部门是订阅模式，后半部门是工作模式，而后半部门的工作模式再消费的时间我们即可以利用默认的轮询均匀分配也可以利用能者多劳的分配方式。 如下图：
4.路由模式（Routing）
路由（Routing）模式是发布订阅模式的升级版。我们知道发布订阅模式是无条件地将全部消息分发给全部消费者队列，每个队列中都有相同的消息；路由模式，由下图很容易理解，每个队列消息会由于绑定的路由不同而不同。
特点：1、每个队列绑定一个路由关键字RoutingKey，生产者将带有RoutingKey的消息发送给互换机，互换机再根据路由 RoutingKey关键字将消息定向发送到指定的队列中；2、默认利用 direct 互换机。
应用场景：1、如在电商网站的促销活动中，双十一搞促销活动会把促销消息发布到全部队列中去；而一些小的促销活动为了节约本钱，只发布到站内信队列。2、为了节省磁盘空间，需要将重要的错误消息引导到日志文件，同时仍然能够在控制台上打印输出全部日志消息。
路由模式是一种精准的匹配，只有设置了 Routing Key 后消息才华举行分发。
5.通配符模式（Topic）
通配符模式(Topic)是在路由模式的底子上升级，给队列绑定带通配符的路由关键字，只要消息的RoutingKey 能实现通配符匹配而不再是固定的字符串，就会将消息转发到该队列。通配符模式比路由模式更灵活。 如下图：
特点：1、消息设置RoutingKey时，RoutingKey由多个单词构成，中间以 . 分割。2、队列设置RoutingKey时，#可以匹配恣意多个单词（包含0个），*可以匹配恣意一个单词。3、利用 topic 互换机。
应用场景：通配符模式的匹配规则相对于路由模式要显得抽象，好比工厂生产手机屏，虽然手机屏的品牌（vivo、华为、光彩）有许多，但是只要有手机屏产出就会发送一条消息给厂商，时刻统计手机屏的数目。路由模式方案：每个手机品牌独占一个队列和互换机绑定一个唯一标识 RoutingKey 手机品牌；通配符模式：一个队列和互换机绑定一个通配的标识 RoutingKey 即可。
留意：（1）在rabbitmq中一个队列可以绑定多个路由键channel.queueBind("SEND_STATION2", ROUTE_NAME, "A"); channel.queueBind("SEND_STATION2", ROUTE_NAME, "B"); 这样SEND_STATION2队列就绑定了两个路由键，只要满意其中一个即会往该队列中添加消息。
（2）多个队列可以绑定相同的路由键channel.queueBind("SEND_STATION1", ROUTE_NAME, "A"); channel.queueBind("SEND_STATION2", ROUTE_NAME, "A"); 这样生产者在推送路由键A的消息时两个队列均可担当到该消息。
（3）一个消费者可以同时绑定多个队列举行消费channel1.basicConsume(“A”, true, consumer1);channel1.basicConsume(“B”, true, consumer2); 这样该消费者即可监听A大概B队列
假如你想从底层源码了解Spring Boot整合RabbitMq的原理，如何生产消息推送到互换机，如何举行消费，可以参考以下文章：从源码层级深入探索 Spring AMQP 如安在 Spring Boot 中实现 RabbitMQ 集成——生产者如何将消息发送到 RabbitMQ Exchange-CSDN博客
从源码层级深入探索 Spring AMQP 如安在 Spring Boot 中实现 RabbitMQ 集成——消费者如何举行消费-CSDN博客
免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。 |
