RocketMQ官微

01—消息幂等性消息中间件是分布式系统常用的组件，无论是异步化、解耦、削峰等都有广泛的应用价值。我们通常会认为，消息中间件是一个可靠的组件——这里所谓的可靠是指，只要我把消息成功投递到了消息中间件，消息就不会丢失，即消息肯定会至少保证消息能被消费者成功消费一次，这是消息中间件最基本的特性之一，也就是我们常说的“AT LEAST ONCE”，即消息至少会被“成功消费一遍”。举个例子，一个消息M发送到了消息中间件，消息投递到了消费程序A，A接受到了消息，然后进行消费，但在消费到一半的时候程序重启了，这时候这个消...

“本文为RIP-14 RocketMQ Community Operation Conventions中文版，也是RocketMQ 社区行为规约2.0。希望能通过该规约，进一步规范Contributor、Committer行为，使社区和项目健康发展。欢迎在本文下留言表达你对该RIP的看法，你也可以回复下面的邮件进行讨论或者直接在Google文档上评论来表达你的观点。”

经过近一个多月的迭代，万众期待的Apach RocketMQ 4.7.0 版终于发布啦！该版本不仅对原有的功能进行了增强，修复了多个bug。此外对原有的同步双写进行全新升级，极大地提升同步双写的性能。同步双写极致性能优化。SendMessageProcessor线程不再等待消息复制到Slave节点后再处理新请求，而是提前生成CompletableFuture并返回，并马上处理新的请求。而HAService中的线程在Slave的复制位点超过消息的写入位点后去完成对应的CompletableFuture，并通知remoting模块响应客户端。其中来自ByteDance的同学对此次同步双写性能优化做了重要贡献，并已经在生产使用。非常期待更多的用户、厂商参与到RocketMQ建设中来，共同打造新一代云原生消息数据处理平台。

本文将分享微众银行基于RocketMQ构建消息服务平台的实践，并通过添加诸多高级特性来解决消息收发过程中遇到的各种问题，通过此文，您将了解到：金融行业服务架构的演进历程微众银行的消息服务架构基于RocketMQ定制的消息高级特性银行应用架构的演进历史不管是银行的系统还是其他一些传统企业的系统，他们在最早的时候都使用到了服务总线，即ESB或者某种形式存在于SOA架构中，目的是把所有的服务都串起来，让服务之间能够形成一个调用。消息存活期当对消息的有效期有要求时，可以在消费消息时对存活时间进行判断，超时则丢弃。

信用算力自2016年开始实施微服务改造，通过消息队列，后文简称MQ，来规避微服务存在的缺陷，实现金融级数据服务。为解决此类重度依赖的问题，我们在架构层面引入了 MQ，用来规避微服务之间重度耦合调用的弊端。因为金融行业对于数据一致性以及服务可用性的要求非常高，所以任何关于技术的选项都显得尤为重要。MQ 在微服务下的使用场景MQ是一种跨进程的通信机制，用于上下游传递消息，目前信用算力将RocketMQ 应用于解耦、流量削峰、分布式事务的处理等几个场景。消息中心接收到消息后会全部写入不同 topic的 MQ，多个消费者来消费并把信息推送给终端用户。

沈辉是今日头条的架构师，主要负责 RocketMQ 在头条的落地以及架构设计，参与消息系统的时间大概一年左右。为什么选择 RocketMQ这是一个经过阿里巴巴多年双11验证过的、可以支持亿级并发的开源消息队列，是值得信任的。综合以上特性最终选择了 RocketMQ 。以上是我们通过 Proxy 接口给 RocketMQ 带来的好处。

2019年，Apache RocketMQ开源生态得到了进一步的壮大和发展。近期Apache RocketMQ也荣膺2019年中国最受欢迎开源软件。为了表彰社区优秀的贡献者，同时鼓励更多的开源爱好者参与Apache RocketMQ项目，社区计划启动Apache RocketMQ中国社区优秀贡献者评选活动。奖项设置优秀贡献者：主要针对在Apache RocketMQ 项目做出杰出贡献的开发者，可能是RocketMQ某个模块的主导者或者核心代码贡献者。D 优秀应用案例：将Apache RocketMQ应用到企业线上的技术团队。

本次会为大家介绍 Apache RocketMQ 项目的历史发展、企业应用情况以及目前社区孵化的生态项目与最新进展。Apache IoTDB项目的初始源码提交者之一。

日志处理RocketMQ 的设计模式借鉴于 Kafka，且后者经常用于日志管理系统充当数据缓冲的角色。但Kafka 过度依赖ZooKeeper，而 RockerMQ 则可实现无 ZooKeeper 部署，简化安装部署工作，所以，在联想大数据业务线和解决方案中，将RocketMQ 应用于日志处理业务，逐渐增加RocketMQ的使用率。而 RocketMQ 可实现不依赖 ZooKeeper的部署，大大降低使用门槛和学习成本。因为8080端口一般为Web应用使用端口，但当启动 RocketMQ 后，发现此端口被占用，导致某个Web应用程序不能正常启动。所以，我们在使用过程中，基于源码进行了二次开发，并在 RocketMQ 的配置文件中增加了对此端口的动态配置项。

经过近四个月的迭代，万众期待的Apach RocketMQ V4.6.0版终于发布啦！全面支持IPV6据悉，Apache RocketMQ是现代云原生架构消息引擎首次全面拥抱IPv6。目前来看，IPv6已经成为可穿戴设备、智慧城市、工业互联网等万物联网爆发的前提条件，对IPv6的支持更大的意义是可以支撑更多创新应用，更好的支持物联网、车联网、人工智能等新场景、新产业的发展，加速推进Apache RocketMQ成为下一代数据处理基础设施。LitePullConsumer提供了更多接收消息的选择，用户能更加自由地控制消息拉取，使Apache RocketMQ更好地应用于大数据、流计算领域。近段时间，蚂蚁消息团队也积极活跃在RocketMQ 社区。点击阅读原文下载Apache RocketMQ V4.6.0试用

为什么 RocketMQ 是企业服务总线的最佳技术方案之一？因此，ServiceMesh 只是 一个微服务架构实施的临时方案。为什么 RocketMQ 是企业服务总线的最佳技术方案之一在 SOA 架构发展的三个阶段，我们提到了 ESB 的优势和缺点，对于 ESB 当时采用的消息中间件过重、性能差等技术问题，随着开源技术的不断发展和进步，这些问题得到有效解决，目前开源技术中消息中间件大概有

本文整理自李样兵在北京站 RocketMQ meetup分享美菜网使用 RocketMQ 过程中的一些心得和经验，偏重于实践。左边是 Producer ，业务通过 Http 连接 NSQ ，对于生产者，实现一个 http 网关，来接收业务生产消息转发到 RocketMQ 。

通过 Jepsen 测试，能发现分布式系统在极端故障下的隐藏错误，从而提高分布式系统的容错能力。因此 Jepsen 测试被应用到许多分布式数据库或分布式协调服务集群的可靠性检测中，成为验证分布式系统一致性验证的重要手段。而现在我们以基于日志的分布式存储库 DLedger 和分布式消息队列 RocketMQ 为例，介绍 Jepsen 测试在分布式消息系统中的应用。DLedger 的 Jepsen 测试DLedger 是一个基于 raft 的 java 库，用于构建高可用性、高持久性、强一致性的 commitlog 。因此采用 Jepsen 的 Set 测试对 DLedger 在各种故障下的一致性进行检测。

产品岗位需求：技术岗位需求：职位描述1、负责云原生分布式消息引擎整体架构设计、核心功能开发以及架构演进等工作。

本文整理自海尔的姚翔在2019年10月26日Apache RocketMQ开发者沙龙西安站的分享。从图中可以看出，RocktMQ相对RabbitMQ，特性更多，体量和性能也更好。后面再针对Kafka和RocketMQ进行一些对比。rocketmq是目前支持比较丰富的。对于消费者，DefaultRocketMQListenerContainer 为默认的容器，默认使用DefaultMQPushConsumer。kafka消息平台为数据源，有大量的设备绑定和解绑消息。keepalive中有保存用户和session的对应关系。目前在海尔智家主要负责系统的 MQ 及微服务的落地及演进相关的技术平台。

邱博文Apache RocketMQ西安社区联合发起人 & 兆日科技技术主管Apache RocketMQ在海尔智家的应用实践海尔智家资深工程师分享从海尔自身业务特点出发，到消息中间件的选型及实践两个方面介绍RocketMQ在海尔的落地。姚翔Apache RocketMQ西安社区联合发起人 &海尔智家资深工程师MeetWith Apache RocketMQ Committers活动最后社区的Committer和现场开发者进行了互动在场小伙伴针对在RocketMQ使用中出现的问题积极地提问，两位分享者也逐一回答了现场提出的问题。

接着，由Apache RocketMQ PMC Member & Committer杜恒分享了本次活动的第二个主题《RocketMQ 高可用存储演进之路》。第三个主题是由 Apache RocketMQ 西安社区联合发起人& Contributor 孙文博分享的，题目是《基于 RocketMQ 的全新数据流转处理平台-RocetMQ Connect揭秘》。休息过后，由Apache RocketMQ西安社区联合发起人邱博文分享了当天的第四个主题，《Apache RocketMQ在即时通讯的应用实践》。Apache RocketMQ西安社区联合发起人邱博文邱博文的分享结合IM自身业务的特点，从消息中间件的选型及实践两个方面介绍RocketMQ是如何在企业落地。

本次会为大家介绍 RocketMQ 近期开源的New Features，会介绍事务消息、消息轨迹、多语言客户端、多副本存储等RocketMQ新特性的基本原理、支撑的业务场景及目前在企业的应用情况。最后会介绍RocketMQ社区目前的发展情况。RocketMQ Contributor，有多年微服务、分布式系统开发经验。

Alibaba Dragonwell 静态编译实践极速启动：Meta 节点应用 Serverless 化从 Java 程序角度看，经过静态编译后 Java 程序具有更快的启动速度、更低的内存占用、更小的发布体积，在云上部署时从服务拉起到响应用户的请求所需的时间更短，非常适合云原生的需求。静态编译的挑战和 Alibaba Dragonwell 的应对然而世界上没有银弹，静态编译技术也不例外。阿里巴巴正在结合自己的业务场景与 SVM 开源社区紧密合作，以 Alibaba Dragonwell 和 SVM 为基础，积极探索如何缩小静态编译和传统 Java 之间的鸿沟。阿里巴巴对 Alibaba Dragonwell 进行静态

Connect实际上是实现了OpenMessaging规范在Connect领域的一个标准，其他的消息中间件只需要实现相应的接口就会具有Connect的能力。OpenMessaging Connect和RocketMQ的关系：RocketMQ Connect是OpenMessaging Connect的一个实现，2、 OpenMessaging Connect架构从整体架构上来说，OpenMessaging Connect包含了三个重要的领域模型：Connect Model， Worker Model以及Runtime Model，分别抽象了数据解析梳理，服务运行以及服务调度等具体逻辑。