欢迎关注头条号：老顾聊技术精品原创技术分享，知识的组装工目录前言自定义Binding声明接口发布与消费自定义MessageConverter异常处理重试机制定制消费者线程数边接收边发送RocketMq的Tag特性RocketMq广播方式总结前言之前老顾介绍了基本的实战知识点，今天老顾介绍一下深入的知识点。自定义Binding声明接口除了使用Spring Cl …
docker rocketmq
消息存储Broker收到消息后会调用CommitLog的asyncPutMessage方法写入消息，在DLedger模式下使用的是DLedgerCommitLog，进入asyncPutMessages方法，主要处理逻辑如下：调用serialize方法将消息数据序列化；构建批量消息追加请求BatchAppendEntryRequest，并设置上一步序列化的消息 …
什么是可靠消息最终一致性可靠消息最终一致性方案是指当事务发起方执行完成本地事务后并发出一条消息，事务参与方(消息消费者)一定能够接收消息并处理事务成功，此方案强调的是只要消息发给事务参与方最终事务要达到一致。此方案是利用消息中间件完成，如下图：事务发起方（消息生产方）将消息发给消息中间件，事务参与方从消息中间件接收消息，事务发起方和消息中间件之间，事务参与方 …
网上博客常说，kafka的topic数量过多会影响kafka，而RocketMQ不会受到topic数量影响。但是，果真如此吗？最近排查一个问题，发现RocketMQ稳定性同样受到topic数量影响！！好了，一起来回顾下这次问题排查吧，最佳实践和引申思考放在最后，千万不要错过。1、问题描述我们的RocketMQ集群为4.6.0版本，按照3个nameserver …
在怀疑是系统（服务器）问题前，先多考虑是否是程序本身的问题大过年在家里，正玩王者，突然收到带的新人徒弟发来的微信消息，说线上mq数据统计错乱了，有的多，有的少，说可能RocketMq集群有问题。影响到了用户报表，十分紧急，无奈之下，只能坑队友一把（挂机），连上easyConnect，帮徒弟定位问题。 刚上线，就看到徒弟已经拉了一个群，里面拉了运维同事，让运 …
众所周知RocketMQ消息队列一直是由阿里云作为此技术的天花板，消息队列RocketMQ版（原名开放消息服务，简称ONS）是阿里云基于Apache RocketMQ构建的低延迟、高并发、高可用、高可靠的分布式消息中间件。今天小编就给大家分享一份号称是阿里云大佬分享的《RocketMQ分布式消息中间件手册》希望能对正在学习这个技术的小伙伴有到帮助!Rock …
目录RocketMQ介绍RocketMQ概念为什么要用RocketMQ？异步解耦削峰填谷分布式事务最终一致性数据分发RocketMQ架构RocketMQ消息类型普通消息顺序消息定时消息事务消息最佳实践消息重试消息过滤消费模式消费幂等本地事务消息封装参考代码RocketMQ 介绍Apache RocketMQ 是一款 低延迟、高并发、高可用、高可靠的分布式消息 …
作者：君哥聊技术来源：https:mp.weixin.qq.comsn9QlZ73SQyCGIyPLvHMy0A大家好，我是君哥。今天聊一聊 RocketMQ 的顺序消息实现机制。在有些场景下，使用 MQ 需要保证消息的顺序性，比如在电商系统中，用户提交订单、支付订单、订单出库这 3 个消息应该保证顺序性，如下图：对于 RocketMQ 来说，主要是通过 P …
一 RocketMQ基础1.1 介绍MQ是一种提供消息队列服务的中间件，也称为消息中间件，是一套提供了消息生产、存储、消费全过程API的软件系统。RocketMQ是使用Java语言开发的一款MQ产品，经过数年阿里双11的考验，性能与稳定性非常高，其没有遵循任何常见的MQ协议，而是使用自研协议。1.2 官网地址https:rocketmq.apache.org …
今天我们来讨论如何在项目开发中优雅地使用RocketMQ。本文分为三部分，第一部分实现SpringBoot与RocketMQ的整合，第二部分解决在使用RocketMQ过程中可能遇到的一些问题并解决他们，第三部分介绍如何封装RocketMQ以便更好地使用。1. SpringBoot整合RocketMQ在SpringBoot中集成RocketMQ，只需要简单四步 …