快捷導(dǎo)航

springboot+feign+Hystrix整合(親測(cè)有效)

更新時(shí)間：2023年11月20日 08:28:20 作者：大樹(shù)葉

本文主要介紹了springboot+feign+Hystrix整合,文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧

pom依賴(lài)

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-openfeign</artifactId>
    <version>3.0.6</version>
</dependency>
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
     <version> 2.2.10.RELEASE</version>
</dependency>

properties 開(kāi)啟選項(xiàng)

feign:
  client:
    config:
       default:
         #發(fā)起重試的時(shí)間間隔3s
         feignPeriod: 3000
         #發(fā)起重試的最大時(shí)間間隔10s，單位毫秒
         feignMaxPeriod: 10000
         #重試次數(shù)2，如果需要重試1次，就設(shè)置為2
         feignMaxAttempts: 3
         #5s connectTimeout 和 readTimeout 必須同時(shí)配置
         connectTimeout: 5000
         readTimeout: 5000
         writeTimeout: 5000
  compression:
    request:
      enabled: true
    response:
      enabled: true
  httpclient:
    enabled: false
  okhttp:
    enabled: true
  circuitbreaker:
    enabled: true

hystrix:
  command:
    default:
      execution:
        isolation:
          thread:
            timeoutInMilliseconds: 5000

注：這里開(kāi)啟選項(xiàng)為feign.circuitbreaker.enable=true，這是對(duì)2021年后的spring cloud版本的。 Spring Cloud CircuitBreaker 已經(jīng)是獨(dú)立項(xiàng)目了。 springcloud早期版本用下面這段配置在feign中生效：feign.hystrix.enabled=true

Java code example

注意使用@EnableHystrix 和@EnableFeignClients

@EnableTransactionManagement
@EnableAspectJAutoProxy
@Configuration
@SpringBootApplication(scanBasePackages = {"cn.com.datang.supersms"},exclude = {ArchaiusAutoConfiguration.class})
@EnableCaching
@EnableFeignClients(basePackages = "cn.com.datang.supersms.rpc")
@EnableHystrix
public class AhohSuerSMSDeliveryApplication {
    public static void main(String[] args) {
        SpringApplication.run(AhohSuerSMSDeliveryApplication.class, args);
    }
}

業(yè)務(wù)代碼

@FeignClient(
        name = "portrayalApi",
        url = "${datang.portrayal.addr}",
        fallbackFactory = PortrayalApiFallbackFactory.class
)
public interface PortrayalApi {
    @GetMapping(value = "/upb2")
    String getInterestedCarsInfo(@RequestParam(value = "appid") String appid,
                                 @RequestParam(value = "type") String type,
                                 @RequestParam(value = "id") String id);
}
@Slf4j
@Component
public class PortrayalApiFallbackFactory implements FallbackFactory<PortrayalApi> {
    @Override
    public PortrayalApi create(Throwable cause) {
        return (appid, type, id) -> {
             log.warn("網(wǎng)絡(luò)調(diào)用異常，使用降級(jí)措施來(lái)處理了.異常信息:",cause);
             return null;
         };
    }
}

好了，到此結(jié)束，親自有效！更多相關(guān)springboot+feign+Hystrix內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: