8.5.Feign 与 Hystrix整合
服务熔断服务降级彻底解耦
前面的代码，用@HystrixCommand fallbackMethod是很不好的，因为和业务代码耦合度太高，不利于维护，所以需要解耦。
首先我们将Feign与 Hystrix整合。
第一，microservice-ticket-provider-hystrix-1004项目修改
按照正常的逻辑来写；
TicketService加新的接口方法lockTicket()：
/**
* 锁票业务
* @return
*/
public Map<String,Object> lockTicket();
TicketServiceImpl写具体实现：
@Override
public Map<String, Object> lockTicket() {
try {
//模拟超时用
Thread.sleep(2000);
} catch (InterruptedException e) {
e.printStackTrace();
}
Map<String,Object> map=new HashMap<String,Object>();
map.put("code", 200);
map.put("msg", "锁定的车票数据xxxxx3000");
return map;
}
TicketProviderController正常调用service方法：
注意：注释部分是之前的那种方法写的，为了便于学习对比，注释保留
/**
* 锁票业务
*
* @return
* @throws InterruptedException
*/
@ResponseBody
@GetMapping(value = "/lockTicket")
// @HystrixCommand(fallbackMethod = "lockTicketFallback")
public Map<String, Object> lockTicket() throws InterruptedException {
// Thread.sleep(2000);
// Map<String,Object> map=new HashMap<String,Object>();
// map.put("code", 200);
// map.put("msg", "锁定的车票数据xxxxx3000");
// return map;
return ticketService.lockTicket();
} /**
* 模拟锁票超时 或者 系统故障的回调函数
* @return
* @throws InterruptedException
*/
// public Map<String,Object> lockTicketFallback() throws InterruptedException{
// Map<String,Object> map=new HashMap<String,Object>();
// map.put("code", 500);
// map.put("msg", "系统出错，稍后重试");
// return map;
// }
第二步：microservice-common项目新建FallbackFactory类，解耦服务熔断服务降级
TicketClientService接口，新增lockTicket()方法；
/**
* 索票业务
* @return
*/
@GetMapping(value="/ticket/lockTicket")
public Map<String,Object> lockTicket();
新建 TicketClientFallbackFactory 类，实现FallbackFactory<TicketClientService>接口；
package com.wfd360.service; import com.wfd360.model.Ticket;
import feign.hystrix.FallbackFactory;
import org.springframework.web.bind.annotation.PathVariable; import java.util.HashMap;
import java.util.List;
import java.util.Map; /**
* Created by 姿势帝-博客园 on 2019/4/1.
* 欢迎添加笔者wx(851298348)共同探讨、学习！
*/ public class TicketClientFallbackFactory implements FallbackFactory<TicketClientService> {
@Override
public TicketClientService create(Throwable throwable) {
return new TicketClientService() {
@Override
public Ticket get(@PathVariable("id") Integer id) {
// 服务超时或者出错时 返回的业务逻辑
return null;
} @Override
public List<Ticket> list() {
// 服务超时或者出错时 返回的业务逻辑
return null;
} @Override
public boolean save(Ticket ticket) {
// 服务超时或者出错时 返回的业务逻辑
return false;
} @Override
public boolean delete(@PathVariable("id") Integer id) {
// 服务超时或者出错时 返回的业务逻辑
return false;
} @Override
public Map<String, Object> lockTicket() {
Map<String, Object> map = new HashMap<String, Object>();
map.put("code", 500);
map.put("msg", "系统出错，稍后重试");
return map;
}
};
}
}
TicketClientService接口的@FeignClient注解加下 fallbackFactory属性
@FeignClient(value="MICROSERVICE-STUDENT",fallbackFactory=TicketClientFallbackFactory.class)
这类我们实现了 降级处理方法实现；
第三步：microservice-ticket-consumer-feign-80修改 支持Hystrix
TicketConsumerFeignController新增方法调用
/**
* 索票
* @return
*/
@GetMapping(value="/lockTicket")
@ResponseBody
public Map<String,Object> lockTicket(){
System.out.println("------调用锁票业务------------");
return ticketClientService.lockTicket();
}
application.yml加上hystrix支持
feign:
hystrix:
enabled: true
=======================
feign与hystrix 服务熔断服务降级彻底解耦完成，测试与之前一样！
8.6.Feign Hystrix整合之超时时间配置
Feign Hystrix整合后，hystrix超时时间配置的话 这里要配置到消费端。
也就是 microservice-ticket-provider-hystrix-1004 的 yml里的
hystrix:
command:
default:
execution:
isolation:
thread:
timeoutInMilliseconds: 3000
这个配置放到 microservice-ticket-consumer-feign-80 的yml里
但是 放进去后 大伙测试 依然无效。
这里因为还有一个 feign 也有一个超时时间的设置，当然feign底层是 ribbon的封装，所以 直接配置ribbon，ribbon默认超时也是1秒。
所以这里都是强制要求，ribbon的超时时间要大于hystrix的超时时间，否则 hystrix自定义的超时时间毫无意义。
所以还得加个 ribbon超时时间设置
ribbon:
ReadTimeout: 50000
ConnectTimeout: 6000
测试与之前一样，大家可以设定设置超时间后，在调整睡眠时间进行测试！
hystrix 的应用暂时讲到这里，本案例代码可以下载 V8版本！