快捷導(dǎo)航

SpringBoot項(xiàng)目中feignClient使用方式

更新時(shí)間：2024年11月13日 09:16:31 作者：三五二十五

文章介紹了在Spring Boot項(xiàng)目中配置Feign客戶端攔截器的具體步驟,包括在application.yml中添加配置、在主類上啟用組件掃描、將攔截器加入到攔截器列表中以及在接口調(diào)用時(shí)的說明,總結(jié)指出這是個(gè)人經(jīng)驗(yàn)分享,希望對(duì)大家有所幫助

SpringBoot項(xiàng)目中feignClient使用

1.在application.yml中加入兩個(gè)配置

# feign client 配置
hystrix:
  threadpool:
    default:
      coreSize: 500
      maxQueueSize: -1
      queueSizeRejectionThreshold: 10000
  command:
    default:
      circuitBreaker:
        requestVolumeThreshold: 1500
      execution:
        #（超時(shí)時(shí)間）
        timeout:
          enabled: false
        #（上下文傳遞）
        isolation:
          strategy: SEMAPHORE
          semaphore:
            maxConcurrentRequests: 1500
            maxSemaphores: 1500
ribbon:
  ConnectTimeout: 50000000
  ReadTimeout: 500000000

2.在主類上加入

scanBasePackageClasses = FeignInterceptor.class, scanBasePackages = {"com.example"}

FeignInterceptor用來掃描 傳遞上下文的攔截器
 {"com.example"}用來掃描自己的包
 @EnableFeignClients（主類上）掃描被@FeignClient注解的接口
  
@EnableFeignClients
@SpringBootApplication(scanBasePackageClasses = FeignInterceptor.class, scanBasePackages = {"com.example"})

3.將xxxRestContextInterceptor加入到攔截器中

 @Configuration
public class  WebAppConfig extends WebMvcConfigurerAdapter {
 
    @Override
    public void addInterceptors(InterceptorRegistry registry) {
        //注冊自定義攔截器，添加攔截路徑和排除攔截路徑
        registry.addInterceptor(new XsyRestContextInterceptor());
    }
}

4.接口調(diào)用說明

聲明一個(gè)接口比如:PaasAggFeignClient,在其上顯式加上@FeignClient注解

內(nèi)部填入Eureka上已注冊服務(wù)名稱比如：

@FeignClient("manager-service", configuration = FeignInterceptor.class)

其中configuration = FeignInterceptor.class是要加上的，保證FeignInterceptor生效

自定義方法，請(qǐng)求路徑為該服務(wù)上對(duì)應(yīng)的rest請(qǐng)求路徑，如下

@FeignClient("manager-service")
public interface PaasAggFeignClient {
    @RequestMapping(value = "/api/xxxx/test/description", method = RequestMethod.GET)
    String testDescription();
 
    @RequestMapping(value = "/api/xxxx/test/{id}", method = RequestMethod.GET)
    String testInfo(@PathVariable("id") Long id);
 
    @RequestMapping(value = "/api/xxxx/test/", method = RequestMethod.POST, consumes = {MediaType.APPLICATION_JSON})
    String testCreate(@RequestBody JSONObject jsonObject);
 
    @RequestMapping(value = "/api/xxxx/test/{id}", method = RequestMethod.DELETE)
    String testDelete(@PathVariable("id") Long id);
 
    @RequestMapping(value = "/api/xxxx/test/{id}", method = RequestMethod.PATCH, consumes = {MediaType.APPLICATION_JSON})
    String testUpdate(@PathVariable("id") Long id, @RequestBody JSONObject jsonObject);
}

5.在對(duì)應(yīng)controller內(nèi)引入自定義接口即可使用

@Resource
private PaasAggFeignClient paasAggFeignClient;
 
String paasAggResult = paasAggFeignClient.testDescription();
 
String paasAggResult = paasAggFeignClient.testCreate(entity);
 
String paasAggResult = paasAggFeignClient.testDelete(id);
 
.....