介绍 RocketMQ是阿里巴巴开源的分布式消息中间件，它是一个高性能、低延迟、可靠的消息队列系统，用于在分布式系统中进行异步通信。 从4.3.0版本开始正式支持分布式事务消息~ RocketMq事务消息支持最终一致性：在普通消息基础上，支持二阶段的提交能力。将二阶段提交和本地事务绑定，实现全局提交
2023-08-23
归去，也无风雨也无晴。 哈喽大家好呀，好久不见，今天继续来跟大家聊一聊RocketMQ吧，上回书说到了RocketMQ的性能优化，有兴趣的同学可以回去翻一翻上一篇文章： 关于RocketMQ那些你可能不知道的性能优化 其实顺序消息是业务中常用的功能之一，只要是使用MQ的，就不太可能绕的过去这个问
2023-08-18
作者：小傅哥 博客：bugstack.cn 沉淀、分享、成长，让自己和他人都能有所收获！😄 本文的宗旨在于通过简单干净实践的方式教会读者，使用 Docker 配置 RocketMQ 并在基于 DDD 分层结构的 SpringBoot 工程中使用 RocketMQ 技术。因为大部分 MQ 的发送都
2023-08-18
白话3分钟，快速了解RocketMQ如何存储消息。 看完如果不了解，欢迎来打我。 我们知道RocketMQ主要分为消息 生产、存储、消费 三大块领域。 那接下来，我们白话一下，RocketMQ是如何存储消息的，揭秘消息存储全过程。 注意，如果白话中不小心提到相关代码配置与类名，请参考Rocket
2023-08-18
这里是weihubeats,觉得文章不错可以关注公众号小奏技术，文章首发。拒绝营销号，拒绝标题党 背景 最近在维护RocketMQ经常会出现这种问题 消息发送方和接收方出现扯皮，消息发送方说我的消息已经发送成功了，消费方说我没接收到消息。两边各持己见，谁也不会说服谁。这时候就非常希望RocketM
2023-08-15
我们知道RocketMQ主要分为消息 生产、存储（消息堆积）、消费 三大块领域。那接下来，我们白话一下，RocketMQ是如何存储消息的，揭秘消息存储全过程。注意，如果白话中不小心提到相关代码配置与类名，请参考RocketMQ 4.9.4版本关键字摘要存储模型与存储类型如何保证存储消息不丢失如何提高
2023-08-14
NameServer 是专为 RocketMQ 设计的轻量级名字服务，它的源码非常精简，八个类 ，少于1000行代码。图片这篇文章， 笔者会从基础概念、Broker发送心跳包、NameServer 维护路由、Zookeeper vs NameServer 四个模块揭秘名字服务的设计精髓。一、基础概念
2023-08-10
作者：隆基 01 消息场景 RocketMQ 5.0 是消息事件流一体的实时数据处理平台，是业务消息领域的事实标准，很多互联网公司在业务消息场景会使用 RocketMQ。 我们反复提到的“消息、业务消息”，指的是分布式应用解耦，是 RocketMQ 的业务基本盘。通过本文，我们将深入了解 Rock
2023-08-09
我们知道RocketMQ主要分为消息 生产、存储（消息堆积）、消费 三大块领域。那接下来，我们白话一下，RocketMQ是如何发送消息的，揭秘消息生产全过程。注意，如果白话中不小心提到相关代码配置与类名，请参考RocketMQ 4.9.4版本关键字摘要哪些消息类型？发给谁？怎么发？怎么知道发成功了还
2023-08-09
白话3分钟，快速了解RocketMQ如何发送消息。 看完如果不了解，欢迎来打我。 我们知道RocketMQ主要分为消息 生产、存储（消息堆积）、消费 三大块领域。 那接下来，我们白话一下，RocketMQ是如何发送消息的，揭秘消息生产全过程。 注意，如果白话中不小心提到相关代码配置与类名，请参考
2023-08-09
本文的宗旨在于通过简单干净实践的方式教会读者，使用 Docker 配置 RocketMQ 并在基于 DDD 分层结构的 SpringBoot 工程中使用 RocketMQ 技术。因为大部分 MQ 的发送都是基于特定业务场景的，所以本章节也是基于 《MyBatis 使用教程和插件开发》 章节的扩展。本
2023-08-05
在众多关于MQ的面试八股文中有这么一道题，“如何保证MQ消息消费的幂等性”。 为什么需要保证幂等性呢？是因为消息会重复消费。 为什么消息会重复消费？ 明明已经消费了，为什么消息会被再次被消费呢？ 不同的MQ产生的原因可能不一样 本文就以RocketMQ为例，来扒一扒RocketMQ中会导致消息重复消
2023-07-31
这里是weihubeats,觉得文章不错可以关注公众号小奏技术，文章首发。拒绝营销号，拒绝标题党 RocketMQ版本 5.1.0 背景 最近线上的RocketMQ集群遇到了如下问题，业务方的小伙伴反馈问题，说出现了 MQBrokerException：CODE:2DESC:[TIMEOUT_
2023-07-31
落花人独立, 微雨燕双飞 一、前言 上篇文档主要给大家介绍了下RocketMQ消费者相关内容，其中提到过消费者底层和Broker进行通信的时候，有两种模式，分别是同步消费和异步消费，不知道大家有没有过类似的疑问，netty底层本身是基于java nio的，按理说都是异步非阻塞的，那么RocketM
2023-07-25
白话3分钟，快速了解RocketMQ基础，包括适用场景，以及基本概念。 看完如果不了解，欢迎来打我。 关键字摘要 低延迟、高可用、高可靠、高并发 的消息中间件 适合在线业务 分为producer、consumer、nameserver、broker等角色 另外还有主题（Topic）、队列（Mes
2023-07-25
背景 可以在以下场景使用单体服务部署 私有化部署场景，客户只有一台服务器，却需要消息队列进行业务处理 运维人力有限，分布式集群无力维护 测试环境中只需单个Broker节点满足业务开发即可 部署过程 我们直接使用开源一键docker部署环境 hub.docker.com/r/xuchengen…
2023-07-25
白话3分钟，快速了解RocketMQ基础，包括适用场景，以及基本概念。看完如果不了解，欢迎来打我。关键字摘要低延迟、高可用、高可靠、高并发 的消息中间件适合在线业务分为producer、consumer、nameserver、broker等角色另外还有主题（Topic）、队列（MessageQueu
2023-07-25
1.引言 Hi，大家好，我是有清 缓存我们都知道，在我们日常的工作过程中一般都有使用，一般我们使用的都是堆内缓存，但是我一提到堆外缓存，想必 堆外缓存顾名思义，这部分数据是放在堆内存以外，因为堆外内存并不在 GC 的工作范围之内，所以可以有效的避免缓存过大对于 GC 的影响，听起来好像很棒的样子
2023-07-25
这里是weihubeats,觉得文章不错可以关注公众号小奏技术，文章首发。拒绝营销号，拒绝标题党 RocketMQ版本 5.1.0 入口 这里消息删除的源码入口其实不太好直接确定，我们可以通过启动broker的代码开始即BrokerStartup的main方法 这里我们直接进入到contro
2023-07-25
DefaultMQPushConsumer 使用系统控制读取操作的DefaultMQPushConsumer可以自动调用传入的处理方法来处理收到的消息。通过设置各种参数和传入处理消息的函数，使用DefaultMQPushConsumer的主要目的是方便配置和处理消息。在收到消息后，系统会自动保存Of
2023-07-24