在消费消息时，因为异常导致消费不成功的时候，RocketMQ默认会连续进行三次重试。
可以通过下面的代码测试一下：
@StreamListener("input1")public void receiveInput1(@Payload Message message) throws ValidationException { if (0 == count) { //此处模拟的是...
RocketMQ – 与Spring Cloud Stream结合
最近在加班，五一看了一遍《钢之炼金术师》，空闲时间又对Netty产生了兴趣，还得陪闺女，然后TBC怀旧又要蹭一波热度去，所以时间不够用，更新十分缓慢。
我在学习RocketMQ怎么和Spring Cloud结合的时候，首先被下面这个问题困扰：
Spring Cloud Bus和Spring Cloud Stream有什么不同？应用的场景都是什么样的？
后来吧，我得出了一个非常简单的结论，无论什么场景都用Spring Cloud Stream就完事了...
Spring Cloud Gateway
Spring Cloud Gateway早就被玩烂了，所以这篇也不是什么教程，顶多算是个人总结/记录而已。
由来是因为要用Swagger，但是面向服务的系统，如果只是单独的集成Swagger就显得很混乱，所以需要Knife4j的分布式文档支持。
从我的理解上来讲，Gateway的作用就如同Nginx，是一个独立的服务，用来将所有的请求进行过滤、转发。从目前我使用的情况来看，它与其它服务是解耦的，无侵入的。
新建一个Spring...