如何对 javanica @HystrixCommand 注释方法进行单元测试？

Question

我正在使用 javanica 并像这样注释我的 hystrix 命令方法：

@HystrixCommand(groupKey="MY_GROUP", commandKey="MY_COMMAND" fallbackMethod="fallbackMethod")
public Object getSomething(Object request) {
....

我正在尝试对我的回退方法进行单元测试，而不必直接调用它们，即我想调用 @HystrixCommand 注释方法并让它在抛出 500 错误后自然地进入回退.这一切都在单元测试之外工作。

在我的单元测试中，我使用弹簧 MockRestServiceServer 到 return 500 个错误，这部分工作正常，但 Hystrix 在我的单元测试中没有正确初始化。在我的测试方法开始时，我有：

HystrixRequestContext context = HystrixRequestContext.initializeContext();
myService.myHystrixCommandAnnotatedMethod();

在此之后，我试图通过按键获取任何 hystrix 命令并检查是否有任何已执行的命令但列表始终为空，我正在使用此方法：

public static HystrixInvokableInfo<?> getHystrixCommandByKey(String key) {
    HystrixInvokableInfo<?> hystrixCommand = null;
    System.out.println("Current request is " + HystrixRequestLog.getCurrentRequest());
    Collection<HystrixInvokableInfo<?>> executedCommands = HystrixRequestLog.getCurrentRequest()
            .getAllExecutedCommands();
    for (HystrixInvokableInfo<?> command : executedCommands) {
        System.out.println("executed command is " + command.getCommandGroup().name());
        if (command.getCommandKey().name().equals(key)) {
            hystrixCommand = command;
            break;
        }
    }
    return hystrixCommand;
}

我意识到我在单元测试初始化中遗漏了一些东西，任何人都可以指出正确的方向，告诉我如何正确地对其进行单元测试吗？

Answer 1

Hystrix 是您接受的功能性工具，很像 Spring 是您接受的功能性工具。您不需要对 Hystrix 调用回退方法的能力进行单元测试。

您应该通过在单元测试中直接调用回退方法来对其进行单元测试。

也就是说，当你希望 Hystrix 调用 fallback 方法时，你很可能想测试 Hystrix 是否真的在调用 fallback 方法；这不是单元测试，这将是一个集成测试。

虽然可以使用 jUnit 编写许多集成测试， Hystrix 显然不想参与 jUnit 测试。

我建议您将应用程序安装在开发 and/or qa 测试环境中，并通过在运行系统上强制回退来测试 Hystrix 回退功能。

Answer 2

尽管您不一定要 UNIT 测试 hystrix 命令。进行某种 spring 混合测试仍然很有用，我认为在添加注释时直接接受功能是不正确的。我创建的测试确保断路器在异常时打开。

@RunWith(SpringRunner.class)
@SpringBootTest
public class HystrixProxyServiceTests {

    @MockBean
    private MyRepo myRepo;

    @Autowired
    private MyService myService;

    private static final String ID = “1”;

    @Before
    public void setup() {
        resetHystrix();
        openCircuitBreakerAfterOneFailingRequest();
    }

    @Test
    public void circuitBreakerClosedOnSuccess() throws IOException, InterruptedException {

        when(myRepo.findOneById(USER_ID1))
        .thenReturn(Optional.of(Document.builder().build()));

        myService.findOneById(USER_ID1);
        HystrixCircuitBreaker circuitBreaker = getCircuitBreaker();
        Assert.assertTrue(circuitBreaker.allowRequest());

        verify(myRepo, times(1)).findOneById(
            any(String.class));
    }

    @Test
    public void circuitBreakerOpenOnException() throws IOException, InterruptedException {

        when(myRepo.findOneById(ID))
            .thenThrow(new RuntimeException());

        try {
            myService.findOneById(ID);
        } catch (RuntimeException exception) {
            waitUntilCircuitBreakerOpens();
            HystrixCircuitBreaker circuitBreaker = getCircuitBreaker();
            Assert.assertFalse(circuitBreaker.allowRequest());
        }

        verify(myRepo, times(1)).findOneById(
            any(String.class));
    }

    private void waitUntilCircuitBreakerOpens() throws InterruptedException {
        Thread.sleep(1000);
    }

    private void resetHystrix() {
        Hystrix.reset();
    }

    private void warmUpCircuitBreaker() {
        myService.findOneById(USER_ID1);
    }

    public static HystrixCircuitBreaker getCircuitBreaker() {
        return HystrixCircuitBreaker.Factory.getInstance(getCommandKey());
    }

    private static HystrixCommandKey getCommandKey() {
        return HystrixCommandKey.Factory.asKey("findOneById");
    }

    private void openCircuitBreakerAfterOneFailingRequest() {

        ConfigurationManager.getConfigInstance().
            setProperty("hystrix.command.findOneById.circuitBreaker.requestVolumeThreshold", 1);
    }

}

另一件让我困惑了一段时间的小事是我输入了没有特定命令键的默认注释，但是当创建命令键时，它们是根据我指定的方法名称创建的多于。对于一个完整的示例，我还添加了注释以表明我没有指定 commandKey。

@HystrixCommand
public Optional<Document> findOneById(final String id) {
    return this.myRepo.findOneById(id);
}

希望这对某人有所帮助。

Answer 3

有一个问题我已经运行解决了几次：如果包装方法的方法签名发生变化，则没有编译时间或 bootstrap 检查回退方法是否仍然可调用.因此，如果一个 int arg 更改为一个 String，而我忘记更改回退方法的签名，直到应用程序运行ning 并调用包装方法我才会知道。

Answer 4

可能来不及了.. 但是您可以在代码运行之前使用该方法实例化一个

我是这样做的

public void warmUpCircuitBreaker() {
    HystrixCommandKey commandKey= HystrixCommandKey.Factory.asKey("test");
    HystrixCommandProperties.Setter setter = HystrixCommandProperties.defaultSetter();


    HystrixPropertiesCommandDefault hystrixPropertiesCommandDefault = new HystrixPropertiesCommandDefault(commandKey, setter);
    HystrixCommandGroupKey test = HystrixCommandGroupKey.Factory.asKey("Test");
    HystrixCircuitBreaker.Factory.getInstance(commandKey,
            test,
            hystrixPropertiesCommandDefault,
            HystrixCommandMetrics.getInstance(commandKey, test, hystrixPropertiesCommandDefault));

}

在调用 SUT 之前调用此方法您也可以设置所有必需的属性

在我的测试中我正在设置属性以测试不同的场景

 ConfigurationManager.getConfigInstance()
            .setProperty("hystrix.command.test.circuitBreaker.forceClosed",
                    true);

如何对 javanica @HystrixCommand 注释方法进行单元测试？

How can I unit-test javanica @HystrixCommand annotated methods?

java

unit-testing

annotations

hystrix

mockrestserviceserver