RocketMQ路由注册与删除是通过Broker与NameServer的心跳功能实现的。Broker启动时向集群中所有的NameServer发送心跳语句，每隔30s向集群中所有NameServer发送心跳包，NameServer收到Broker心跳包时会更新brokerLiveTable中的lastUpdateTimestamp，然后NameServer每隔10s扫描brokerLiveTable,如果连续120s没有收到心跳包…

微信公众号「后端进阶」，专注后端技术分享：Java、Golang、WEB框架、分布式中间件、服务治理等等。

NameServer是整个RocketMQ的“大脑”,提供动态路由发现与剔除机制。其启动过程中最核心的就是：开启Netty的服务端，并注册请求处理器来处理Broker连上后的请求；开启定时任务，每隔10s扫描一次Broker，移除处于不激活状态的Broker。

RocketMQ是一款分布式消息中间件，其设计基于主题的发布与订阅模式。功能包括消息发送、消息存储、消息消费，参与的基本组件主要包括：消息发送者、消息服务器、消息消费、路由发现，分别对应RocketMQ集群中包含的4个模块： Producer、Broker、Consumer，Namesrv。

作为一位刚进公司的小白，参与到项目的第一个任务是为操作记录的存储增加消息队列，为什么我们要这么做呢？原因如下：在现有系统中我们直接将用户的操作记录增加到mongodb数据库中，但是在我们的系统出现峰值的时候，发现mongodb受不了，为此我们要做到削峰这个功能，按照惯例我们想到了使用消息队列，同时由于我们在项…

微信公众号「后端进阶」，专注后端技术分享：Java、Golang、WEB框架、分布式中间件、服务治理等等。

在 Knative 中已经提供了对 Kafka 事件源的支持，那么如何在阿里云上基于 Kafka 实现消息推送，本文给大家解锁这一新的姿势。

在高并发业务场景下，消息队列在流量削峰、解耦上有不可替代的作用。当前使用较多的消息队列有 RabbitMQ、RocketMQ、ActiveMQ、Kafka、ZeroMQ、Pulsar 等。

最近闲来无事，down了RocketMQ 4.5.2的源码学习一下，ok,进入主题 consumer.start()对应的调用如下图所示： 由上图可知，在DefaultMQPushConsumer.start()中 调用 MQClientInstance的构造方法，递归调用PullMessa…

一般认为，消息中间件属于分布式系统中一个子系统，关注于数据的发送和接收，利用高效可靠的异步消息传递机制对分布式系统中的其余各个子系统进行集成。