升级微服务架构4：断路器

　　断路器是电路中的一个保护电路安全的开关，当电路出现短路时，断路器会自动跳闸，防止出现电路故障。

　　一个微服务架构的系统中也需要这种保护装置，当消费者调用某一个服务的时候，如当前的服务有异常，譬如服务已经挂了，这时候就需要断路器来把当前调用的服务断开，Spring Cloud中集成的断路器组件为：Hystrix。如图所示，Hystrix在调用服务失败的情况下会进行回退或者降级处理，比如快速失败、无声失败、返回默认值、自己组装一个返回值、利用远程缓存、主次方式回退等回退类型。

　　降级回退相关资料：https://www.jianshu.com/p/3e11ac385c73?from=timeline

　　


　　以上一章的调用用户服务为例，先实现Java端的再移植到.net core

　　1.服务调用设置断路器java版

　　在Spring Cloud官方文档搜索断路器：Circuit Breaker

　　参考：http://cloud.spring.io/spring-cloud-static/Finchley.SR1/single/spring-cloud.html#_circuit_breaker_hystrix_clients

　　官方文档示例：

　　


　　1.1 添加断路器依赖

　　断路器是在消费者调用时添加的，首先在orderservice上添加Hystrix依赖　　

<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
</dependency>

　　在启动类上添加@EnableCircuitBreaker注解来启用Hystrix

　　1.2 指定调用失败退回方法

　　在调用服务类UserService各个方法中添加回退错误的方法，并使用@HystrixCommand注解指定回退的方法

@Service
public class UserService {

@Autowired
private RestTemplate restTemplate;

private String serviceUrl="http://userservice/user";

@HystrixCommand(fallbackMethod = "getAllError")
public List<User> getAll() {
ParameterizedTypeReference<List<User>> responseType = new ParameterizedTypeReference<List<User>>(){};
ResponseEntity<List<User>> resp = restTemplate.exchange(serviceUrl+"/getall",
HttpMethod.GET, null, responseType);
List<User> list = resp.getBody();
return list;
}

@HystrixCommand(fallbackMethod = "getPortError")
public String getPort(){
String msg = restTemplate.getForObject(serviceUrl+"/getport", String.class);
return msg;
}

public User getByName(String name){
User user = restTemplate.getForObject(serviceUrl+"/getbyname?name="+name, User.class);
return user;
}

//getAll回退方法
public List<User> getAllError() {
return null;
}
//getPort回退方法
public String getPortError() {
return "userservice服务断开，getPort方法调用错误!";
}
}

　　把userservice服务停掉，调用一下订单服务的获取端口方法，进入了错误方法了，说明已经成功设置回退方法。

　　


　　启动服务后，调用成功。

　　


　　

　　1.3 设置超时时间

　　如果调用一直进入回退方法，可能是Hystrix没设置超时时间，配置下超时时间即可。　　

hystrix:
command:
default:
execution:
timeout:
enabled: true
isolation:
thread:
timeoutInMilliseconds: 10000 #设置超时时间 10秒

　　

　　2.服务调用设置断路器.net core版

　　2.1 添加断路器引用

　　首先在OrderService项目中添加Steeltoe.CircuitBreaker.HystrixCore引用

　　


　　2.2 创建Command类来指定退回方法

　　在调用用户服务UserService类上继承HystrixCommand<string>

　　官方文档：http://steeltoe.io/docs/steeltoe-circuitbreaker/#1-2-8-use-commands

　　.net core版比较麻烦的是，不能直接在Service的方法上加特性来声明要回退的方法，而是每个方法要都用一个继承自HystrixCommand<>的泛型方法，泛型类型为方法返回的类型，然后再调用这个类的方法，Java版直接用注解还是方便很多。
　　可以参考SteeltoeOSS的例子：https://github.com/SteeltoeOSS/Samples/tree/dev/CircuitBreaker/src/AspDotNetCore/FortuneTeller/Fortune-Teller-UI/Services

　　


　　两个Command类对应Service里面的两个方法。

　　Command类我们按照服务名（去掉后面的Service）+方法名+Command来命名，方便确定是调用的那个方法，譬如获取所有用户的类：UsergetAllCommand。

　　

using System.Collections.Generic;
using System.Threading.Tasks;
using Steeltoe.CircuitBreaker.Hystrix;

namespace OrderService.Controllers
{
public class UsergetAllCommand : HystrixCommand<List<User>>
{
private IUserService _userService;
public UsergetAllCommand(IHystrixCommandOptions options,IUserService userService)
: base(options)
{
_userService = userService;
IsFallbackUserDefined = true;
}
public async Task<List<User>> getAll()
{
return await ExecuteAsync();
}
protected override async Task<List<User>> RunAsync()
{
var result = await _userService.getAll();
return result;
}

/// <summary>
/// 回退方法
/// </summary>
/// <returns></returns>
protected override async Task<List<User>> RunFallbackAsync()
{
return null;
}
}
}

　　

　　同样再创建一个getPort的命令类，然后在Startup类中的ConfigureServices配置HystrixCommand类的注入　　

// 注册使用HystrixCommand类封装UserService方法做断路器的命令类
services.AddHystrixCommand<UsergetAllCommand>("userservice", Configuration);
services.AddHystrixCommand<UsergetPortCommand>("userservice", Configuration);

　　

　　在OrderController中改为使用Command类来调用userservice的方法。　　

[Route("[controller]")]
[ApiController]
public class OrderController : ControllerBase
{
private readonly IUserService _userService;

private readonly UsergetAllCommand _usergetAllCommand;

private readonly UsergetPortCommand _usergetPortCommand;
//构造方法来注入实例
public OrderController(IUserService userService
,UsergetAllCommand usergetAllCommand
,UsergetPortCommand usergetPortCommand)
{
_userService = userService;
_usergetAllCommand = usergetAllCommand;
_usergetPortCommand = usergetPortCommand;
}

[Route("getalluser")]
[HttpGet]
public async Task<List<User>> getAll()
{
//List<User> list = await _userService.getAll();
var list =await _usergetAllCommand.getAll();
return list;
}

[Route("getuserserviceport")]
[HttpGet]
public async Task<string> getUserServicePort()
{
//var port = await _userService.getPort();
var port = await _usergetPortCommand.getPort();
return port;
}

}

　　停止userservice服务，成功调用回退方法。

　　


　　启动userservice服务后再刷新，成功获取到数据。

　　


　　2.3 设置超时时间　　

{
"Logging": {
"LogLevel": {
"Default": "Warning"
}
},
"AllowedHosts": "*",
"spring": {
"application": {
"name": "orderservice"
}
},
"eureka": {
"client": {
"serviceUrl": "http://localhost:8881/eureka/",
"shouldRegisterWithEureka": true,
"shouldFetchRegistry": true
},
"instance": {
"port": 6660
}
},
"hystrix": {
"command": {
"default": {
"execution": {
"timeout": { "enabled": true },
"isolation": {
"thread": { "timeoutInMilliseconds" : 10000 }
}
}
}
}
}
}

　　至此断路器已添加完毕。