与Hystrix的异常

Question

我是海斯特里克斯的新手。我正在尝试将它与Spring AOP一起使用。以下详细说明了我正在努力实现的目标。

有一个“ServiceClass”，其中注入了一些RestClient类。我用的是Spring。现在，我想将Hystrix与SpringAOP结合使用，以便可以同步或异步地从ServiceClass调用RestClient方法。

到目前为止，我所做的工作如下。

创建了一个类“我的命令”，它扩展了Hystrix命令实现了方法拦截器

在其中实现了一个方法“execute”（MethodInvocation m，String模式），如下所示：

                      protected Object execute(MethodInvocation m, String mode){
                      this.mode = mode;
                      this.method = m;
                      return execute();}

在（重写的方法）“invoke”中

                       public Object invoke(MethodInvocation m) throws throwable{
                         try{
                              execute(m,"Sync");
                         } catch(Exception e){
                             e.printStackTrace();
                         }
                        }

这个“MyCommand”被设置为spring配置文件中“ServiceClass”的AOP拦截器。

现在，问题是；在我的“主”应用程序中，当我从ClassPathXmlApplication ationContext检索“ServiceClass”并调用一个方法时，它工作正常。但是，如果我尝试调用"ServiceClass"的两个方法，它会引发以下异常：

              *java.lang.IllegalStateException: This instance can only be executed once. Please instantiate a new instance.*

代码段：

              ServiceClass srvc = (ServiceClass) ctx.getBean("proxy");
              srvc.getRequest();
              srvc.postRequest(); 

我花了将近三天的时间试图找出这个异常的原因和解决方案，但没有任何好处。请帮我把这个弄对。我错过了什么？

和往常一样，先谢谢你

Answer 1

HystrixRE对象只能使用一次，因为它在执行后包含有用的状态信息，可用于进一步处理。例如，如果您想在调用run（）超时后进行特殊处理，您可以执行以下操作：

public class MyHystrixCommand extends HystrixCommand<Object> { ... }

MyHystrixCommand command = new MyHystrixCommand();

command.execute();

if(command.isResponseTimedOut()){
    //do post processing
}

如果您可以多次调用执行（），特别是从多个线程调用，如果您的REST终结点有多个消费者，您将无法知道在查询其命令时哪个调用超时状态。