RocketMQ – 消费者异常处理和图形化监控

在消费消息时,因为异常导致消费不成功的时候,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...
Copyright © 字痕随行 保留所有权利.   Theme  Ality

用户登录

分享到: