Создание собственных приложений для облачной среды Spring — часть 5

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

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

Как владелец сервиса, мы хотим оградить себя от проблем в наших зависимых сервисах, так как мы это делаем? Одним из решений является использование шаблона автоматического выключателя, который был представлен Майклом Найгардом в его книге « Освободи его» .

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

В мире Netflix и Spring Cloud инструмент для реализации автоматических выключателей называется Hystrix . Давайте посмотрим, как мы защищаем вызовы удаленных служб в нашем приложении с помощью Hystrix.

Добавление автоматических выключателей в наш код

В нашем приложении есть 2 места, где один сервис вызывает другой сервис. Первое, что должно прийти в голову, — это то, где мы используем прокси Zuul (из части 2  этого урока). Прокси Zuul используется в нашем веб-приложении для передачи наших вызовов JavaScript из нашего веб-приложения на другие микросервисы. К счастью, Spring Cloud автоматически защищает все эти звонки с помощью автоматических выключателей, поэтому мы ничего не должны делать

Другой удаленный вызов, который мы делаем в нашем приложении, включает API, который мы добавили для мобильных клиентов в последнем сообщении в блоге . В этом API мы делаем запрос в службу Участников из нашей службы Races. Если по какой-либо причине наша служба Участников не работает или не отвечает достаточно быстро, наша Служба Гонок пострадает. Вместо того чтобы прерывать работу нашего сервиса Races из-за проблем со службой участников, мы можем защитить удаленный вызов с помощью автоматического выключателя и фактически вернуть что-то нашим клиентам, даже если есть проблема со службой участников. То, чем мы отвечаем, может быть не идеальным или иметь всю информацию, которая нужна нашим клиентам, но это лучше, чем сбой вызова или тайм-аут. Давайте посмотрим, как мы используем Hystrix в нашем сервисе Races.

Чтобы использовать Hystrix, нам нужно добавить зависимость Hystrix в наш сервис Races. Откройте файл POM для службы Races и добавьте следующую зависимость в раздел зависимостей.

<dependency>
  <groupId>org.springframework.cloud</groupId>
  <artifactId>spring-cloud-starter-hystrix</artifactId>
</dependency>

@SpringBootApplication
@RestController
@EnableEurekaClient 
@EnableFeignClients
@EnableCircuitBreaker
public class OcrRacesApplication implements CommandLineRunner {
    
    private static List<Race> races = new ArrayList<Race>();
    @Autowired
    private ParticipantsBean participantsBean;

    public static void main(String[] args) {
        SpringApplication.run(OcrRacesApplication.class, args);
    }

    @Override
    public void run(String... arg0) throws Exception {
        races.add(new Race("Spartan Beast", "123", "MA", "Boston"));
        races.add(new Race("Tough Mudder RI", "456", "RI", "Providence"));
    }
    
    @RequestMapping("/")
    public List<Race> getRaces() {
        return races;
    }
    
    @RequestMapping("/participants")
    public List<RaceWithParticipants> getRacesWithParticipants() {
        List<RaceWithParticipants> returnRaces = new ArrayList<RaceWithParticipants>();
        for(Race r : races) {
            returnRaces.add(new RaceWithParticipants(r, participantsBean.getParticipants(r.getId())));
        }
        return returnRaces;
    }
}  

 @Component
class ParticipantsBean {
    @Autowired
    private ParticipantsClient participantsClient;
    
    @HystrixCommand(fallbackMethod = "defaultParticipants")
    public List<Participant> getParticipants(String raceId) {
        return participantsClient.getParticipants(raceId);
    }
    
    public List<Participant> defaultParticipants(String raceId) {
        return new ArrayList<Participant>();
    }
}

package com.ryanjbaxter.spring.cloud.ocr.hystrix;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.hystrix.dashboard.EnableHystrixDashboard;
import org.springframework.cloud.netflix.turbine.EnableTurbine;

@SpringBootApplication
@EnableHystrixDashboard 
public class HystrixDashboardApplication {

    public static void main(String[] args) {
        SpringApplication.run(HystrixDashboardApplication.class, args);
    }
}

server:
  port: 8383

$ siege http://localhost:8080/races

<dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-actuator</artifactId>
</dependency>

[
   {
      "name":"Spartan Beast",
      "id":"123",
      "state":"MA",
      "city":"Boston",
      "participants":[

      ]
   },
   {
      "name":"Tough Mudder RI",
      "id":"456",
      "state":"RI",
      "city":"Providence",
      "participants":[

      ]
   }
]

package com.ryanjbaxter.spring.cloud.ocr.hystrix;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.hystrix.dashboard.EnableHystrixDashboard;
import org.springframework.cloud.netflix.turbine.EnableTurbine;

@SpringBootApplication
@EnableHystrixDashboard
@EnableTurbine
public class HystrixDashboardApplication {

    public static void main(String[] args) {
        SpringApplication.run(HystrixDashboardApplication.class, args);
    }
}

server:
  port: 8383
  
turbine:
  appConfig: web,races
  aggregator:
    clusterConfig: WEB,RACES