«Интеграция Hystrix с существующим приложением Spring»

«1. Обзор

В прошлой статье мы рассмотрели основы Hystrix и то, как он может помочь в создании отказоустойчивого и отказоустойчивого приложения.

Существует множество существующих приложений Spring, которые выполняют вызовы во внешние системы, которые выиграют от Hystrix. К сожалению, может оказаться невозможным переписать эти приложения для интеграции Hystrix, однако возможен неинвазивный способ интеграции Hystrix с помощью Spring AOP.

В этой статье мы рассмотрим, как интегрировать Hystrix с существующим приложением Spring.

2. Превращение Hystrix в Spring-приложение

2.1. Существующее приложение

Давайте взглянем на существующий вызывающий клиент приложения, который вызывает RemoteServiceTestSimulator, созданный нами в предыдущей статье: для выполнения вызовов удаленной службы RemoteServiceTestSimulator. Конечно, приложения реального мира не будут такими простыми.

@Component("springClient")
public class SpringExistingClient {

    @Value("${remoteservice.timeout}")
    private int remoteServiceDelay;

    public String invokeRemoteServiceWithOutHystrix() throws InterruptedException {
        return new RemoteServiceTestSimulator(remoteServiceDelay).execute();
    }
}

2.2. Создайте Around Advice

Чтобы продемонстрировать, как интегрировать Hystrix, мы будем использовать этот клиент в качестве примера.

Для этого мы определим совет Around, который сработает, когда будет выполнен invokeRemoteService.

Теперь давайте посмотрим на определение аннотации HystrixCircuitBreaker:

@Around("@annotation(com.baeldung.hystrix.HystrixCircuitBreaker)")
public Object circuitBreakerAround(ProceedingJoinPoint aJoinPoint) {
    return new RemoteServiceCommand(config, aJoinPoint).execute();
}

2.3. Логика Hystrix

Теперь давайте посмотрим на RemoteServiceCommand. Он реализован как статический внутренний класс в примере кода, чтобы инкапсулировать логику вызова Hystrix:

@Retention(RetentionPolicy.RUNTIME)
@Target(ElementType.METHOD)
public @interface HystrixCircuitBreaker {}

Всю реализацию компонента Aspect можно увидеть здесь.

2.4. Аннотировать с помощью @HystrixCircuitBreaker

private static class RemoteServiceCommand extends HystrixCommand<String> {

    private ProceedingJoinPoint joinPoint;

    RemoteServiceCommand(Setter config, ProceedingJoinPoint joinPoint) {
        super(config);
        this.joinPoint = joinPoint;
    }

    @Override
    protected String run() throws Exception {
        try {
            return (String) joinPoint.proceed();
        } catch (Throwable th) {
            throw new Exception(th);
        }
    }
}

Как только аспект определен, мы можем аннотировать наш клиентский метод с помощью @HystrixCircuitBreaker, как показано ниже, и Hystrix будет вызываться при каждом вызове аннотированных методов:

Приведенный ниже интеграционный тест продемонстрирует разница между маршрутом Hystrix и маршрутом не Hystrix.

2.5. Протестируйте интеграцию

@HystrixCircuitBreaker
public String invokeRemoteServiceWithHystrix() throws InterruptedException{
    return new RemoteServiceTestSimulator(remoteServiceDelay).execute();
}

В целях демонстрации мы определили два маршрута выполнения методов: один с Hystrix, а другой без него.

Когда тест выполняется, вы можете видеть, что вызов метода без Hystrix будет ожидать все время выполнения удаленной службы, тогда как маршрут Hystrix замкнется и вызовет HystrixRuntimeException после определенного тайм-аута, который в нашем случае составляет 10 секунд.

3. Заключение

public class SpringAndHystrixIntegrationTest {

    @Autowired
    private HystrixController hystrixController;

    @Test(expected = HystrixRuntimeException.class)
    public void givenTimeOutOf15000_whenClientCalledWithHystrix_thenExpectHystrixRuntimeException()
      throws InterruptedException {
        hystrixController.withHystrix();
    }

    @Test
    public void givenTimeOutOf15000_whenClientCalledWithOutHystrix_thenExpectSuccess()
      throws InterruptedException {
        assertThat(hystrixController.withOutHystrix(), equalTo("Success"));
    }
}

Мы можем создать один аспект для каждого вызова удаленной службы, который мы хотим сделать с различными конфигурациями. В следующей статье мы рассмотрим интеграцию Hystrix с самого начала проекта.

Весь код этой статьи можно найти в репозитории GitHub.

«

All code in this article can be found in the GitHub repository.