springboot +aop使用guavaretryer 的重试机制

简介: 1. 最近在公司在进行rpc 调用的时候,对方的服务不太稳定. 需求就是要间隔多长时间,多少次来重试。达到最大值之后就不在重试。
  1. 最近在公司在进行rpc 调用的时候,对方的服务不太稳定. 需求就是要间隔多长时间,多少次来重试。达到最大值之后就不在重试。
  2. 看了好多的资料,发现了一个开源的guavaretryer, 比较简单对用户非常的友好。
  3. 我们先新建一个springboot的项目,要引入guava-retry 的包,它会自动引入guava的包。


我们将其打开,看一下Retryer这个类


这里面是它的一些参数,具体的意思看注释就行了。
我们主要看一下call 方法


这里也就是表明返回的是两种值,一个是你自己自定义callable 返回 的值,一个是Throwable 的值。
下面还有一个监听器。


在下面就是在尝试,可以尝试就返回结果。不能尝试就走下面的是否应该停止,要是可以停止的话,就抛出retry 异常,
不可以的话就阻塞,就是组织结束尝试,要是保错的话,会对当前进程进行中断。

4,下面我们写一个自定义的注解加上aop 来 实现这个功能,
先写一个自定义注解

在写一个aop


这里retryer使用的是构建者模式,第一个的意思是如果返回值是null, 我们上面的cell()满足。 如果报错了返回值是null , 下面是异常类型,在注解里面声明了。在下面是否是运行是的异常。 下面就是重试的时间间隔和单位, 下面就是多少次之后就停止重试。

5 我们在写一个接口测试一下


先测试一下正常情况


没问题, 在测试一下异常情况,把刚才的注释放开
看一下控制台和浏览器


就是我们注解默认的重试三次,间隔三秒。这种异常的堆栈信息我是打印出来,其实可以用全局异常拦截的,在入库。
好了。
喜欢就点赞啊。

相关文章
|
1月前
|
SQL 监控 Java
在IDEA 、springboot中使用切面aop实现日志信息的记录到数据库
这篇文章介绍了如何在IDEA和Spring Boot中使用AOP技术实现日志信息的记录到数据库的详细步骤和代码示例。
在IDEA 、springboot中使用切面aop实现日志信息的记录到数据库
|
2月前
|
Java Spring
在Spring Boot中使用AOP实现日志切面
在Spring Boot中使用AOP实现日志切面
|
1月前
|
Java Spring 容器
SpringBoot整合AOP实现打印方法执行时间切面
SpringBoot整合AOP实现打印方法执行时间切面
30 1
|
1月前
|
Java 数据库 开发者
深入剖析 SpringBoot 的 SPI 机制
【8月更文挑战第10天】在软件开发中,SPI(Service Provider Interface)机制是一种重要的服务发现和加载机制,尤其在构建模块化、可扩展的系统时尤为重要。SpringBoot作为Spring家族的一员,其内置的SPI机制不仅继承了Java SPI的设计思想,还进行了优化和扩展,以适应Spring Boot特有的需求。本文将深入剖析SpringBoot中的SPI机制,揭示其背后的原理与应用。
56 7
|
1月前
|
Java 开发者 Spring
"揭秘SpringBoot魔法SPI机制:一键解锁服务扩展新姿势,让你的应用灵活飞天!"
【8月更文挑战第11天】SPI(Service Provider Interface)是Java的服务提供发现机制,用于运行时动态查找和加载服务实现。SpringBoot在其基础上进行了封装和优化,通过`spring.factories`文件提供更集中的配置方式,便于框架扩展和组件替换。本文通过定义接口`HelloService`及其实现类`HelloServiceImpl`,并在`spring.factories`中配置,结合`SpringFactoriesLoader`加载服务,展示了SpringBoot SPI机制的工作流程和优势。
39 5
|
1月前
|
Java API Spring
Spring Boot 中的 AOP 处理
对 Spring Boot 中的切面 AOP 做了详细的讲解,主要介绍了 Spring Boot 中 AOP 的引入,常用注解的使用,参数的使用,以及常用 api 的介绍。AOP 在实际项目中很有用,对切面方法执行前后都可以根据具体的业务,做相应的预处理或者增强处理,同时也可以用作异常捕获处理,可以根据具体业务场景,合理去使用 AOP。
|
20天前
|
安全 Java UED
掌握SpringBoot单点登录精髓,单点登录是一种身份认证机制
【8月更文挑战第31天】单点登录(Single Sign-On,简称SSO)是一种身份认证机制,它允许用户只需在多个相互信任的应用系统中登录一次,即可访问所有系统,而无需重复输入用户名和密码。在微服务架构日益盛行的今天,SSO成为提升用户体验和系统安全性的重要手段。本文将详细介绍如何在SpringBoot中实现SSO,并附上示例代码。
37 0
|
23天前
|
消息中间件 Java Kafka
深入SpringBoot的心脏地带:掌握其核心机制的全方位指南
【8月更文挑战第29天】这段内容介绍了在分布式系统中起到异步通信与解耦作用的消息队列,并详细探讨了三种流行的消息队列产品:RabbitMQ、RocketMQ 和 Kafka。RabbitMQ 是一个基于 AMQP 协议的开源消息队列系统,支持多种消息模型,具有高可靠性及稳定性;RocketMQ 则是由阿里巴巴开源的高性能分布式消息队列,支持事务消息等多种特性;而 Kafka 是 LinkedIn 开源的分布式流处理平台,以其高吞吐量和良好的可扩展性著称。文中还提供了使用这三种消息队列产品的示例代码。总之,这三款产品各有优势,适用于不同场景。
9 0
|
23天前
|
消息中间件 Java Kafka
SpringBoot大揭秘:如何轻松掌握其核心机制?
【8月更文挑战第29天】这段内容介绍了在分布式系统中起到异步通信与解耦作用的消息队列,并详细探讨了三种流行的消息队列产品:RabbitMQ、RocketMQ 和 Kafka。RabbitMQ 是一个基于 AMQP 协议的开源消息队列系统,支持多种消息模型,具有高可靠性及稳定性;RocketMQ 则是由阿里巴巴开源的高性能分布式消息队列,支持事务消息等多种特性;而 Kafka 是 LinkedIn 开源的分布式流处理平台,以其高吞吐量和良好的可扩展性著称。文中还提供了使用这三种消息队列产品的示例代码。
11 0
WXM
|
1月前
|
存储 缓存 Java