当前位置：首页 > 科技 > 软件

消息队列中间件详解，你学会了吗？

来源：责编：时间：2024-07-11 17:31:23 860观看

导读消息队列中间件消息队列就是Message Queue，本质就是一个保存消息的队列。如下图所示：图片消息队列通常由一个中间件组件提供，它作为消息的中转站，负责接收、存储和转发消息。发送者将消息发送到消息队列中，接收者则从队列

消息队列中间件

消息队列就是Message Queue，本质就是一个保存消息的队列。

如下图所示：

图片

消息队列通常由一个中间件组件提供，它作为消息的中转站，负责接收、存储和转发消息。发送者将消息发送到消息队列中，接收者则从队列中获取消息进行处理。

消息中间件应用场景

消息队列的应用场景，主要包含：异步、解耦、削峰等，如下图所示：

图片

1.异步通信

发送方和接收方不需要直接进行实时的通信，而是通过消息队列中间件进行异步的消息传递

2.解耦和解偶

消息队列可以将发送方和接收方解耦，使得它们可以独立地进行开发、部署和维护

图片

主要会包含：生产者、Broker、消费者...等。

1.生产者

生产者，主要负责发送消息，生产者将消息发送到消息队列。

生产者根据业务逻辑生成消息，这些消息包含各种数据，例如：用户请求、系统事件、日志记录...等。

消费的类型：消息可以是文本、JSON、XML、或其他格式的......数据。

2.消息存储(Broker)

Broker：主要负责接收、存储和转发消息，通常具有持久化机制，确保消息不丢失。

Broker还将消息分发给合适的消费者，可以通过轮询、负载均衡...等方式进行调度。

以及，Broker需要等待消费者确认消息已被成功处理，然后才会将该消息从队列中移除，确保消息不被丢失。

3.消费者接收消息

消费者是消息的接收者和处理者，它从消息队列中读取消息，并执行相应的业务逻辑。

消费者从Broker中读取消息，可以是主动拉取（Pull）、或被动推送（Push）模式。

处理完成后，消费者需要向Broker发送确认信息，通知Broker该消息已被成功处理。

如果没有确认，消息可以重新投递，确保处理的可靠性。

消息队列类型

消息队列主要包含两种：一个是点对点，一个是发布订阅模型。

1.点对点

图片

点对点的特点：每个消息只有一个消费者（Consumer），即一旦被消费，消息就不再在消息队列中。

2.发布订阅

发布订阅模型包含三个角色：主题（Topic）、发布者（Publisher）、订阅者（Subscriber）。

如下图所示：

图片

消息协议

消息协议是消息队列中间件的重要组成部分，决定了消息的格式、传输方式、和通信规则。

1.JMS

Java Message Service（JMS）是Java平台上用于消息通信的标准API，提供了一种通用的方式来创建、发送、接收和读取消息。

比如：老牌的ActiveMQ，就是典型的JMS实现。

2.AMQP

AMQP，全程是“Advanced Message Queuing Protocol”，是一种开放标准的应用层协议。

特点是：

AMQP协议设计为与平台无关，支持多种编程语言；
通过交换机（Exchange），实现复杂的消息路由机制，包括：直接交换（Direct）、主题交换（Topic）...等。
支持消息确认、持久化、事务、死信队列...等功能，确保消息的可靠传递和处理。

rabbitmq，就是典型的AMQP的实现。

3.MQTT

Message Queuing Telemetry Transport（MQTT），是一种轻量级的发布/订阅消息协议，设计用于低带宽、高延迟、或不可靠的网络环境。

消息队列有哪些

常见的消息队列有：ActiveMQ、RocketMQ、Kafka、Pulsar、RabbitMQ等等。

如下图所示：

图片

RabbitMQ：RabbitMQ是一个开源的消息队列系统，它实现了AMQP（Advanced Message Queuing Protocol）协议，并提供了丰富的功能，如消息持久化、消息确认、灵活的路由和绑定等。
Apache Kafka：Apache Kafka是一个分布式的流式平台，它可以处理大规模的实时数据流。Kafka基于发布-订阅模型，具有高吞吐量和持久性，适用于处理大量实时数据的场景。
ActiveMQ：ActiveMQ是Apache基金会的一个开源消息中间件，支持JMS（Java Message Service）规范。它提供了多种通信模式，如点对点（P2P）和发布-订阅（Pub/Sub），并具有可靠性、可扩展性和高可用性。
Redis：Redis是一个内存数据库，但也可以用作消息队列。Redis提供了List、Pub/Sub等数据结构和命令，可以实现简单的消息队列功能。
Apache Pulsar：Apache Pulsar是一个开源的分布式消息和流处理平台，具有高性能、可扩展性和持久化特性。Pulsar支持多租户、多数据中心部署和动态扩展，适用于大规模和复杂的消息队列和流处理场景。

选型比较

ActiveMQ	JMS，多协议支持	成熟稳定，功能丰富，多语言支持	性能有限，管理复杂	中小规模企业应用，需要JMS功能支持的场景

RocketMQ	高性能，强事务消息，分布式架构	高吞吐量低延迟，分布式，强一致性	社区支持少，运维复杂	互联网和金融系统，高吞吐量和严格一致性场景

Kafka	高吞吐量，日志式存储，分区和复制	高性能，可扩展，生态系统丰富	延迟较高，不支持事务消息	大数据处理，实时流处理，需要高吞吐和扩展性场景

Pulsar	多租户，分层架构，原生流处理	高性能，持久化存储，灵活扩展	学习曲线陡，社区和生态系统较小	云环境和企业系统，多租户和高性能消息传递场

RabbitMQ	基于AMQP，灵活路由，丰富插件	易于使用，功能丰富，多语言支持	性能有限，集群管理复杂	中小规模企业应用，复杂路由和消息确认场景

总的来说

互联网和金融系统，高吞吐量和严格一致性场景，可以选择：RocketMQ;

中小规模企业应用，复杂路由、和消息确认场景，可以选择：RabbitMQ;

大数据处理，实时流处理，需要高吞吐、和扩展性场景，可以选择Kafka。

本文链接：http://www.28at.com/showinfo-26-100465-0.html消息队列中间件详解，你学会了吗？

声明：本网页内容旨在传播知识，若有侵权等问题请及时与本网联系，我们将在第一时间删除处理。邮件：2376512515@qq.com

上一篇：基于Rspack实现大仓应用构建提效实践

下一篇： Springboot如何通过配置来决定使用的Web容器

标签：

热门焦点

小米平板5 Pro 12.4简评：多专多能兼顾影音娱乐的大屏利器

疫情带来了网课，网课盘活了安卓平板，安卓平板市场虽然中途停滞了几年，但好的一点就是停滞的这几年行业又有了新的发展方向，例如超窄边框、高刷新率、多摄镜头组合等，这就让安卓
帅气纯真少年！日本最帅初中生选美冠军出炉

日本第一帅哥初一生选美大赛冠军现已正式出炉，冠军是来自千叶县的宗田悠良。日本一直热衷于各种选美大赛，从“最美JK”起到“最美女星&r
容量越大越不坏？24万块硬盘故障率报告公布这些产品零故障

8月5日消息，云存储服务商Backblaze发布了最新的硬盘故障率报告，年故障率有所上升。Backblaze发布的硬盘季度统计数据，其中包括故障率等重要方面。这些结
2023 年的 Node.js 生态系统

随着技术的不断演进和创新，Node.js 在 2023 年达到了一个新的高度。Node.js 拥有一个庞大的生态系统，可以帮助开发人员更快地实现复杂的应用。本文就来看看 Node.js 最新的生
得物效率前端微应用推进过程与思考

一、背景效率工程随着业务的发展，组织规模的扩大，越来越多的企业开始意识到协作效率对于企业团队的重要性，甚至是决定其在某个行业竞争中突围的关键，是企业长久生存的根本。得物
为什么你不应该使用Div作为可点击元素

按钮是为任何网络应用程序提供交互性的最常见方式。但我们经常倾向于使用其他HTML元素，如 div span 等作为 clickable 元素。但通过这样做，我们错过了许多内置浏览器的功能。
10天营收超1亿美元，《星铁》比《原神》差在哪？

来源：伯虎财经作者：陈平安即便你没玩过《原神》，你一定听说过的它的大名。恨它的人把《原神》开服那天称作是中国游戏史上最黑暗的一天，有粉丝因为索尼在PS平台上线《原神》，怒而
阿里大调整

来源：产品刘有媒体报道称，近期淘宝天猫集团启动了近年来最大的人力制度改革，涉及员工绩效、层级体系等多个核心事项，目前已形成一个初步的“征求意见版”：1、取消P序列
华为Mate 60保护壳曝光：硕大后置相机模组凸起程度有惊喜

这段时间以来，关于华为新旗舰的爆料日渐密集。据此前多方爆料，今年华为将开始恢复一年双旗舰战略，除上半年推出的P60系列外，往年下半年的Mate系列也将

消息队列中间件详解，你学会了吗？

消息队列中间件

消息中间件应用场景

1.异步通信

2.解耦和解偶

1.生产者

2.消息存储(Broker)

3.消费者接收消息

消息队列类型

1.点对点

2.发布订阅

消息协议

1.JMS

2.AMQP

3.MQTT

消息队列有哪些

总的来说

小米平板5 Pro 12.4简评：多专多能兼顾影音娱乐的大屏利器

帅气纯真少年！日本最帅初中生选美冠军出炉

容量越大越不坏？24万块硬盘故障率报告公布这些产品零故障

2023 年的 Node.js 生态系统

得物效率前端微应用推进过程与思考

为什么你不应该使用Div作为可点击元素

10天营收超1亿美元，《星铁》比《原神》差在哪？

阿里大调整

华为Mate 60保护壳曝光：硕大后置相机模组凸起程度有惊喜

最新推荐

猜你喜欢

热门推荐

相关资讯