关于 MQ 的界说
Message Queue（MQ）新闻行列中心件，通常我们在网上看到的对其界说是将新闻的发送和接受星散来实现应用程序的异步息争耦，给人的直觉是 MQ 是异步的，用来解耦的。但这个只是 MQ 的效果，而不是目的。MQ 真正的目的是为了通讯，屏障底层庞大的通讯协议，界说了一套应用层上加倍简朴的通讯协议。
一套分布式系统中两个模块之间通讯要么是 HTTP，要么是 TCP，但这两种协议实在都是原始的协议。前者实现通讯就必须要做到各客户端都有 WebServer，而且不支持长毗邻；后者就加倍原始了 — 粘包、心跳、私有的协议。
而 MQ 所要做就是在基于这些现有的协议之上构建一个更简朴的通讯（生产者/消费者）模子。它界说了两个工具 —发送数据的叫生产者，接受数据的叫消费者，提供一个 SDK 给我们自己界说生产者和消费者实现新闻通讯，且无视底层通讯协议。
带 Broker 的派别
这个派别通常有一台服务器作为 Broker，所有的新闻都通过它举行中转。生产者把新闻发送给它就竣事自己的义务了，最后 Broker 则把新闻自动推送给消费者（或者消费者自动轮询）。
重 Topic 的 MQ
Kafka、Active MQ 就属于这个派别：生产者发送 key 和数据到 Broker，由 Broker 对照 key 之后决议给哪个消费者。
在这种模式下，Topic（主题新闻） 往往是一个对照大的观点，甚至一个系统中就可能只有一个 Topic。
虽然这两种新闻行列的架构一样，然则 Kafka 的性能要比 Active MQ 的性能不知道高到多少倍，以是基本这种类型的 MQ 只有 Kafka一种备选方案。
轻 Topic 的 MQ
这种的代表是 RabbitMQ（AMQP）。生产者发送 key 和数据，Borker 收到数据之后会凭据 key 通过一定的逻辑计算出响应的行列，最后消费者订阅行列。
在这种架构中 Queue 是异常轻量级的（在 RabbitMQ 中它的上限取决于你的内存），消费者体贴的只是自己的 Queue；生产者不必体贴数据最终给谁，只要指定 key 就行了。中心的那层映射在 AMQP 中叫 exchange（交换机）。
AMQP 中有四种 exchange：
Direct exchange：key即是queue。Fanout exchange：无视key，给所有的queue都来一份。Topic exchange：key可以用 “宽字符” 模糊匹配queue。Headers exchange：无视key，通过查看新闻的头部元数据来决议发给哪个queue。
这种架构给通讯带来了极大的灵活性，我们能想到的通讯方式都可以用这四种 exchange 表达出来。
不带 Broker 的派别
ZeroMQ
不带 Broker 的 MQ 代表就是 ZeroMQ。可以说是解决通讯问题的更高级 Socket，它被设计成了一个 “库” 而不是一个中心件，这种实现也可以到达没有 Broker 的目的。
各节点之间的通讯都是发送到相互的行列中，每个节点即是生产者也是消费者。类似于一套 Socket 的 API，可以完成发送和读取数据。
,
文章作者：彭超
本文首发于小我私家博客：https://antoniopeng.com/2020/06/15/mq/%E8%B0%88%E8%B0%88%E6%B6%88%E6%81%AF%E9%98%9F%E5%88%97%E7%9A%84%E6%B5%81%E6%B4%BE/
版权声明：本博客所有文章除稀奇声明外，均接纳 CC BY-NC-SA 4.0 允许协议。转载请注明来自 彭超 | Blog！
欢迎进入欧博官网手机（Allbet Game）：www.aLLbetgame.us，欧博官网是欧博集团的官方网站。欧博官网开放Allbet注册、Allbe代理、Allbet电脑客户端、Allbet手机版下载等业务。
转载声明：本站发布文章及版权归原作者所有，转载本站文章请注明文章来源！
网友评论