​HunterConsumer和HunterProducer组件主要是利用AOP思想实现，它使开发人员在编写业务逻辑时可以专心于核心业务，而不用过多的关注于一些非业务的重复代码，这不但提高了开发效率，而且增强了代码的可维护性。

本文将介绍基于RocketMQ建设消息中间件平台并实现在线业务无感知的平滑迁移。

本文主要介绍RocketMQ消费者的启动流程和消息消费过程。

近期在负责 RocketMQ 消息多副本和高可用能力的建设，和大家分享下一些有趣的想法。

在公司使用RocketMQ的时候发现事务消息不是社区版的,而是自研版本。

这就引发了强烈的好奇,为什么要自己研发一套呢? 和社区版的又有什么不同呢?

随着公司业务的快速发展，业务部门为了满足自己业务场景需求自己搭建RocketMQ集群，没有做MQ消息中间件集群做统一规划，导致现有公司线上存在多套集群。然而随着业务的增长，虽然多套集群能够起到业务间消息、流量隔离、各个业务间相互不影响。

RocketMQ作为一款流行的消息中间件在各大互联网应用广泛，本文主要分析RocketMq在消息生产和消费过程中的负载均衡机制，并创新提出消费端负载均衡策略的改写以实现固定IP消费的可能。

本文通过Queue来隔离灰度与非灰度消息，最终实现MQ全链路灰度流量的无损切换。

RocketMQ作为公司消息中间件在各个业务广泛使用，用于公司的各个业务场景各个业。公司MQ集群已经支撑业务正常使用了很长一段时间，然而最近公司招采业务在发送MQ消息时出现了频繁超时导致业务事务回滚，严重影响了业务的使用。需要尽快解决MQ超时问题。

消息队列是一种服务间异步通信方式，广泛应用于微服务架构设计中的解耦、异步、削峰等场景。消息在被处理和删除之前一直存储在队列上。本文主要从源码角度讲述 RocketMQ 存储模块如何设计。

本文基于NameServer的源码来深入剖析NameServer的实现原理以及其中的一些编程技巧。

消息队列是分布式系统中重要中间件，目前比较常见的产品有ActiveMQ，RabbitMQ，ZeroMQ，Kafka，RocketMQ，NSQ等。本文将其中对三款优秀消息中间件（nsq,kafka,rocketMq）的实现架构进行简单介绍～

本文主要做了RocketMQ4.8版本的源码主流程分析。

从消息的产生到最终消费。

RocketMQ是一个高可用、高性能、高可靠的分布式消息队列，相对于kafka更适合处理业务系统之间的消息。

分布式事务之事务消息，到底如何实现呢？