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

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

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

导读消息队列中间件消息队列就是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月安卓手机好评榜：魅族20 Pro夺冠

性能榜和性价比榜之后，我们来看最后的安卓手机好评榜，数据来源安兔兔评测，收集时间2023年5月1日至5月31日，仅限国内市场。第一名：魅族20 Pro好评率：97.50%不得不感慨魅族老品牌还
太卷！Redmi MAX 100英寸电视便宜了：12999元买Redmi史上最大屏

8月5日消息，从小米商城了解到，Redmi MAX 100英寸巨屏电视日前迎来官方优惠，到手价12999元，比发布价便宜了7000元，在大屏电视市场开卷。据了解，Redmi MAX 100
摸鱼心法第一章——和配置文件说拜拜

为了能摸鱼我们团队做了容器化，但是带来的问题是服务配置文件很麻烦，然后大家在群里进行了“亲切友好”的沟通图片图片图片图片对比就对比，简单对比下独立配置中心和k8s作为配
腾讯盖楼，字节拆墙

来源 | 光子星球撰文 | 吴坤谚编辑 | 吴先之“想重温暴刷深渊、30+技能搭配暴搓到爽的游戏体验吗？一起上晶核，即刻暴打！”曾凭借直播腾讯旗下代理格斗游戏《DNF》一
阿里大调整

来源：产品刘有媒体报道称，近期淘宝天猫集团启动了近年来最大的人力制度改革，涉及员工绩效、层级体系等多个核心事项，目前已形成一个初步的“征求意见版”：1、取消P序列
AI芯片初创公司Tenstorrent获三星和现代1亿美元投资

Tenstorrent是一家由芯片行业资深人士Jim Keller领导的加拿大初创公司，专注于开发人工智能芯片，该公司周三表示，已经从现代汽车集团和三星投资基金等
三星折叠屏手机去年销售近1000万台今年目标定为1500万

7月29日消息，三星率先发力可折叠手机市场，在全球市场已经取得了非常亮眼的成绩，接下来会进一步巩固和扩大这一优势。三星在推出Galaxy Z Flip5和Galax
iQOO Neo8 Pro抢先上架：首发天玑9200+ 安卓性能之王

经过了一段时间的密集爆料，昨日iQOO官方如期对外宣布：将于5月23日推出全新的iQOO Neo8系列新品，官方称这是一款拥有旗舰级性能调校的作品。随着发布时
与兆芯合作联想推出全新旗舰版笔记本电脑开天N7系列

联想与兆芯合作推出全新联想旗舰版笔记本电脑开天 N7系列。这个系列采用兆芯KX-6640MA处理器平台，KX-6640MA 处理器是采用了陆家嘴架构，16nm 工艺，4 核 4 线

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

消息队列中间件

消息中间件应用场景

1.异步通信

2.解耦和解偶

1.生产者

2.消息存储(Broker)

3.消费者接收消息

消息队列类型

1.点对点

2.发布订阅

消息协议

1.JMS

2.AMQP

3.MQTT

消息队列有哪些

总的来说

5月安卓手机好评榜：魅族20 Pro夺冠

太卷！Redmi MAX 100英寸电视便宜了：12999元买Redmi史上最大屏

摸鱼心法第一章——和配置文件说拜拜

腾讯盖楼，字节拆墙

阿里大调整

AI芯片初创公司Tenstorrent获三星和现代1亿美元投资

三星折叠屏手机去年销售近1000万台今年目标定为1500万

iQOO Neo8 Pro抢先上架：首发天玑9200+ 安卓性能之王

与兆芯合作联想推出全新旗舰版笔记本电脑开天N7系列

最新推荐

猜你喜欢

热门推荐

相关资讯