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

在消费消息时,因为异常导致消费不成功的时候,RocketMQ默认会连续进行三次重试。 可以通过下面的代码测试一下: @StreamListener("input1")public void receiveInput1(@Payload Message message) throws ValidationException {    if (0 == count) {        //此处模拟的是...

RocketMQ – 事务消息

选择RocketMQ是因为它支持事务消息,它的事务消息实现过程如下: 1. 先发送一条半消息。 2. 处理业务逻辑。 3. 业务逻辑成功,则确认消息,这时候半消息会正式推送至消费者。业务逻辑失败,则回滚消息,这时候半消息会取消。 4. 因为异常情况,导致无法确认或者回滚时,利用回查接口轮询最终的业务处理结果,再确认或者回滚消息。 上面的过程都是我抄的,只不过边读边理解,然后用自己的话...

Spring Cloud Alibaba – 莫名其妙的异常

每一次对莫名其妙发生的异常刨根问底的时候,都是非常痛苦的经历,脑仁要炸掉的感觉。 本文基于: Spring Cloud Alibaba 2.2.0.Release Dubbo 最近吧,应用越来越多,规范也越来越重要,就想把Nacos的配置中心用起来。 去年已经进行过初步调研,这次算是再拾掇一下,感觉应该没什么难度。 开始在示例工程里面写例子的时候,还是相当轻松愉快的,但是想要替换一个工程落地测试一下...

Dubbo – Http协议实现Restful接口

每天开车望红灯,时间都被浪费在路上,无奈。 本章记录一下如何使用Http协议实现Restful接口,如果想了解Rest协议的实现,可以看这里:Dubbo - Rest协议实现Restful接口。 本示例基于: Spring Boot 2.2.5.RELEASE Spring Cloud vHoxton.SR3 Spring Cloud Alibaba 2.2.0.RELEASE provider的pom文件引入Jar包如下: <dependencies>    <!-- Spring...

Dubbo – Rest协议实现Restful接口

最近做了一些Dubbo的示例,在此记录一下。 本章记录一下使用Rest协议实现Http Restful接口。 本示例基于: Spring Boot 2.2.5.RELEASE Spring Cloud vHoxton.SR3 Spring Cloud Alibaba 2.2.0.RELEASE Netty 4.1.42.final Resteasy 3.11.0.Final provider的pom文件引入Jar包如下: <dependencies>    <!--单元测试-->...
Copyright © 字痕随行 保留所有权利.   Theme  Ality

用户登录

分享到: