我正在使用 spring-cloud-starter(即具有所有微服务功能的 spring boot)。当我在使用 javanica @HystrixCommand 注释的组件中创建 hystrix 方法时，请按照 javanica github 站点 (https://github.com/Netflix/Hystrix/tree/master/hystrix-contrib/hystrix-javanica) 上的说明使该方法异步运行，无论我是使用它们的“Future<>”还是 Reactive execution“Observable<>'，没有运行/执行，我得到
java.lang.ClassCastException: springbootdemo.EricComponent$1 cannot be cast to springbootdemo.Eric 每当我尝试拉取结果(在 Future<> 的情况下)或获得回调(在 Reactive Execution 的情况下) .. 并且 println 没有触发，所以它真的没有运行)。

public class Application { ...
}
@RestController
@RequestMapping(value = "/makebunchofcalls/{num}")
class EricController { ..

    @RequestMapping(method={RequestMethod.POST})
    ArrayList<Eric> doCalls(@PathVariable Integer num) throws IOException {
        ArrayList<Eric> ale = new ArrayList<Eric>(num);
        for (int i =0; i<num; i++) {
            rx.Observable<Eric> oe = this.ericComponent.doRestTemplateCallAsync(i);
            oe.subscribe(new Action1<Eric>() {
                @Override
                public void call(Eric e) {  // AT RUNTIME, ClassCastException
                    ale.add(e);
                }
            });
        }

        return ale;
    }

@Component
class EricComponent { ...

    // async version =========== using reactive execution via rx library from netflix ==============

    @HystrixCommand(fallbackMethod = "defaultRestTemplateCallAsync", commandKey = "dogeAsync")
    public rx.Observable<Eric> doRestTemplateCallAsync(int callNum) {
        return new ObservableResult<Eric>() {
            @Override
            public Eric invoke() {  // NEVER CALLED
                try {
                    ResponseEntity<String> result = restTemplate.getForEntity("http://doges/doges/24232/photos", String.class);  // actually make a call
                    System.out.println("*************** call successfull: " + new Integer(callNum).toString() + " *************");
                } catch (Exception ex) {
                    System.out.println("=============== call " + new Integer(callNum).toString() + " not successfull: " + ex.getMessage() + " =============");
                }
                return new Eric(new Integer(callNum).toString(), "ok");
            }
        };
    }

    public rx.Observable<Eric> defaultRestTemplateCallAsync(int callNum) {
        return new ObservableResult<Eric>() {
            @Override
            public Eric invoke() {
                System.out.println("!!!!!!!!!!!!! call bombed " + new Integer(callNum).toString() + "!!!!!!!!!!!!!");
                return new Eric(new Integer(callNum).toString(), "bomb");
            }
        };
    }
}

为什么我要取回 EricComponent$1 而不是 Eric？顺便说一句，Eric 只是一个带有 2 个字符串的简单类……它被省略了。

我认为我必须显式执行，但这暗示了我，因为:1) 使用 Future<> 执行此操作，queue() 方法不可用，如文档所述，以及 2) 使用 Observable<> 执行此操作真的不是我得到的执行它的方法。

最佳答案

你有@EnableHystrix吗？你的应用程序类上的注释？

subscribe方法是异步的，并且您正尝试在同步 Controller 方法中填充列表，因此那里可能存在问题。你能改变subscribe吗？至 toBlockingObservable().forEach()看看是否有帮助？

更新#1 我能够复制。您的默认方法不应返回 Observable<Eric> , 只是一个 Eric .

public Eric defaultRestTemplateCallAsync(final int callNum) {
    System.out.println("!!!!!!!!!!!!! call bombed " + new Integer(callNum) + "!!!!!!!!!!!!!");
    return new Eric(new Integer(callNum).toString(), "bomb");
}

更新#2 在这里查看我的代码 https://github.com/spencergibb/communityanswers/tree/so26372319

更新#3 当我注释掉 fallbackMethod属性，它提示找不到 EricComponent 的公共(public)版本对于 AOP。我做了 EricComponent public static它奏效了。自己文件中的顶级类将起作用。上面链接的我的代码有效(假设 restTemplate 调用有效)并返回 n OK .

关于java - javanica 中的 Hystrix 异步方法未在 spring-boot java 应用程序中运行，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/26372319/