说说 MQ 之 RocketMQ ( 二 )

（点击上方公众号，可快速关注）来源：Valleylord ，valleylord.github.io/post/201607-mq-rocketmq/RocketMQ 的 Java APIRocketMQ 是用 Java 语言开发的，因此，其 Java API 相对是比较丰富的，当然也有部分原因是 RocketMQ 本身提供的功能就比较多。RocketMQ API 提供的功能包括，广播消费，这个在之前已经提到过；消息过滤，支持简单的 Message Tag 过滤，也支持按 Message Header、body 过滤；顺序消费和乱序消费，之前也提到过，这里的顺序消费应该指的是普通顺序性，这一点与 Kafka 相同；Pull 模式消费，这个是相对 Push 模式来说的，Kafka 就是 Pull 模式消费；事务消息，这个好像没有开源，但是 example 代码中有示例，总之，不推荐用；Tag，RocketMQ 在 Topic 下面又分了一层 Tag，用于表示消息类别，可以用 ………………………………