在消费消息时,因为异常导致消费不成功的时候,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...