0

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

有一个“ServiceClass”，其中注入了一些 RestClient 类。我正在使用弹簧。现在，我想将 Hystrix 与 Spring AOP 一起使用，以便从 ServiceClass 对 RestClient 的方法调用可以同步或异步进行。

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

创建了一个扩展 HystrixCommand 实现 MethodInterceptor 的类“MyCommand”

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

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

在（覆盖方法）“调用”中

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

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

现在，问题是；在我的“主”应用程序中，当我从 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();

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

一如既往，提前感谢

4

1 回答 1

2

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

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

MyHystrixCommand command = new MyHystrixCommand();

command.execute();

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

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

于 2015-07-22T19:05:38.400 回答