Hystrix 的 IllegalStateException

Question

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

有一个"ServiceClass"，其中注入了一些RestClientclass。我正在使用 Spring。现在，我想将 Hystrix 与 Spring AOP 一起使用，以便可以同步或异步地从 ServiceClass 调用 RestClient 的方法。

我目前所做的如下。

创建了一个 class "MyCommand" 扩展 HystrixCommand 实现 MethodInterceptor

在其中实现了一个方法“execute(MethodInvocation m, String mode)”如下：

                      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-config 文件中 "ServiceClass" 的 AOP 拦截器。

现在，问题是；在我的 "Main" 应用程序中，当我从 ClassPathXmlApplicationContext 检索 "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

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

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

MyHystrixCommand command = new MyHystrixCommand();

command.execute();

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

如果您可以多次调用 execute()，尤其是从多个线程调用（如果您的 REST 端点有多个使用者），您将无法知道哪个调用超时了您查询命令的状态。

Hystrix 的 IllegalStateException

IllegalStateException with Hystrix

java

spring-aop

hystrix