可靠：断路器模式

背景

你已经使用了微服务架构。有时服务结合起来处理请求。当一个服务同步条用另一个服务时，总有肯呢个出现其他服务不可用或者出现很高的延迟而基本不可用。前一个服务的资源，比如线程，可能在等待其他服务的响应时被占用。一个服务的失败潜在的级联影响到应用中其他服务的吞吐量。

问题

如何阻止网络或服务的失效级联影响到其他的服务？

限制

解决方案

服务客户端应该通过一层代理访问远程服务，这个店里提供了类似电路断路器的功能。当连续失败的次数超出阈值，断路器跳闸，在一个超时周期范围内所有尝试请求远程服务的请求都快速失败。当超时时间到达后，断路器允许一定数量的测试请求通过。如果这些请求成功，断路器恢复正常操作。否则，如果出现失败，则上述超时周期又重新开始。

示例

微服务示例应用 中的 RegistrationServiceProxy 是一个示例组件，采用Scala编写，使用断路器处理调用远程服务的失败。

@Component
class RegistrationServiceProxy @Autowired()(restTemplate: RestTemplate) extends RegistrationService {

  @Value("${user_registration_url}")
  var userRegistrationUrl: String = _

  @HystrixCommand(commandProperties=Array(new HystrixProperty(name="execution.isolation.thread.timeoutInMilliseconds", value="800")))
  override def registerUser(emailAddress: String, password: String): Either[RegistrationError, String] = {
    try {
      val response = restTemplate.postForEntity(userRegistrationUrl,
        RegistrationBackendRequest(emailAddress, password),
        classOf[RegistrationBackendResponse])
      response.getStatusCode match {
        case HttpStatus.OK =>
          Right(response.getBody.id)
      }
    } catch {
      case e: HttpClientErrorException if e.getStatusCode == HttpStatus.CONFLICT =>
        Left(DuplicateRegistrationError)
    }
  }
}

@HystrixCommand 安排了使用断路器来处理对 registerUser() 的调用。

通过在 UserRegistrationConfiguration 类上添加 @EnableCircuitBreaker 模式，启用断路器功能。

@EnableCircuitBreaker
class UserRegistrationConfiguration {

结果

这个模式有如下优势：

• 服务处理了它们调用远程服务产生的错误

这个模式有如下问题：

• 选择合适的超时时间，不带来误报或引入更多的延迟，是有挑战性的。

相关模式

• 微服务基架 可能实现了这个模式
• API网关 将使用这个模式调用服务
• 服务端发现 路由可能使用这个模式调用服务

参见

• Netflix Hystrix 是实现了这个模式的一个示例库