Регистрация и обнаружение микросервисов с помощью Spring Cloud и Eureka от Netflix

Первоначально опубликовано Джошом Лонгом в весеннем блоге

Архитектура микросервисного стиля — это не столько создание отдельных сервисов, сколько создание   надежных и отказоустойчивых взаимодействий между сервисами. Хотя фокус на этих взаимодействиях является новым, необходимость в этом фокусе не является. Мы давно знаем, что сервисы не работают в вакууме. Еще до облачной экономики мы знали, что в практическом мире клиенты должны быть защищены от перебоев в обслуживании. Облако позволяет легко воспринимать емкость как эфемерную, текучую. На клиенте лежит бремя управления этой внутренней сложностью.

В этой статье мы рассмотрим, как  Spring Cloud  помогает вам справляться с этой сложностью с помощью реестра служб, такого как Eureka и Consul, и балансировки нагрузки на стороне клиента.

Облачная телефонная книга

Реестр сервисов — это телефонная книга для ваших микросервисов. Каждый сервис регистрируется в реестре сервисов и сообщает реестру, где он находится (хост, порт, имя узла) и, возможно, другие метаданные, относящиеся к сервису, — вещи, которые другие сервисы могут использовать для принятия обоснованных решений по этому поводу. Клиенты могут задавать вопросы о топологии обслуживания («есть ли какие-либо« услуги выполнения », и если да, где?») И возможностях обслуживания («можете ли вы справиться с X, Y и Z?»). Возможно, вы уже используете технологию, которая имеет некоторое представление о кластере (Cassandra, Memcached и т. Д.), И эта информация в идеале хранится в реестре сервисов.

Есть  несколько популярных опций для регистрации сервисов . Netflix построил, а затем открыл свой собственный сервисный реестр  Eureka . Еще один новый, но все более популярный вариант —  Консул . Мы рассмотрим в основном некоторые аспекты интеграции между Spring Cloud и реестром сервисов Eureka Netflix.

Со  страницы проекта Spring Cloud : «Spring Cloud предоставляет разработчикам инструменты для быстрого построения некоторых распространенных шаблонов в распределенных системах (например, управление конфигурацией, обнаружение служб, прерыватели цепи, интеллектуальная маршрутизация, микропрокси-сервер, шина управления, однократный токены, глобальные блокировки, выборы руководителей, распределенные сеансы, состояние кластера). Координация распределенных систем приводит к созданию шаблонов, и разработчики Spring Cloud могут быстро остановить службы и приложения, которые реализуют эти шаблоны. Они будут хорошо работать в любой распределенной среде, включая собственный ноутбук разработчика, голые металлические центры обработки данных и управляемые платформы, такие как Cloud Foundry ».

Spring Cloud уже поддерживает Eureka и Consul, хотя в этом посте я остановлюсь на Eureka, поскольку его можно автоматически загрузить в одной из автоконфигураций Spring Cloud. Эврика реализована на JVM, а Консул — на Go.

Установка Эврика

Поддерживать экземпляр реестра служб Eureka легко, если у вас есть  org.springframework.boot:spring-cloud-starter-eureka-server путь к классам.

package registry;




import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;




@SpringBootApplication
@EnableEurekaServer
public class Application {




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

Мой номинал  src/main/resources/application.yml выглядит так в эти дни.

server:
port: ${PORT:8761}




eureka:
client:
registerWithEureka: false
fetchRegistry: false
server:
waitTimeInMsWhenSyncEmpty: 0

Порт сервиса по умолчанию настроен на хорошо известный 8761 , если  Cloud Foundry «S VCAP_APPLICATION_PORT переменной окружения не доступна. Остальная часть конфигурации просто говорит этому экземпляру не регистрироваться в экземпляре Eureka, который он находит, потому что этот экземпляр … сам по себе. Если вы запускаете его локально, вы можете указать браузер http://localhost:8761 и отслеживать реестр оттуда.

Развертывание Эврика

Spring Cloud  запустит экземпляр Eureka с автоконфигурацией Spring Boot . При развертывании Eureka необходимо учитывать несколько моментов. Во-первых, вы всегда должны   использовать высокодоступную конфигурацию в производстве.  Образец Spring Cloud Eureka  показывает, как развернуть его в конфигурации с высокой доступностью.

Клиенты должны знать, где найти экземпляр Eureka. Если у вас есть DNS, то это может быть одним из вариантов, если вы не загрязняете слишком большое глобальное пространство имен. Если вы  работаете в Platform-as-a-Service и используете приложения в стиле 12-факторных приложений,  то учетные данные службы поддержки являются конфигурацией и находятся вне приложения и часто представляются в виде переменных среды. Однако вы можете получить эффект от службы Eureka прямо сейчас, используя cf CLI  Cloud Foundry  для создания  предоставляемой пользователем службы .

cf cups eureka-service -p '{"uri":"http://host-of-your-eureka-setup"}'

Укажите  host-of-your-eureka-setup на известный хост для вашей высокодоступной установки Eureka. Я подозреваю, что скоро мы увидим способ создания Eureka в качестве вспомогательного сервиса так же, как вы можете создать экземпляр PostgreSQL или ElasticSearch в  Pivotal Cloud Foundry .

Теперь, когда Eureka запущена и работает, давайте использовать ее для соединения некоторых служб друг с другом!

Говори за себя

Сервисы Spring Cloud имеют  spring.application.name свойство. Он используется для вывода конфигурации с сервера конфигурации, для идентификации сервиса для Eureka, и может использоваться во многих других контекстах при создании приложений на основе Spring Cloud. Это значение, как правило src/main/resources/bootstrap.(yml,properties), находится в , которое выбирается раньше при инициализации, чем обычно  src/main/resources/application.(yml,properties). Служба с  org.springframework.cloud:spring-cloud-starter-eureka на classpath будет зарегистрирована в реестре Eureka его  spring.application.name.

src/main/resources/boostrap.yml Файл для каждого из моих услуг выглядит следующим образом , где  my-service это имя службы , что изменения от сервиса:

spring:
application:
name: my-service

eureka:
client:
serviceUrl:
defaultZone: ${vcap.services.eureka-service.credentials.uri:http://127.0.0.1:8761}/eureka/




---
spring:
profiles: cloud
eureka:
instance:
hostname: ${APPLICATION_DOMAIN}
nonSecurePort: 80

package passport;




import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.CommandLineRunner;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.builder.SpringApplicationBuilder;
import org.springframework.cloud.client.ServiceInstance;
import org.springframework.cloud.client.discovery.DiscoveryClient;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
import org.springframework.cloud.netflix.feign.FeignConfiguration;
import org.springframework.context.annotation.Bean;
import org.springframework.core.ParameterizedTypeReference;
import org.springframework.http.HttpMethod;
import org.springframework.http.ResponseEntity;
import org.springframework.stereotype.Component;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.client.RestTemplate;




import java.util.List;




@SpringBootApplication
@EnableEurekaClient
public class Application extends FeignConfiguration {




public static void main(String[] args) {
new SpringApplicationBuilder(Application.class)
.web(false)
.run(args);
}




@Bean
BookmarkClient bookmarkClient() {
return loadBalance(BookmarkClient.class, "http://bookmark-service");
}
}




@Component
class DiscoveryClientExample implements CommandLineRunner {




@Autowired
private DiscoveryClient discoveryClient;




@Override
public void run(String... strings) throws Exception {
List<ServiceInstance> photoServices = discoveryClient.getInstances("photo-service");
photoServices.forEach(System.out::println);




List<ServiceInstance> bookmarkServices = discoveryClient.getInstances("bookmark-service");
bookmarkServices.forEach(System.out::println);
}
}




@Component
class RestTemplateExample implements CommandLineRunner {




@Autowired
private RestTemplate restTemplate;




@Override
public void run(String... strings) throws Exception {
// use the "smart" Eureka-aware RestTemplate
ResponseEntity<List<Bookmark>> exchange = this.restTemplate.exchange(
"http://bookmark-service/{userId}/bookmarks", HttpMethod.GET, null,
new ParameterizedTypeReference<List<Bookmark>>() {}, (Object) "mstine");




exchange.getBody().forEach(System.out::println);
}
}




@Component
class FeignExample implements CommandLineRunner {




@Autowired
private BookmarkClient bookmarkClient;




@Override
public void run(String... strings) throws Exception {
this.bookmarkClient.getBookmarks("jlong").forEach(System.out::println);
}
}




interface BookmarkClient {




@RequestMapping(method = RequestMethod.GET, value = "/{userId}/bookmarks")
List<Bookmark> getBookmarks(@PathVariable("userId") String userId);
}




class Bookmark {
private Long id;
private String href, label, description, userId;




@Override
public String toString() {
return "Bookmark{" +
"id=" + id +
", href='" + href + '\'' +
", label='" + label + '\'' +
", description='" + description + '\'' +
", userId='" + userId + '\'' +
'}';
}




public Bookmark() {
}




public Long getId() {
return id;
}




public String getHref() {
return href;
}




public String getLabel() {
return label;
}




public String getDescription() {
return description;
}




public String getUserId() {
return userId;
}
}

@Bean
BookmarkClient bookmarkClient() {
return loadBalance(BookmarkClient.class, "http://bookmark-service");
}