Spring Cloud：第四章：Hystrix 断路器，mybatis 面试常问问题
@LoadBalanced
RestTemplate restTemplate() {
return new RestTemplate();
}
public static void main(String[] args) {
SpringApplication.run(ConsumerApplication.class, args);
}
}
3 增加 HelloService 类
package com.didispace.web;
import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand;
import org.apache.log4j.Logger;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.ResponseEntity;
import org.springframework.stereotype.Service;
import org.springframework.web.client.RestTemplate;
import org.springframework.web.util.UriComponents;
import org.springframework.web.util.UriComponentsBuilder;
import java.net.URI;
import java.util.HashMap;
import java.util.Map;
@Service
public class HelloService {
@Autowired
RestTemplate restTemplate;
//使用 @HystrixCommand 注解指定回调方法
@HystrixCommand(fallbackMethod = "helloFallback")
public String hello() {
return restTemplate.getForEntity("http://HELLO-SERVICE/hello", String.class).getBody();
}
public String helloFallback() {
return "error";
}
}
4 控制器类编写
package com.didispace.web;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;
@RestController
public class ConsumerController {
@Autowired
HelloService helloService;
@RequestMapping(value = "/ribbon-consumer", method = RequestMethod.GET)
public String helloConsumer() {
return helloService.hello();
}
}
测试
==
1 启动 Eureka、启动 2 个 Hello-Service 服务，启动 1 个 ribbon-consumer 服务
2 访问 http://localhost:9000/ribbon-consumer
并且 Hello-Service 两个服务轮询
3 关闭其中一个服务
4 访问 http://localhost:9000/ribbon-consumer
浏览器结果为如下，结果轮询，说明回退生效。
error
或者
Hello World
Hystrix 是如何工作的
================
第 1 步 创建 HystrixCommand 或 HystrixObservableCommand 对象
首先，构建一个 HystrixCommand 或 HystrixObservableCommand 对象，用来表示对依赖服务的操作请求，同时传递所有需要的参数。这两个对象都采用了命令模式来实现对服务调用操作的封装，但是这两个对象分别针对不同的应用场景。
HystrixCommand: 用在依赖的服务返回单个操作结果的时候
HystrixObservableCommand: 用在依赖的服务返回多个操作结果的时候
命令模式，将来自客户端的请求封装成一个对象，从而让你可以使用不同的请求对客户端进行参数化。它可以用于实现行为请求者和行为实现者的解耦，以便使两者可以适应变化
命令模式的示例代码在 command 模块下
通过命令模式的示例代码可以分析出命令模式的几个关键点：
Receiver: 接收者，处理具体的业务逻辑
Command: 抽象命令，定义了一个对象应具备的一系列命令操作，如 execute()、undo()、redo()等。当命令操作被调用的时候就会触发接收者做具体命令对应的业务逻辑。
ConcreteCommand: 具体的命令实现，在这里要绑定命令操作和接收者之间的关系，execute()命令的实现转交给了 Receiver 的 action()方法
Invoker: 调用者，它拥有一个命令对象，可以在需要时通过命令对象完成具体的业务逻辑
命令模式中 Invoker 和 Receiver 的关系非常类似于请求-响应模式，所以它比较适用于实现记录日志、撤销操作、队列请求等。
以下情况我们可以考虑使用命令模式:
使用命令模式作为回调在面向对象系统中的替代。
需要在不同的时间指定请求、将请求排队。一个命令对象和原先的请求发出者可以有不同的生命周期。换言之，原先的请求发出者可能已经不在了，但是命令本身仍然是活动的。这时命令的接收者可以是在本地，也可以在网络的另一个地址。命令对象可以在序列化之后传送到另一台机器上。
系统需要支持命令的撤销。命令对象可以把状态存储起来，等到客户端需要撤销命令所产生的效果时，可以调用 undo()方法，把命令所产生的效果撤销掉。命令对象还提供 redo()方法，以供客户端在需要时再重新实施命令效果。
如果要将系统中所有的数据更新到日志里，以便在系统崩溃时，可以根据日志读回所有的数据更新命令，重新调用 execute()方法一条一条执行这些命令，从而恢复系统在崩溃前所做的数据更新。
第 2 步 命令执行
从图中我们可以看到一共存在 4 种命令的执行方式，Hystrix 在执行时会根据创建的 Command 对象以及具体的情况来选择一个执行。
HystrixCommand
HystrixCommand 实现了两个执行方式：
execute(): 同步执行，从依赖的服务返回一个单一的结果对象，或是在错误时抛出异常
queue(): 异步执行，直接返回一个 Future 对象，其中包含了服务执行结束时要返回的单一结果对象。
R value = command.execute();
Future<R> fValue = command.queue();
HystrixObservableCommand
HystrixObservableCommand 实现了另两种执行方式:
observer(): 返回 Observable 对象，它代表了操作的多个结果，是一个 HotObservable
toObservable(): 同样返回 Observable 对象，也代表操作的多个结果，返回的是一个 ColdObservable
Observable<R> ohvalue = command.observe();
Observable<R> ocvalue = command.toObservable();
Hot Observable 和 Cold Observable，分别对应了上面 command.observe()和 command.toObservable 的返回对象。
Hot Observable，不论事件源是否有订阅者，都会在创建后对事件进行发布，所以对 Hot Observable 的每一个订阅者都有可能是从事件源的中途开始的，并可能只是看到了整个操作的局部过程。
Cold Observable 在没有订阅者的时候不会发布事件，而是进行等待，直到有订阅者后才会发布事件，所以对于 Cold Observable 的订阅者，它可以保证从一开始看到整个操作的全部过程。
HystrixCommand 也使用 RxJava 实现：
execute():该方法是通过 queue()返回的异步对象 Future<R>的 get()方法来实现同步执行的。该方法会等待任务执行结束，然后获得 R 类型的结果返回。
queue():通过 toObservable()获得一个 Cold Observable，并且通过通过 toBlocking()将该 Observable 转换成 BlockingObservable，它可以把数据以阻塞的方式发出来，toFuture 方法则是把 BlockingObservable 转换为一个 Future，该方法只是创建一个 Future 返回，并不会阻塞，这使得消费者可以自己决定如何处理异步操作。execute()则是直接使用了 queue()返回的 Future 中的阻塞方法 get()来实现同步操作的。
通过这种方式转换的 Future 要求 Observable 只发射一个数据，所以这两个实现都只能返回单一结果。
RxJava 观察者-订阅者模式入门介绍
在 Hystrix 的底层实现中大量使用了 RxJava。上面提到的 Observable 对象就是 RxJava 的核心内容之一，可以把 Observable 对象理解为事件源或是被观察者，与其对应的是 Subscriber 对象，可以理解为订阅者或是观察者。
Observable 用来向订阅者 Subscriber 对象发布事件，Subscriber 对象在接收到事件后对其进行处理，这里所指的事件通常就是对依赖服务的调用。
一个 Observable 可以发出多个事件，直到结束或是发生异常。
Observable 对象每发出一个事件，就会调用对应观察者 Subscriber 对象的 onNext()方法。
每一个 Observable 的执行，最后一定会通过调用 Subscriber.onCompleted()或是 Subscriber.onError()来结束该事件的操作流。
第 3 步 结果是否被缓存
若当前命令的请求缓存功能是被启用的，并且该命令缓存命中，那么缓存的结果会立即以 Observable 对象的形式返回。
第 4 步 断路器是否打开
在命令结果没有缓存命中的时候，Hystrix 在执行命令前需要检查断路器是否为打开状态:
如果断路器是打开的，Hystrix 不会执行命令，而是直接赚到 fallback 处理逻辑(对应下面第 8 步)
如果断路器是关闭的，那么 Hystrix 会跳到第 5 步，检查是否有可用资源来执行命令。
第 5 步 线程池/请求队列/信号量是否占满
如果与命令相关的线程池和请求队列或者信号量(不使用线程池的时候)已被占满，那么 Hystrix 不会执行命令，转接到 fallback 处理逻辑(对应下面第 8 步)
Hystrix 所判断的线程池并非容器的线程池，而是每个依赖服务的专有线程池。Hystrix 为了保证不会因为某个依赖服务的问题影响到其他依赖服务而采用了舱壁模式来隔离每个依赖的服务。
第 6 步 HystrixObservableCommand.construct()或 HystrixCommand.run()
Hystrix 会根据我们编写的方法来决定采取什么样的方式去请求依赖服务:
HystrixCommand.run(): 返回一个单一的结果，或者抛出异常
HystrixObservableCommand.construct(): 返回一个 Observable 对象来发射多个结果，或通过 onError 发送错误通知
如果 run()或 construct()方法的执行时间超过了命令设置的超时阀值，当前处理线程会抛出一个 TimeoutException(如果该命令不在其自身的线程中执行，则会通过单独的计时线程抛出)。在这种情况下，Hystrix 会转到 fallback 逻辑去处理(第 8 步)。同时，如果当前命令没有被取消或中断，那么它最终会忽略 run()或 construct()方法的返回。
如果命令没有抛出异常并返回了结果，那么 Hystrix 在记录一些日志并采集监控报告之后将该结果返回。在使用 run()时，返回一个 Observable，它会发射单个结果并产生 onCompleted 的结束通知，在使用 construct()时，会直接返回该方法产生的 Observable 对象。
第 7 步 计算断路器的健康度
Hystrix 会将成功、失败、拒绝、超时等信息报告给断路器，断路器会维护一组计数器来统计这些数据。
断路器会使用这些统计数据来决定是否要将断路器打开，来对某个依赖服务的请求进行熔断/短路，直到恢复期结束。若在恢复期结束后，根据统计数据判断如果还是未达到健康指标，就再次熔断/短路。
第 8 步 fallback 处理
当命令执行失败时，Hystrix 会进入 fallback 尝试回退处理，我们通常也称之为服务降级。能够引起服务降级处理的情况主要有以下几种:
第 4 步，当前命令处于熔断/短路状态，断路器是打开的时候。
第 5 步，当前命令的线程池、请求队列或者信号量被占满的时候。
第 6 步，HystrixObservableCommand.construct()或 HystrixCommand.run()抛出异常的时候。
在服务降级逻辑中，我们需要实现一个通用的响应结果，并且该结果的处理逻辑应当是从缓存或是根据一些静态逻辑来获取，而不是依赖网络请求获取。如果一定要在降级逻辑中包含网络请求，那么该请求也必须被包装在 HystrixCommand 或是 HystrixObservableCommand 中，从而形成级联的降级策略，而最终的降级逻辑一定不是一个依赖网络请求的处理，而是一个能够稳定返回结果的处理逻辑。
HystrixCommand 和 HystrixObservableCommand 中实现降级逻辑时有以下不同:
评论