中间件消息发布者与消息中间件的交互

简介: 【6月更文挑战第11天】

image.png
中间件消息发布者与消息中间件的交互主要涉及消息的创建、发送、存储和转发等过程。以下是关于这两者之间交互的详细解释:

  1. 消息创建与发送

    • 消息发布者(也称为生产者或发送方)负责创建消息。这些消息可以包含各种类型的数据,如简单文本、复杂的对象等。
    • 消息由两部分组成:消息头和消息体。消息头包含元数据,如目标地址、消息优先级等;消息体则是实际传输的数据。
    • 消息发布者通过消息中间件提供的API或接口,将消息发送到消息中间件。
  2. 消息存储

    • 消息中间件接收到消息后,会根据配置和策略将消息存储在内部的队列或主题中。
    • 队列(Queue)和主题(Topic)是消息中间件支持的两种主要消息传递模型。队列用于点对点(Point-to-Point, P2P)模型,消息被发送到一个队列,每个消息只能被一个消费者接收和处理;主题用于发布/订阅(Publish/Subscribe, Pub/Sub)模型,消息被发布到一个主题,所有订阅了该主题的消费者都可以接收到消息。
  3. 消息转发

    • 消息中间件根据配置的规则,在合适的时候将消息从队列或主题中取出,并转发给订阅了该队列或主题的消费者(也称为接收方或订阅者)。
    • 消息转发可以是同步的(即消费者立即接收消息)或异步的(即消费者可以在稍后的时间接收消息)。
  4. 消息持久性与传递保障

    • 消息中间件通常提供不同级别的消息持久性(是否存储消息直到它被消费)和传递保障(如仅一次、至少一次、最多一次)。这些特性保证了消息传递的可靠性。
  5. 其他特性

    • 部分消息中间件还支持交易性消息(Transactional Messaging),这允许在发送或接收消息的过程中执行一系列操作,要么全部成功,要么全部撤回,保证了数据的一致性和完整性。
  6. 总结

    • 中间件消息发布者与消息中间件之间的交互是一个复杂但高效的过程,它确保了消息在网络中的可靠传递,并支持各种复杂的分布式系统场景。通过熟悉消息中间件的核心概念和特性,架构师和开发人员可以更好地设计和构建分布式系统,提高系统的性能和可伸缩性。
目录
相关文章
|
6月前
|
消息中间件 存储 监控
中间件消息发布者功能特性
【6月更文挑战第11天】
50 5
|
6月前
|
XML 监控 中间件
中间件消息发布者角色定位
【6月更文挑战第11天】
54 5
|
5月前
|
消息中间件 Cloud Native 中间件
云原生中间件问题之消息中间件MetaQ中的NameServer如何解决
云原生中间件问题之消息中间件MetaQ中的NameServer如何解决
|
6月前
|
消息中间件 存储 监控
中间件消息发布者(Publisher)
【6月更文挑战第10天】
42 1
|
7月前
|
缓存 监控 中间件
中间件Cache-Aside策略应用程序直接与缓存和数据库进行交互
【5月更文挑战第8天】中间件Cache-Aside策略应用程序直接与缓存和数据库进行交互
85 4
|
消息中间件 存储 运维
消息队列与消息中间件概述:消息中间件核心概念与技术选型
消息队列是一个存放消息的容器,消息队列是分布式系统中重要的组件,使用消息队列主要是为了通过异步处理提高系统性能、削峰、降低系统耦合性。
607 14
|
新零售 消息中间件 监控
消息中间件系列一、消息中间件的基本了解
一、消息中间件的定义:   没有标准定义,一般认为,采用消息传送机制/消息队列 的中间件技术,进行数据交流,用在分布式系统的集成 二、为什么要用消息中间件? 解决分布式系统之间消息的传递。电商场景:  用户下单减库存,调用物流系统,系统扩充后服务化和业务拆分。
4409 10
|
消息中间件 RocketMQ 中间件
业务系统对消息中间件的要求(接上一篇《分布式消息中间件中的一些概念》)
  在大型互联网中,主要采用消息中间件来进行业务的解耦和操作的异步化,这也是消息中间件最基础的特点,也是业务系统对消息中间件的最基本需求。   在这个基础之上,本篇来谈一下业务系统从功能、性能等各个方面对消息中间件的需求。
1031 7
|
存储 消息中间件 缓存
分布式消息中间件中的一些概念(接上一篇的《什么是分布式消息中间件?》)
接上一篇的《什么是分布式消息中间件?》,这一篇来介绍一下消息中间件相关的一些概念和专业术语。   Topic 主题,从逻辑上讲一个Topic就是一个Queue,即一个队列;从存储上讲,一个Topic存储了一类相同的消息,是一类消息的集合。
1049 1
|
6月前
|
消息中间件 存储 中间件
【消息中间件】详解三大MQ:RabbitMQ、RocketMQ、Kafka
【消息中间件】详解三大MQ:RabbitMQ、RocketMQ、Kafka
1642 0