用户将命令通过Hytrix调用(通过继承HystrixCommand),通过Hystrix实现对调用异常的控制,以此来隔离被调用方对调用方的影响。
如果某程序或class要使用Hystrix,只需简单继承HystrixCommand/HystrixObservableCommand
并重写run()/construct()
,然后调用程序实例化此class并执行execute()/queue()/observe()/toObservable()
// HelloWorldHystrixCommand要使用Hystrix功能
public class HelloWorldHystrixCommand extends HystrixCommand { private final String name; public HelloWorldHystrixCommand(String name) {
super(HystrixCommandGroupKey.Factory.asKey("ExampleGroup"));
this.name = name;
}
// 如果继承的是HystrixObservableCommand,要重写Observable construct()
@Override protected String run() {
return "Hello " + name;
}
}
/* 调用程序对HelloWorldHystrixCommand实例化,执行execute()即触发HelloWorldHystrixCommand.run()的执行 */
String result = new HelloWorldHystrixCommand("HLX").execute();
System.out.println(result); // 打印出Hello HLX