ribbon，feign选择和与Hystrix的整合应用 _hystrix

丈夫志四海，万里犹比邻。这篇文章主要讲述ribbon，feign选择和与Hystrix的整合应用相关的知识，希望能为你提供帮助。

文章图片

1.ribbon与feign的区别

feign是在ribbon上封装的
ribbon请求需要自己拼接而 Feign 是一个使用起来更加方便的 HTTP 客戶端，使用起来就像是调用自身工程的方法，而感觉不到是调用远程方法。

文章图片
feign封装了负载均衡功能
可以统一管理方便复用
极简整合hystrix

2.spring boot使用feign+hystrix 1.修改application类

@SpringBootApplication(scanBasePackages = "com.vanpeng.cms")
@ComponentScan("com.vanpeng.cms.*")
@EnableCaching
@EnableEurekaClient
@EnableSwagger2
@EnableFeignClients#开启feign
@EnableCircuitBreaker#开启hystrix
//@EnableApolloConfig
public class CmsApplication {

public static void main(String[] args) {
SpringApplication.run(CmsApplication.class, args);
}

@Bean
@LoadBalanced
RestTemplate restTemplate() {
return new RestTemplate();
}

}

2.修改application.yml

feign:
hystrix:
enabled: true#hystrix默认关闭需要开启
ribbon:
ConnectTimeout: 5000 # 请求连接的超时时间默认的时间为 1 秒
ReadTimeout: 5000 # 请求处理的超时时间
hystrix:
command:
default:#default全局有效，service id指定应用有效
execution:
timeout:
#如果enabled设置为false，则请求超时交给ribbon控制,为true,则超时作为熔断根据
enabled: true
isolation:
strategy: SEMAPHORE
thread:
timeoutInMilliseconds: 5000 #断路器超时时间，默认1000ms
circuitBreaker:
enabled: true
requestVolumeThreshold: 10 #默认20 ，熔断的阈值，如何user服务报错满足3次，熔断器就会打开，就算order之后请求正确的数据也不行。
sleepWindowInMilliseconds: 8000 #默认5S ，等5S之后熔断器会处于半开状态，然后下一次请求的正确和错误讲决定熔断器是否真的关闭和是否继续打开
errorThresholdPercentage: 0.5

3.服务间调用

@FeignClient(name = "data-service", fallback = DataFallBack.class) //表明是feign接口 name为被调用服务在erueka上的服务名
public interface DataServiceFeign {

@PostMapping("/selectDataSetId") //对应着被调用服务的路径post表明为post请求请求参数为@RequestBody ResultCatalog resultCatalog
Result< Object> selectByDataSetId(@RequestBody ResultCatalog resultCatalog);

@GetMapping("/resourceMenu/selectFeignService/{lecturerUserNo}") //表明为get请求参数为 @PathVariable(value = "https://www.songbingjia.com/android/lecturerUserNo") Long lecturerUserNo
Result< List< ResultCatalog> >
selectService(@PathVariable(value = "https://www.songbingjia.com/android/lecturerUserNo") Long lecturerUserNo);

}

4.熔断hystrix

@Component
public class DataFallBack implements DataServiceFeign {//需要实现feign接口每个方法对应着每个feign调用的服务

@Override
public Result< Object> selectByDataSetId(ResultCatalog resultCatalog) {
Result< Object> result = new Result< Object> ();
String error = "调用系统失败。";
result.setCode(506);
result.setMessage(error);
return result;
}

@Override
public Result< List< ResultCatalog> >
selectServicel(Long lecturerUserNo) {
Result< List< ResultCatalog> > result = new Result< > ();
String error = "调用系统失败。";
result.setCode(506);
result.setMessage(error);
return result;
}
}

使用依赖注入调用即可.

public class DataServiceController {

@Autowired
DataServiceFeign dataServiceFeign;

@Autowired
SystemPortalFeign systemPortalFeign;

/**
* ajax数据服务
*
* @param resultMapResourceCatalog
* @return
*/
@PostMapping("/DataService")
public Result
DataService(@RequestBody ResultCatalog resultCatalog) {
Result< Object> resultObj = dataServiceFeign.selectByDataSetId(resultCatalog);

}
}