rocketmq 消息队列

rocketmq(https://github.com/apache/rocketmq)是一个分布式的消息队列，主要有product, broker,consumer,nameserver组成，提供流量的削峰填谷，异步通知，应用解耦的功能。
这里主要讲三个问题：

1. 顺序消息
   在发送端可以在调用send方法的时候指定messagequeue, 可以利用key hash的方式，保证相同的key落在同一个messagequeue, 如果要保证全局唯一，整个topic可以只有一个messagequeu。在消费端，rocketmq提供了顺序消费的方法。以上只是在理想情况下唯一，网络抖动，broker切换都有可能导致消息不是顺序，使用时需要注意。
2. 事物消息
   实现方式类似于2pc
   1. product发送half消息到broker
   2. product根据broker返回的结果，成功或者失败，决定是否执行本地事物。
   3. 如果执行本地事物，根据本地事物结果，决定向broker发送commit或者rollback。 
   4. 如果第二步返回，或者第三步提交commit/rollback出现网络问题，broker会回查product, product根据回查决定是否重新提交。 
3. 消费失败问题
   rocketmq通过提交offset的方式，表示小于此offset的都已消费。 对于消费失败的消息，会提交到重试队列，重试队列在重试16次后，如果还失败，会投递到死信队列。 

具体可以参考我的注解版：
https://github.com/zhaoyb/rocketmq

rocketmq 消息队列

原文：https://www.cnblogs.com/beyondbit/p/13941881.html