Spring Cloud Feign 之Hystrix

环境信息: java 1.8、Spring boot 1.5.10.RELEASE、spring cloud-Edgware.SR3、maven 3.3+

本章节只针对Hystrix在Feign中的简单实用，和一些简单的源码分析，更详细的请参考GitHub官网

Fallback章节已经简单的介绍了Hystrix的熔断保护使用，这章将介绍HystrixCommand、Observable、Single、Completable这四种异步HTTP请求方式。

那么Hystrix为什么可以支持者四种异步HTTP请求方式，其实很简单通过一段源码就可以看出

HystrixDelegatingContract.parseAndValidatateMetadata方法的四个if else判断分别对应四个类

package feign.hystrix;
import static feign.Util.resolveLastTypeParameter;
import java.lang.reflect.ParameterizedType;
import java.lang.reflect.Type;
import java.util.List;
import com.netflix.hystrix.HystrixCommand;
import feign.Contract;
import feign.MethodMetadata;
import rx.Completable;
import rx.Observable;
import rx.Single;
/**
* This special cases methods that return {@link HystrixCommand}, {@link Observable}, or {@link Single} so that they
* are decoded properly.
*
* <p>For example, {@literal HystrixCommand<Foo>} and {@literal Observable<Foo>} will decode {@code Foo}.
*/
// Visible for use in custom Hystrix invocation handlers
public final class HystrixDelegatingContract implements Contract {
private final Contract delegate;
public HystrixDelegatingContract(Contract delegate) {
this.delegate = delegate;
}
@Override
public List<MethodMetadata> parseAndValidatateMetadata(Class<?> targetType) {
List<MethodMetadata> metadatas = this.delegate.parseAndValidatateMetadata(targetType);
for (MethodMetadata metadata : metadatas) {
Type type = metadata.returnType();
if (type instanceof ParameterizedType && ((ParameterizedType) type).getRawType().equals(HystrixCommand.class)) {
Type actualType = resolveLastTypeParameter(type, HystrixCommand.class);
metadata.returnType(actualType);
} else if (type instanceof ParameterizedType && ((ParameterizedType) type).getRawType().equals(Observable.class)) {
Type actualType = resolveLastTypeParameter(type, Observable.class);
metadata.returnType(actualType);
} else if (type instanceof ParameterizedType && ((ParameterizedType) type).getRawType().equals(Single.class)) {
Type actualType = resolveLastTypeParameter(type, Single.class);
metadata.returnType(actualType);
} else if (type instanceof ParameterizedType && ((ParameterizedType) type).getRawType().equals(Completable.class)) {
metadata.returnType(void.class);
}
}
return metadatas;
}
}

这里使用了委派模式，具体工作给委派对象，实际就是SpringMvcContract，它负责处理spring MVC 注解方式声明的Feign接口，所以需要SpringMvcContract。

HystrixCommand

Hystrix命令模式，在这里不做深度剖析有兴趣的同学可以到GitHub官网查看，只针对对在Feign中是如何使用的。

其实在Feign中使用很简单，HystrixCommand是一个泛型的抽象类，只需在返回类型指定泛型的类型即可

如：HystrixCommand<List<User>>指定List<User>泛型即可

UserFeign.findAll:

@GetMapping
HystrixCommand<List<User>> findAll();

是不是很简单,那么HystrixCommand如何使用呢，下面讲一下两个常用方法

HystrixCommand.execute 直接获取请求结果

这种方式跟java.util.concurrent.Future.get()方法使用方式是一样的。

启动FeignApplication服务提供方

运行单元测试UserFeignTest.save保存两条数据。

UserFeignTest.findAll ，直接将结果打印

@Test
public void findAll() {
HystrixCommand<List<User>> userList = userFeign.findAll();
//直接获取结果，这块可以处理一些业务逻辑，最后需要userList数据调用execute方法
System.out.println(userList.execute());
}

[User{id='1', name='张三1'}, User{id='2', name='张三2'}]

HystrixCommand.observe或toObservable 观察者模式(订阅发布)

observe() 是 Hot observables ，toObservable()是 Cold observables

Hot observables

Hot observable 不管有没有订阅者订阅，他们(发布者/生产者)创建后就开发发射数据流。

Cold observables

只有当有订阅者订阅的时候， Cold Observable 才开始执行发射数据流的代码。

更多请参考Reactive Execution 或 RxJava 驯服数据流之 hot & cold Observable

Observable<List<User>> listObservable = userList.observe();
Observable<List<User>> listObservable = userList.toObservable();

接下来讲下 Observable使用

Observable观察者模式(订阅发布)

Feign接口的方法返回类型也可以是Observable<T>泛型类型可以是任意类型，我们这里以Observable<User>为例

由于Hystrix是异步，会出现主线程结束后Hystrix线程同时杀死，导致结果无法打印，在订阅之后添加TimeUnit.SECONDS.sleep(2)使主线程睡眠2秒钟。

UserFeign.getUserByID,其他内容省略

@GetMapping("/{id}")
Observable<User> getUserByID(@PathVariable("id") String id);

如果对结果集处理，只需订阅Observable<User>

Observable<User> user = userFeign.getUserByID("1");
user.subscribe(new Observer<User>() {
/**
* 数据发射完成时执行与{@link #onError(Throwable)} 它俩只会执行其中一个方法
*/
@Override
public void onCompleted() {
System.out.println("user处理完成");
}
/**
* 发生错误时执行与{@link #onCompleted()} 它俩只会执行其中一个方法
*/
@Override
public void onError(Throwable e) {
System.out.println("user出现异常" + e);
}
/**
* 发射数据流 user
*/
@Override
public void onNext(User user) {
System.out.println("返回数据：" + user);
}
});

运行单元测试UserFeignTest.getUserByID,输出结果

返回数据：User{id='1', name='张三'}
user处理完成

Single

Observable的订阅者Observer.onNext方法可能执行多次，最后执行Observer.onCompleted或Observer.onError(发生异常的情况下),其实在平时开发过程中大多数情况下Observer.onNext只需执行一次就可以获取到全部结果集，Single的订阅者Observer.onNext方法只会执行一次就完成了。接下来简单介绍下Single的使用

UserFeign.getUserByIDSingle 很简单返回类型指定Single泛型是User即可:

@GetMapping("/{id}")
Single<User> getUserByIDSingle(@PathVariable("id") String id);

运行单元测试UserFeignTest.getUserByIDSingle

Single<User> singleUser = userFeign.getUserByIDSingle("1");
singleUser.subscribe(new Observer<User>() {
@Override
public void onCompleted() {
System.out.println("执行完成");
}
@Override
public void onError(Throwable e) {
System.out.println("执行错误" + e);
}
@Override
public void onNext(User user) {
System.out.println("返回数据：" + user);
}
});

输出结果：

返回数据：User{id='1', name='张三'}
执行完成

Single订阅者Observer.onNext方法只会执行一次，其实Observer.onCompleted方法没有什么作用，再加上我们有的时候不需要处理错误Observer.onError，这样我们就可以简化代码了

简化后的代码：

Single<User> singleUser = userFeign.getUserByIDSingle("1");
singleUser.subscribe(System.out::println);

Completable

CompletableHTTP客户端只需知道请求成功或失败，不需要返回的数据时使用。

这里以保存为例UserFeign.save

单元测试UserFeignTest.save

单元测试UserFeignTest.save完成处理

User user = new User();
user.setName("张三4");
Completable completable = userFeign.save(user);
completable.subscribe(() -> System.out.println("保存成功"));

单元测试UserFeignTest.save同步请求阻塞，异常处理，如果没有异常throwable==null

User user = new User();
user.setName("张三4");
Completable completable = userFeign.save(user);
//
completable.subscribe(() -> System.out.println("保存成功"));
Throwable throwable = completable.get();
System.out.println("异常信息："+throwable);

总结

本章节讲了如下内容

Spring Cloud Feign HTTP请求异常Fallback容错机制，它是基于Hystrix实现的，所以要通过配置参数feign.hystrix.enabled=true开启该功能，及其两种实现方式。

Fallback工厂方式引出了ErrorDecoder错误解码自定义处理，有三种方式，可根据实际请求选择，举一反三其他自定义配置也可以通过这种方式实现如：Decoder、Encoder、Logger(第二、三章有介绍)。

如果开启的Hystrix就不要用feign的超时配置了,单位是毫秒

feign.client.config.defalut.connect-timeout=10000

defalut是默认配置名称，可以使用feign.client.default-config替换自定义名称

feign.client.default-config=my-config
feign.client.config.my-config.connect-timeout=10000

请使用如下属性配置超时时间，单位毫秒

hystrix.command.default.execution.isolation.thread.timeoutInMilliseconds=20000

样例地址 spring-cloud-feign 分支 Spring-Cloud-Feign-之fallback

写在最后

Spring Cloud Feign 系列持续更新中。。。。。欢迎关注

如发现哪些知识点有误或是没有看懂，请在评论区提出，博主及时改正。

欢迎转载请注明出处。

最后

以上就是忧郁背包为你收集整理的Spring Cloud Feign(第五篇) 之HystrixSpring Cloud Feign 之Hystrix的全部内容，希望文章能够帮你解决Spring Cloud Feign(第五篇) 之HystrixSpring Cloud Feign 之Hystrix所遇到的程序开发问题。

如果觉得靠谱客网站的内容还不错，欢迎将靠谱客网站推荐给程序员好友。