分布式消息中间件系列 消息中间件

分布式消息中间件系列

从本专栏开始,我将详细讲解分布式系统中常用的一种组件——消息中间件。目前工业环境常用的消息中间件主要有ActiveMQ、RabbitMQ、Kafka、RocketMQ。这四种消息中间件的优劣和使用场景,我会在专栏中进行对比,读者也可以先参照我的另一个专栏《分布式系统从理论到实战系列》对消息中间件的核心要点进行了解。
阅读全文

RocketMQ源码分析(四)——Broker注册原理

对于Broker来说,注册流程的核心点就是基于底层的Netty API与NameServer建立Channel,然后发送注册请求;对于NameServer来说,也是基于内部的NettyServer服务器先接受请求,然后将请求转交给请求处理器组件处理,而请求处理器组件则是根据不同的请求类。
阅读全文

RocketMQ源码分析(二)——NameServer启动流程

在RocketMQ使用的时候,第一个步骤一定是先启动NameServer,那么我们就先来分析NameServer启动这块的源码。它最核心的就是基于Netty实现了一个网络服务器,然后监听默认的9876端口,这样就可以接收Broker和客户端的网络请求了。
阅读全文

分布式消息中间件(十二)——RocketMQ顺序消息

在RocketMQ中,提供了一种顺序消息类型。所谓顺序消息(FIFO 消息),是一种严格按照顺序来发布和消费的消息。顺序发布和顺序消费是指对于指定的一个Topic:生产者按照一定的先后顺序发布消息;消费者按照既定的先后顺序订阅消息,即先发布的消息一定会先被客户端接收到。
阅读全文
本文目录
    Loading...