RocketMQ源码分析

最近事比较多, 因此很久没更新博客了. 这是我抽时间看了下RocketMQ的源码并进行了分析的一些心得.
相比于Kafka, RocketMQ在分布式部分做了简化, 但也增强了更多新的功能. 比如:
1. PushConsumer和PullConsumer(Kafka只有Pull Consumer, 但0.8之后的版本也支持长轮询, 性能和Push方式差不多)
2. 消费模式有集群模式和广播模式.广播模式可保证不同consumer,即便为同一consumerGroup,也可消费同一topic消息(Kafka中只能通过配置不同的consumerGroup来实现)
3. 严格顺序消息消费(Kafka也支持)
4. 事务消息(Kafka不支持)
5. 消息过滤. RocketMQ支持两种方式的消息过滤:通过Tag或通过自定义的com.alibaba.rocketmq.common.filter.MessageFilter实现类来实现消息在broker上的过滤(Kafka不支持)
6. 定时消息发送和定时拉取(Kafka不支持)
7. 消息按key进行检索.这个有时很有用,可用于判断消息是否存在. (Kafka不支持)
8. 消息同步和异步刷盘(FlushDiskType.SYNC_FLUSH和FlushDiskType.ASYNC_FLUSH),同步双写(BrokerRole.SYNC_MASTER),Kafka只有异步刷盘(其实也可以支持同步刷盘, 配置参数 log.flush.interval.messages=1 即可),没有同步双写功能(这个不能这么说, 可配置request.required.acks=-1来实现),slave是从master上不断异步拉取commitLog数据