I am Cat Slave.
-
RocketMQ In Action - Remoting
Remoting,RocketMQ的通信系统。RocketMQ使用Netty作为底层通信框架,自定义了NettyRemotingServer和NettyRemotingClient两个客户端实例以及NettyRemotingAbstract公共抽象类。
-
Linux Zero-Copy
Zero-Copy 零拷贝技术,就是避免CPU将数据从一块存储拷贝到另一块存储的技术,减少数据传输过程中发生的用户空间和内核空间的上下文切换带来的开销,从而有效地提高数据传输效率。
-
RocketMQ In Action - Broker
Broker 负责消息的存储和转发。将消息存储到文件中,根据消费者请求的消息类型,从文件中获取消息然后发送给消费者。
-
RocketMQ In Action - Consumer
消费者,消费消息。生产者将消息发送到Broker,Broker存储消息并将消息转发给消费者,消费者接收消息然后处理消息。消费者也可以订阅指定主题的消息,Broker收到该主题的消息后会主动将消息推送给已订阅的消费者。
-
RocketMQ In Action - Producer
消息的生产者,负责产生消息。通过Name Server获取到Topic信息,从Topic中选择一个消息队列进行消息发送。根据选择的消息队列,获取该消息队列的Broker地址,然后生产者与该Broker建立连接,将消息发送到Broker上。
-
RocketMQ In Action - NameServer
Name Server 主要负责管理集群的路由信息,包括Topic队列信息和Broker地址信息。客户端可以通过Name Server获取当前topic信息,通过topic获取broker信息,通过broker获取broker地址信息等等。