Maison  >  Article  >  Java  >  Comment SpringBoot intègre Retry pour implémenter une nouvelle tentative d'erreur

Comment SpringBoot intègre Retry pour implémenter une nouvelle tentative d'erreur

PHPz
PHPzavant
2023-05-19 22:11:32978parcourir

    Présentation des dépendances

    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-aop</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.retry</groupId>
        <artifactId>spring-retry</artifactId>
    </dependency>

    Dépendance complète sur pom.xml

    <?xml version="1.0" encoding="UTF-8"?>
    <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
        xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
        <modelVersion>4.0.0</modelVersion>
        <parent>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-parent</artifactId>
            <version>2.7.7</version>
            <relativePath/> <!-- lookup parent from repository -->
        </parent>
        <groupId>com.example</groupId>
        <artifactId>demo</artifactId>
        <version>0.0.1-SNAPSHOT</version>
        <name>demo</name>
        <description>Demo project for Spring Boot</description>
        <properties>
            <java.version>1.8</java.version>
        </properties>
        <dependencies>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-devtools</artifactId>
                <scope>runtime</scope>
                <optional>true</optional>
            </dependency>
            <dependency>
                <groupId>org.projectlombok</groupId>
                <artifactId>lombok</artifactId>
                <optional>true</optional>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-test</artifactId>
                <scope>test</scope>
            </dependency>
            <!-- spring-retry -->
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-aop</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.retry</groupId>
                <artifactId>spring-retry</artifactId>
            </dependency>
        </dependencies>
        <build>
            <plugins>
                <plugin>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-maven-plugin</artifactId>
                    <configuration>
                        <excludes>
                            <exclude>
                                <groupId>org.projectlombok</groupId>
                                <artifactId>lombok</artifactId>
                            </exclude>
                        </excludes>
                    </configuration>
                </plugin>
            </plugins>
        </build>
    </project>

    Open spring-retry # 🎜🎜#

    Ajouter une annotation à la classe de démarrage

    @EnableRetry

    package com.example.demo;
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.retry.annotation.EnableRetry;
    @EnableRetry
    @SpringBootApplication
    public class Application {
        public static void main(String[] args) {
            SpringApplication.run(Application.class, args);
        }
    }

    Utiliser l'annotation de nouvelle tentative

    @Annotation réessayable

    #🎜 🎜#
      value, type d'exception réessayable. La signification est la même que celle d'inclure. La valeur par défaut est vide (si l'exclusion est également vide, toutes les exceptions sont réessayées)
    • include : types d'exceptions réessayables. La valeur par défaut est vide (si l'exclusion est également vide, toutes les exceptions sont réessayées)
    • exclude : types d'exceptions qui n'ont pas besoin d'être réessayés. La valeur par défaut est vide (si include est également vide, toutes les exceptions seront réessayées)
    • maxAttempts : Le nombre maximum de tentatives (y compris le premier échec), la valeur par défaut est 3 fois
    • backoff : Réessayez la stratégie d'attente, qui sera introduite dans @Backoff ci-dessous
    • recover : signifie réessayer la méthode de rappel une fois que le nombre de tentatives atteint le nombre maximum de tentatives delay, retry Le temps d'attente maximum entre les tentatives (en millisecondes) #
    • multiplier, précisez le multiple du délai

    delayExpression, le temps d'attente expression entre les tentatives

    • maxDelayExpression, l'expression du temps d'attente maximum entre les tentatives

    • multiplierExpression, l'expression multiplicateur qui précise le délai

      #🎜 🎜#
    • aléatoire, précise aléatoirement le délai

    • Exemple d'utilisation

      package com.example.demo.component;
      import org.springframework.retry.annotation.Recover;
      import org.springframework.retry.annotation.Retryable;
      import org.springframework.stereotype.Component;
      @Component
      public class HttpRequest {
          private int count = 0;
          /**
           * 模拟网络请求异常
           * @return
           */
          @Retryable(recover = "errorHandler")
          public String getResponse() {
              count++;
              System.out.println("time: " + count);
              if (count < 4) {
                  throw new RuntimeException("count: " + count);
              }
              return "success";
          }
          /**
           * 错误处理函数
           * 注意:需要返回 String,否则会抛出方法找不到异常
           * org.springframework.retry.ExhaustedRetryException: Cannot locate recovery method
           *
           * @param e
           * @return
           */
          @Recover
          public String errorHandler(RuntimeException e) {
              System.out.println("errorHandler");
              return "ok";
          }
      }
      # 🎜🎜#Test

      package com.example.demo.component;
      import org.junit.jupiter.api.Test;
      import org.springframework.beans.factory.annotation.Autowired;
      import org.springframework.boot.test.context.SpringBootTest;
      @SpringBootTest
      public class HttpRequestTest {
          @Autowired
          private HttpRequest httpRequest;
          @Test
          public void getResponse(){
              httpRequest.getResponse();
          }
      }
      # 🎜🎜#Résultat de sortie
    • heure : 1

      heure : 2
    • heure : 3
    • errorHandler# 🎜🎜#

    Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!

    Déclaration:
    Cet article est reproduit dans:. en cas de violation, veuillez contacter admin@php.cn Supprimer