javanica中不在spring-boot java应用程序中运行的Hystrix异步方法

Question

我正在使用spring-cloud-starter（即..带有所有微服务特性的spring boot）。当我在一个使用javanica@hystrixCommand注释的组件中创建hystrix方法时，请按照javanica github站点（https://github.com/netflix/hystrix/tree/master/hystrix-contrib/hystrix-javanica）上的说明使该方法异步运行，不管我是使用它们的“future<>”还是使用反应执行“observable<>”，都不会运行/执行任何东西，并且只要我尝试拉出结果（在future<>的情况下）或获得回调（在反应执行的情况下），就会得到
java.lang.ClassCastException：

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<>队列（）方法执行时，不像文档所说的那样可用；2）使用observable<>执行时，我确实没有方法执行它。




Answer 1

应用程序类上是否有@enablehystrix注释？

subscribe方法是异步的，您正在尝试在同步控制器方法中填充列表，因此可能存在问题。您能否将subscribe更改为ToBlockingObServable().foreach()，看看这是否有帮助？

更新#1我可以复制。默认方法不应返回可观察的 ，而应返回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属性时，它抱怨找不到AOP的ericComponent的公共版本。我使ericcomponentpublic static，它工作了。一个顶级类在它自己的文件中可以工作。上面链接的我的代码可以工作（假设restTemplate调用可以工作），并返回n OK。