在消费消息时，因为异常导致消费不成功的时候，RocketMQ默认会连续进行三次重试。
可以通过下面的代码测试一下：
@StreamListener("input1")public void receiveInput1(@Payload Message message) throws ValidationException { if (0 == count) { //此处模拟的是...
RocketMQ – 事务消息
选择RocketMQ是因为它支持事务消息，它的事务消息实现过程如下：
1. 先发送一条半消息。
2. 处理业务逻辑。
3. 业务逻辑成功，则确认消息，这时候半消息会正式推送至消费者。业务逻辑失败，则回滚消息，这时候半消息会取消。
4. 因为异常情况，导致无法确认或者回滚时，利用回查接口轮询最终的业务处理结果，再确认或者回滚消息。
上面的过程都是我抄的，只不过边读边理解，然后用自己的话...
RocketMQ – 与Spring Cloud Stream结合
最近在加班，五一看了一遍《钢之炼金术师》，空闲时间又对Netty产生了兴趣，还得陪闺女，然后TBC怀旧又要蹭一波热度去，所以时间不够用，更新十分缓慢。
我在学习RocketMQ怎么和Spring Cloud结合的时候，首先被下面这个问题困扰：
Spring Cloud Bus和Spring Cloud Stream有什么不同？应用的场景都是什么样的？
后来吧，我得出了一个非常简单的结论，无论什么场景都用Spring Cloud Stream就完事了...
RocketMQ – 入门
最近鼓捣了几个小玩意：
RocketMQCASJWT
有空就记录一下，顺便再梳理一下思路，以后看自己写的东西也比看别人的易于理解。
如何下载？
RocketMQ的下载地址如下：
http://rocketmq.apache.org/dowloading/releases/
RocketMQ对于JDK版本的要求还是挺清晰的：
这里测试的话，我没有下载源码进行编译，以后想看源码的话再说。直接下载的是rocketmq-all-4.8.0-bin-release.zip。
...