云消息队列 MQ解析的相关内容

文章 2024-11-22 来自：开发者社区

RocketMQ文件刷盘机制深度解析与Java模拟实现

引言在现代分布式系统中，消息队列（Message Queue, MQ）作为一种重要的中间件，扮演着连接不同服务、实现异步通信和消息解耦的关键角色。Apache RocketMQ作为一款高性能的分布式消息中间件，广泛应用于实时数据流处理、日志流处理等场景。为了保证消息的可靠性，RocketMQ引入了一种称为“刷盘”的机制，将消息从内存写入到磁盘中，确保消息持久化。本文将从底层原理、业务场...

文章 2024-10-16 来自：开发者社区

RocketMQ消息重试机制解析！

由于网络抖动、服务宕机等一些不确定的因素，RocketMQ在发送消息的时候很有可能出现消息发送或者消费失败的问题。所以RocketMQ消息重试分为2种： Producer端重试和Consumer端重试。 Producer端重试 ...

文章 2024-09-18 来自：开发者社区

RocketMQ消息回溯实践与解析

在分布式系统和高并发应用的开发中，消息队列扮演着至关重要的角色，而RocketMQ作为阿里巴巴开源的一款高性能消息中间件，以其高吞吐量、高可用性和灵活的配置能力，在业界得到了广泛应用。本文将围绕RocketMQ的消息回溯功能进行实践与解析，分享工作学习中的技术干货。一、RocketMQ简介 RocketMQ是阿里巴巴开源的一款分布式消息中间件，使用Java语言编写，并经过双十一...

文章 2024-08-24 来自：开发者社区

【RabbitMQ深度解析】Topic交换器与模式匹配：掌握消息路由的艺术！

在消息队列（MQ）的世界中，交换器是消息路由的核心组件之一。它负责接收生产者发送的消息，并根据一定的规则将消息路由到一个或多个队列中，供消费者消费。其中，topic交换器是RabbitMQ中实现发布-订阅模式的一种交换器类型，它能够根据模式匹配来路由消息。本文将对MQ中的topic交换器及其模式匹配...

文章 2024-07-17 来自：开发者社区

RocketMQ 是大家耳熟能详的消息队列，开源项目 rocketmq-spring 可以帮助开发者在 Spring Boot 项目中快速整合 RocketMQ。这篇文章会介绍 Spring Boot 项目使用 rocketmq-spring SDK 实现消息收发的操作流程，同时笔者会从开发者的角度解读 SDK 的设计逻辑。1 SDK 简介项目地址：https://github.com/apac....

文章 2024-06-26 来自：开发者社区

RocketMQ与Kafka深度对比：特性与适用场景解析

一、数据可靠性数据可靠性是消息中间件的核心指标之一。RocketMQ和Kafka在这方面采取了不同的策略。 RocketMQ提供了多种级别的数据可靠性保证，包括异步实时刷盘、同步刷盘、同步复制和异步复制。其中，同步刷盘功能可以在消息写入后立即将其持久化到磁盘，确保即使在操作系统崩溃的情况下，消息也不会丢失。这种机制使得RocketMQ在单机可靠性上表现优异。 ...

文章 2024-06-16 来自：开发者社区

RabbitMQ揭秘：轻量级消息队列的优缺点全解析

亲爱的读者朋友们，大家好！我是小米，一个热爱技术、喜欢分享的大哥哥。今天我们来聊聊一个在消息队列领域非常重要的工具——RabbitMQ。作为一个在通信领域广泛应用的可靠消息中间件，RabbitMQ有很多值得称道的优点，同时也有一些我们在使用中需要注意的地方。让我们一起来深入了解这个神奇的工具吧！ RabbitMQ的起源 RabbitMQ的诞生可以追溯到电信行业。它最初是为了满足电...

文章 2024-06-05 来自：开发者社区

MQTT 5.0 报文解析 06：AUTH

欢迎阅读 MQTT 5.0 报文系列的最后一篇文章。在上一篇中，我们已经介绍了 MQTT 5.0 的 DISCONNECT 报文。现在，我们将介绍 MQTT 中的最后一个控制报文：AUTH。 MQTT 5.0 引入了增强认证特性，它使 MQTT 除了简单密码认证和 Token 认证以外，还能够支持质询/响应风格的认证。为了实现这一点，它在原先 CONNECT 和 CONNACK 报文的基础上.....

文章 2024-05-30 来自：开发者社区

MQTT 5.0 报文解析 05：DISCONNECT

欢迎阅读 MQTT 5.0 报文系列的第五篇文章。在上一篇中，我们已经介绍了 MQTT 5.0 的 PINGREQ 和 PINGRESP 报文。现在，我们将介绍下一个控制报文：DISCONNECT。在 MQTT 中，客户端和服务端可以在断开网络连接前向对端发送一个 DISCONNECT 报文，来指示连接关闭的原因。客户端发送的 DISCONNECT 报文还可以影响服务端在连接断开后的行为，例.....

文章 2024-05-22 来自：开发者社区

MQTT 5.0 报文解析 04：PINGREQ 与 PINGRESP

欢迎阅读 MQTT 5.0 报文系列的第四篇文章。在上一篇中，我们已经介绍了 MQTT 5.0 中的 SUBSCRIBE 报文和 UNSUBSCRIBE 报文。现在，我们将介绍用于维持连接的控制报文：PINGREQ 和 PINGRESP。除了用于连接、发布和订阅的控制报文，MQTT 还有一类报文用于在客户端和服务端之间模拟心跳，以达到保持连接的目的，它们分别是 PINGREQ 报文和 PI.....