分析MQ系列：消息中间件执行原理

返回192.168.1.1

最后更新：2022-05-12 16:29:09 手机定位技术交流文章

1 关于消息中间件

1. 信息的核心点是什么?

在分布式系统中完成发送和接收信息的基本程序称为中间信息。
信件队列 (Message Quue / MQ) 是中间信件的另一个名称。利用与平台无关的有效和可靠的数据交换信息系统发送平台信息是不可能的。数据通信还用于整合分散的系统。通过提供信息传输和排队模式,在分布式环境中,可以加强流程沟通。
简言之,互联网上经常使用新闻通讯来追踪信息、出版订阅和减轻系统负荷。

一、二、修补我们需要多少悲痛?

1. 脱钩:例如,系统A将分配给系统B处理某些问题,但A不想直接与B链接,因此它不会太强大,无法通过在 A、B、A中创建信息队列来做到这一点,在A、B、A中为信息队列指定任务,B用户队列。

这种情形很普遍,例如,A是订单系统,B是库存系统,可通过电文排队方式交给B系统。如果A试图同时获得B、C、D..

命令:一个系统最初处理任何事项需要很长时间,但一旦处理,还可以向信息小组一次提出其他请求。

数据顺序和一致性要求很高的活动,例如不同入境点使用相同的银行卡,必须确保输入顺序和尽量减少数据不一致。

3. 路线:根据不同原则向不同队列发送队列中的信息。

通过信息队列向各种服务发送各种染色请求,从而实现了根据商业情况支付交通费的目标。

4. 逐步处理:在处理一项任务时,有三个阶段A、B和C,需要首先完成A行动,然后是B、C行动,任务能否成功在很大程度上取决于A的结果,但并不取决于B.C的结果。
如果我们使用连环执行,任务周期将更长,整个系统将更没有能力呕吐(事实上,在同一系统中迈出一步成本更高),因此,信息排队是更好的方法。

登录操作的典型情景包括: A: 执行登录和获取结果, B: 记录登录和获取结果, B: 记录登录和 C: 保存用户信息并输入缓存。 A将能够在登录页面开发后从登录页面导航到顶页, B. C. 允许在不干扰当前操作的情况下缓慢消化服务

5. 高峰期:减少高峰期的活动,如全A类同学进程,包括12个阶段,其中以下11个阶段的数据不需要对结果进行标志性强调,可以排在信息队列中。

2 中间信息执行原则

二.1 信件中建集

经纪人:一个信息服务器,作为服务器,提供基本信息服务。
制作人:信息制作人、业务主办人、负责向经纪人发送生产信息
消费者是信息消费者和商业加工者,他们从经纪人那里获得信息并按商业逻辑行事。
主题:主题,其中将发行/订阅模式中的信息合并;多个制片人将信息传送到 " 专题 ",并将信息散布到MQ服务器,供不同用户播放。
队列:在PTP范式中,特定生产商向特定的队列发送信息,而特定消费者则订阅特定的队列,以完成对定义信件的接收。
信息正文:按照各种通信协议规定的固定格式创建的数据集,以包含操作数据并实现信息发送。

下面是卡夫卡的例子。这是一个标准集束模型。Zookeper维持卡夫卡的集群设置。选举leader，当消费者集团发生变化时重新平衡。制片人使用推动模式向Broker发送消息。消费者使用拉动模式接受并消耗来自经纪人的信息。

制作人负责创建信息。
消费者拥有自己的信息。
作为中介信息服务器提供基本信息处理。
生产者和消费者登记和发现动物园管理者

2 两种中中传递模式分类

2.2.1 PTPP点对话框

队列被用作通信载体;制片人将信息发送到队列,而消费者则从队列中检索和消耗信息。
当新闻被吃掉时,它不再保存在队列中,使得消费者无法消费以前被摄取的信息。许多消费者可以在队列中生存,但只有一个消费者可以消费一个信息。

点对点模式有三种作用:

信件队列
发件人( 发件人)
受援者(受援者)

将每条信件发送到指定的队列, 收件人可以从其中接收信件。队列将保留信件, 可以将其保留在记忆中, 并且可以持续到它们被消耗或时间耗尽为止。

特点：

每条消息只有一位消费者(消费者)(即一旦消化,信息就不再出现在新闻队列中)。
发射机和接收机之间没有时间依赖关系。
收到此信件后, 收件人必须成功响应队列。
有了FIFO的先入先出功能,信息序列可以保证。

2.2.2 钚/Sub-Sub-Sub-Sub-Sub-Sub-Sub-Sub-Sub-Sub-Sub-Sub-Sub-Sub-Sub-Sub-Sub-Sub-Sub-Sub-Sub-Sub-Sub-Sub-Sub-Sub-Sub-Sub-Sub-Sub-Sub-Sub-Sub-Sub-Sub-Sub-Sub-Sub-Sub-Sub-Sub-Sub-Sub-Sub-Sub-Sub-Sub-Sub-Sub-Sub-Sub- Sub-Sub-Sub-Sub-Sub- Sub-Sub-Sub- Sub- Sub-Sub- Sub-Sub-Sub- Sub- Sub- Sub-Sub- Sub-Sub- Sub- Sub- Sub- Sub-Sub- Sub- Sub- Sub- Sub- Sub- Sub-Sub- Sub- Sub- Sub- Sub- Sub-Sub- Sub- Sub- Sub- Sub- Sub- Sub-

信息制作者( 出版者) 将信息传播到 Topic, 而多个新闻评论家( 订阅) 则耗尽了它。与点对点战略不同, 给 Topic 的信息被所有订阅者消化。
将生产者生产信息传送给一些消费者所消费的新闻队列,以平衡工作量,但是,每个信息只能由一位消费者接收,如果没有消费者,则保留信息直到消费者出现。

订阅模式的分布有三种作用:

主题（Topic）
出版商(编辑)
订阅订阅

一些出版商向 " 专题 " 提供信息,然后以有条不紊的方式分发给许多订户。

特点：

与点对点技术不同,每条电文可以有若干消费者,所有订户都可以消化。
发行者和订阅者都取决于时间。
在它可能消耗出版商的信息之前,主题(Topic)的订阅者必须先创建订阅者。
用户必须保持活跃,以获得消费新闻。

2.3 中程信息的好处

系统脱钩:由于互动系统之间没有直接的呼叫联系,但只能通过电文传输,因此该系统的侵扰性较小,连接率较低。
加强系统响应时间:例如,最初的逻辑允许将紧急(要求快速反应)行动置于呼叫方法中,低需求访问信息被推迟并排入供消费者处理的MQ队列。
大型数据处理结构服务:在庞大数据的情况下,信息排队也与实时处理结构相连,以便提供数据处理工作协助。

2.4 中间信息标准化机制

使用AMQP协议、MQTT协议、STOMP协议、XMP协议和其他TCP/IP定义的协议信息来创建这一信息。

2.4.1 AMQP

AMCQP 缩写为 AMCQP 。这是一项不限成员名额的申请级协议标准。设计用于一个面向信息的中间物体。电文的中间部分主要用于断开部件。电文发件人不必知道电文收件人的存在。反之亦然。信息方向、队列、路由器(包括点对点和分发/订阅)、可靠性和安全性是AMQP的主要特点。
优点：可靠、通用。

2.4.2 MQTT

MQTT（Message Queuing Telemetry Transport，IBM为传送遥测信息制定了即时通讯协议。这可能是一个关键的组成部分在一个东西的网络。协定涵盖所有平台。几乎可以将所有在线产品与外部世界连接起来。使用Twitter连接房屋。
效益包括格式简单、带宽使用率最低、移动终端通信、统一和卫生政策以及嵌入系统。

2.4.3 STOMP

STOMP是一个基于文本的短信协议。这是MOM的一个例子(Message Oridgeed Middleware)。设计了一个简单的文本协议。STOMP 提供了一个可互操作的连接格式。客户可以与任何STOMP信息代理(Broker)联系。
好处:指挥模式(非专题队列模式)。

2.4.4 XMPP

XMPP(可扩展通信和存在议定书)《XML协议》是《可扩展通信和存在议定书》的基础。最经常用于即时信息(IM)和在线现场探测。它适用于服务器之间的实时活动。核心是围绕XML流建造的。该协议可能允许互联网用户今后在互联网上向任何其他人发送即时信息。
即使它们的操作系统和浏览器各不相同。
好处包括普遍开放、高度兼容、可缩放和高度安全;然而,XML编码格式消耗带宽。

2.5 主流两流通信中心

共同的信息包括:RabbitMQ、RocketMQ、Kafka等等,然后全面分析这些中间体的能力和技术方面以及各种商业情景中的技术解决办法。

原文链接：
https://www.cnblogs.com/wzh2010/p/15888498.html

如果你认为这些材料有用,请传播。

本文由在线网速测试整理编辑，转载请注明出处。