欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

Java?遠程調用失敗重試的操作方法

 更新時間:2022年09月15日 09:26:50   作者:鴨血粉絲Tang  
這篇文章主要介紹了Java?遠程調用失敗重試的操作方法,今天給大家介紹了一下?Spring??的?@Retryable?注解使用,并通過幾個 demo 來帶大家編寫了自己重試攔截器以及回滾方法,需要的朋友可以參考下

在日常開發(fā)的過程中我們經常會需要調用第三方組件或者數據庫,有的時候可能會因為網絡抖動或者下游服務抖動,導致我們某次查詢失敗。

這種時候我們往往就會進行重試,當重試幾次后依舊還是失敗的話才會向上拋出異常進行失敗。接下來阿粉就給大家演示一下通常是如何做的,以及如何更優(yōu)雅的進行重試。

常規(guī)做法

我們先來看一下常規(guī)做法,常規(guī)做法首先會設置一個重試次數,然后通過 while 循環(huán)的方式進行遍歷,當循環(huán)次數沒有達到重試次數的時候,直到有正確結果后就返回,如果重試依舊失敗則會進行睡眠一段時間,再次重試,直到正常返回或者達到重試次數返回。

package com.example.demo.service;

import org.springframework.retry.annotation.Backoff;
import org.springframework.retry.annotation.Retryable;
import org.springframework.stereotype.Service;

import java.util.Random;
import java.util.concurrent.TimeUnit;

@Service
public class HelloService {
  public String sayHello(String name) {
    String result = "";
    int retryTime = 3;
    while (retryTime > 0) {
      try {
        //
        result = name + doSomething();
        return result;
      } catch (Exception e) {
        System.out.println("send message failed. try again in 1's");
        retryTime--;
        try {
          TimeUnit.SECONDS.sleep(1);
        } catch (InterruptedException ex) {
          throw new RuntimeException(ex);
        }
      }
    }
    return result;
  }

  private int doSomething() {
    Random random = new Random();
    int i = random.nextInt(3);
    System.out.println("i is " + i);
    return 10 / i;
  }
}

這里為了模擬異常的情況,阿粉在 doSomething? 函數里面進行了隨機數的生成和使用,當隨機出來的值為 0 的時候,則會觸發(fā) java.lang.ArithmeticException 異常,因為 0 不能作除數。

接下來我們再對外提供一個接口用于訪問,代碼如下

package com.example.demo.controller;

import com.example.demo.service.HelloService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class HelloController {

  @Autowired
  private HelloService helloService;

  @GetMapping(value = "/hello")
  public String hello(@RequestParam("name") String name) {
    return helloService.sayHello(name);
  }
}

正常啟動過后,我們通過瀏覽器進行訪問。

可以看到,我們第一次方法的時候就成功的達到了我們要的效果,隨機數就是 0 ,在 1 秒后重試后結果正常。在多試了幾次過后,會遇到三次都是 0 的情況,這個時候才會拋出異常,說明服務是真的有問題了。

上面的代碼可以看到是有效果了,雖然不是很好看,特別是在還有一些其他邏輯的情況,看上去會很臃腫,但是確實是可以正常使用的,那么有的小伙伴就要問了,有沒有一種優(yōu)雅的方式呢?總不能在很多地方都重復的這樣寫重試的代碼吧。

注解重試

要知道我們普通人在日常開發(fā)的時候,如果遇到一個問題肯定是別人都遇到過的,什么時候當我們遇到的問題,沒有人遇到過的時候,那說明我們是很前衛(wèi)的。

因此小伙伴能想到的是不是有簡單的方式來進行重試,有的人已經幫我們想好了,可以通過 @Retryable 注解來實現一樣的效果,接下來阿粉就給大家演示一下如何使用這個注解。

首先我們需要在啟動類上面加入 @EnableRetry? 注解,表示要開啟重試的功能,這個很好理解,就像我們要開啟定時功能需要添加 @EnableScheduling? 注解一樣,Spring? 的 @Enablexxx 注解也是很有意思的,后面我們再聊。

添加完注解以后,需要加入切面的依賴,如下

<dependency>
  <groupId>org.aspectj</groupId>
  <artifactId>aspectjweaver</artifactId>
  <version>1.9.2</version>
</dependency>

如下不加入這個切面依賴,啟動的時候會有如下異常

添加的注解和依賴過后,我們需要改造 HelloService? 里面的 sayHello()? 方法,簡化成如下,增加  @Retryable 注解,以及設置相應的參數值。

@Retryable(value = Exception.class, maxAttempts = 3, backoff = @Backoff(delay = 1000, multiplier = 2))
  public String sayHello(String name){
    return name + doSomething();
  }

再次通過瀏覽器訪問 http://127.0.0.1:8080/hello?name=ziyou 我們看到效果如下,跟我們自己寫的重試一樣。

@Retryable 詳解

//
// Source code recreated from a .class file by IntelliJ IDEA
// (powered by FernFlower decompiler)
//

package org.springframework.retry.annotation;

import java.lang.annotation.Documented;
import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;

@Target({ElementType.METHOD, ElementType.TYPE})
@Retention(RetentionPolicy.RUNTIME)
@Documented
public @interface Retryable {
    String recover() default "";

    String interceptor() default "";

    Class<? extends Throwable>[] value() default {};

    Class<? extends Throwable>[] include() default {};

    Class<? extends Throwable>[] exclude() default {};

    String label() default "";

    boolean stateful() default false;

    int maxAttempts() default 3;

    String maxAttemptsExpression() default "";

    Backoff backoff() default @Backoff;

    String exceptionExpression() default "";

    String[] listeners() default {};
}

點到這個注解里面,我們可以看到這個注解的代碼如下,其中有幾個參數我們來解釋一下

  • recover:  當前類中的回滾方法名稱;
  • interceptor: 重試的攔截器名稱,重試的時候可以配置一個攔截器;
  • value:需要重試的異常類型,跟下面的 include 一致;
  • include:包含的重試的異常類型;
  • exclude:不包含的重試異常類型;
  • label:用于統計的唯一標識;
  • stateful?:標志表示重試是有狀態(tài)的,也就是說,異常被重新拋出,重試策略是否會以相同的策略應用于具有相同參數的后續(xù)調用。如果是false,那么可重試的異常就不會被重新拋出。
  • maxAttempts:重試次數;
  • backoff:指定用于重試此操作的屬性;
  • listeners?:重試監(jiān)聽器bean 名稱;

配合上面的一些屬性的使用,我們就可以達到通過注解簡單來實現方法調用異常后的自動重試,非常好用。我們可以在執(zhí)行重試方法的時候設置自定義的重試攔截器,如下所示,自定義重試攔截器需要實現 MethodInterceptor? 接口并實現 invoke 方法,不過要注意,如果使用了攔截器的話,那么方法上的參數就會被覆蓋。

package com.example.demo.pid;

import org.aopalliance.intercept.MethodInterceptor;
import org.aopalliance.intercept.MethodInvocation;
import org.springframework.retry.interceptor.RetryInterceptorBuilder;
import org.springframework.retry.interceptor.RetryOperationsInterceptor;
import org.springframework.retry.policy.SimpleRetryPolicy;
import org.springframework.stereotype.Component;

@Component
public class CustomRetryInterceptor implements MethodInterceptor {

  @Override
  public Object invoke(MethodInvocation invocation) throws Throwable {
    RetryOperationsInterceptor build = RetryInterceptorBuilder.stateless()
      .maxAttempts(2).backOffOptions(3000, 2, 1000).build();
    return build.invoke(invocation);
  }
}

自定義回滾方法,我們還可以在重試幾次依舊錯誤的情況,編寫自定義的回滾方法。

@Retryable(value = Exception.class,
    recover = "recover", maxAttempts = 2,
    backoff = @Backoff(delay = 1000, multiplier = 2))
  public String sayHello(String name){
    return name + doSomething();
  }

  @Recover
  public String recover(Exception e, String name) {
    System.out.println("recover");
    return "recover";
  }

要注意:

  • 重試方法必須要使用@Recover 注解;
  • 返回值必須和被重試的函數返回值一致;
  • 參數中除了第一個是觸發(fā)的異常外,后面的參數需要和被重試函數的參數列表一致;

上面代碼中的 @Backoff(delay = 1000, multiplier = 2) 表示第一次延遲 1000ms 重試,后面每次重試的延遲時間都翻倍。

總結

阿粉今天給大家介紹了一下 Spring? 的 @Retryable 注解使用,并通過幾個 demo 來帶大家編寫了自己重試攔截器以及回滾方法的時候,是不是感覺用起來會很爽,那還在等什么趕緊用起來吧,其中還有很多細節(jié),只有自己真正的使用過才能體會到。

到此這篇關于Java 遠程調用失敗重試的操作方法的文章就介紹到這了,更多相關Java 遠程調用失敗內容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家!

相關文章

  • 學習SpringMVC——國際化+上傳+下載詳解

    學習SpringMVC——國際化+上傳+下載詳解

    本篇文章主要介紹了學習SpringMVC——國際化+上傳+下載,小編覺得挺不錯的,現在分享給大家,也給大家做個參考。
    2016-12-12
  • Spring @Cacheable注解中key的使用詳解

    Spring @Cacheable注解中key的使用詳解

    這篇文章主要介紹了Spring @Cacheable注解中key的使用,具有很好的參考價值,希望對大家有所幫助。如有錯誤或未考慮完全的地方,望不吝賜教
    2021-12-12
  • spring boot實現軟刪除的示例代碼

    spring boot實現軟刪除的示例代碼

    這篇文章主要介紹了spring boot實現軟刪除的示例代碼,小編覺得挺不錯的,現在分享給大家,也給大家做個參考。一起跟隨小編過來看看吧
    2018-07-07
  • 詳解Java中異步轉同步的六種方法

    詳解Java中異步轉同步的六種方法

    針對應用中異步調用,能不能像同步調用一樣立刻獲取到命令的執(zhí)行結果,如何實現異步轉同步?不要擔心,本文就來為大家詳細講講Java中異步轉同步的六種方法,感興趣的可以了解一下
    2022-06-06
  • 簡單操作實現Java jsp servlet文件上傳過程解析

    簡單操作實現Java jsp servlet文件上傳過程解析

    這篇文章主要介紹了簡單操作實現Java jsp servlet文件上傳過程解析,文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下
    2019-10-10
  • IDEA 開發(fā)多項目依賴的方法(圖文)

    IDEA 開發(fā)多項目依賴的方法(圖文)

    這篇文章主要介紹了IDEA 開發(fā)多項目依賴的方法(圖文),本文講一下關于使用IntelliJ IDEA基于Maven創(chuàng)建多模塊項目的實際開發(fā),非常具有實用價值,需要的朋友可以參考下
    2018-10-10
  • 解決IDEA Gradle構建報錯''Cause: zip END header not found''

    解決IDEA Gradle構建報錯''Cause: zip END header not found''

    這篇文章主要介紹了解決IDEA Gradle構建報錯"Cause: zip END header not found"的問題,本文給大家介紹的非常詳細,對大家的學習或工作具有一定的參考借鑒價值,需要的朋友可以參考下
    2021-02-02
  • Java遞歸實現迷宮游戲

    Java遞歸實現迷宮游戲

    這篇文章主要介紹了如何利用Java遞歸方法實現迷宮游戲,下面文章會詳細的從為問題描述開始,清晰的解題思路以及詳細的代碼實現,具有一定的參考價值,需要的小伙伴可以參考一下
    2021-12-12
  • 基于java中正則操作的方法總結

    基于java中正則操作的方法總結

    本篇文章介紹了,在java中正則操作的方法總結。需要的朋友參考下
    2013-05-05
  • SpringBoot路徑映射實現過程圖解

    SpringBoot路徑映射實現過程圖解

    這篇文章主要介紹了SpringBoot路徑映射實現過程圖解,文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下
    2019-12-12

最新評論