hystirx--使用类command说明（1）

文章目录

• 1. Command
• 1.1 参考网址
• 1.2 分类
• 1.2.1 HystrixyCommand
• 1.2.2 HystrixyObservableCommand
• 1.3 执行方法
• execute（）
• queue（）
• observe（）
• toObservable（）
• 1.4 图解

1. Command

1.1 参考网址

[参考网址](https://www.cnblogs.com/cowboys/p/7655829.html

)

1.2 分类

1.2.1 HystrixyCommand

• 实现 T run（）{} 方法

• 返回一条数据

• 执行：execute()、queue()、observe()、toObservable()

• 创建新的线程执行

1.2.2 HystrixyObservableCommand

• 实现 Observable construct(){}方法

• 返回多条数据

• 执行：observe()、toObservable()

• 调用程序线程执行

1.3 执行方法

execute（）

• 同步阻塞，创建新的线程运行

queue（）

• 异步非阻塞，创建新的线程运行，返回fauture对象，通过get()方法获取结果

observe（）

• oberve（）返回observable对象// HystrixCommand创建新线程异步，HystrixObservableCommand调用程序线程堵塞运行

• observable对象subscribe注册事件

• 执行成功则触发onNext()和onCompleted()，如果执行异常则触发onError()

toObservable（）

• toObervable（）返回observable对象

• observable对象subscribe注册事件// HystrixCommand创建新线程异步，HystrixObservableCommand调用程序线程堵塞运行

• 执行成功则触发onNext()和onCompleted()，如果执行异常则触发onError()

1.4 图解