本文共 1251 字，大约阅读时间需要 4 分钟。

rocketmq服务组成:

1.nameserver broker 注册等,多节点 2.broker 消息接收和分发,持久化等,多节点,主从模式保证可用性;模式同步master和异步master,在同步master情况下,slave节点保存成功后,给客户端返回成功.硬盘刷新方式有同步刷新和异步刷新,在同步刷新模式下,当消息写入硬盘后,返回成功. 3.producer 生产者: 3.1 同步发送模式 send 3.2 异步发送模式 sendcallback 3.3 带队列选择的同步/异步发送 select 3.4 one-way方式发送,可用于log-collection等 4.消费者 4.1 push型消费,长pull实现,基于线程池,可配置批量消费,默认批量值1 4.2 pull主动拉取消费,客户端编码较复杂 监听器: 4.3 并发监听消费消息 4.4 顺序监听消息消费,保证每队列消息消费顺序型

hook:跟拦截器功能类似

rpchook:再netty发送消息时实现拦截

public interface RPCHook {    public void doBeforeRequest(final String remoteAddr, final RemotingCommand request);    public void doAfterResponse(final String remoteAddr, final RemotingCommand request,            final RemotingCommand response);}

发送消息拦截可实现统一处理:

public interface SendMessageHook {    String hookName();    void sendMessageBefore(final SendMessageContext context);    void sendMessageAfter(final SendMessageContext context);}

消费消息拦截:

public interface ConsumeMessageHook {    String hookName();    void consumeMessageBefore(final ConsumeMessageContext context);    void consumeMessageAfter(final ConsumeMessageContext context);}

消息过滤:

public interface FilterMessageHook {    public String hookName();    public void filterMessage(final FilterMessageContext context);}

此外,同步异步发送消息都是基于netty进行的实现.

转载地址：http://qbuti.baihongyu.com/