Как настроить распределенную трассировку в микросервисах с помощью Spring Boot, Zipkin или стека ELK

Предварительное условие

Иметь базовое представление о том, как настроить микросервис с помощью spring boot и spring cloud.
Установите сервер zipkin
Установите Elasticsearch, logstash и kibana

Установка и запуск сервера Zipkin

Для того чтобы установить сервер zipkin, существует два способа:

Если у вас установлена Java 8 или выше, самый быстрый способ начать работу – получить Последнюю версию в виде автономного исполняемого файла jar:

curl -sSL https://zipkin.io/quickstart.sh | bash -s java -jar zipkin.jar

Если у вас установлен docker, вы можете использовать следующее для непосредственного запуска последнего образа:

docker run -d -p 9411:9411 openzipkin/zipkin

Установите Elasticsearch, Logstash, Kibana

Существует также два способа установки и использования стека ELK:

Стек elk можно запустить через docker, выполнив следующие команды:

docker run -d –имя elasticsearch –net esp 9200:9200 -p 9300:9300 -e-узел” elasticsearch:6.7.2

Создайте файл logstash.conf со следующим содержимым:

input {
  tcp {
    port => 5000
    codec => json
  }
}
output {
  elasticsearch {
    hosts => ["http://elasticsearch:9200"]
    index => "micro-%{appname}"
  }
}

Затем выполните следующую команду:

docker run-d –name logstash –net ru-p 5044:5044-v ~/logstash.conf:/usr/share/logstash/pipeline/logstash. conf docker.elastic.co/logstash/logstash:6.7.2

Наконец, запустите kibana со следующим:

запуск docker -d -имя kibana -net es -e://elasticsearch:9200 ” -стр. 5601:5601 docker.elastic.co/kibana/kibana:6.7.2

Стек ELK также можно установить, перейдя по ссылке https://www.elastic.co/downloads/ и загружаем elasticsearch, logstash и kibana в файловую систему и распаковываем их.

Эластичный поиск

Распакуйте архив Запустите bin/elasticsearch (или bin\elasticsearch.bat в Windows) Запустить curl http://localhost:9200/ или Invoke-RestMethod http://localhost:9200 с помощью PowerShell

Кибана

Распакуйте архив Откройте config/kibana.yml в редакторе Установите elasticsearch.hosts так, чтобы он указывал на ваш экземпляр Elasticsearch Запустите bin/kibana (или bin\kibana.bat в Windows) Наведите свой браузер на http://localhost:5601

LogStash

Распакуйте архив Подготовьте logstash.conf конфигурация файл Запустите bin/logstash -f logstash.conf

Построение архитектуры микросервиса и интеграция трассировки

ШАГ 1: Создание конфигурационного сервера с помощью spring cloud config

Чтобы включить функцию конфигурации Spring Cloud для приложения, сначала включите spring-cloud-config-server в зависимости вашего проекта.


    org.springframework.cloud
    spring-cloud-config-server

Затем включите запуск встроенного сервера конфигурации во время загрузки приложения, используя аннотацию @EnableConfigServer.

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.config.server.EnableConfigServer;

@SpringBootApplication
@EnableConfigServer
public class ConfigServerApplication {

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

}

По умолчанию сервер Spring Cloud Config Server хранит данные конфигурации внутри репозитория Git. Это очень хороший выбор в рабочем режиме, но для целей этого руководства будет достаточно серверной части файловой системы. Действительно легко начать с config server, потому что мы можем поместить все свойства в classpath. Spring Cloud Config по умолчанию выполняет поиск источников свойств в следующих расположениях: classpath:/, classpath:/config, file:./, file:./config.

Мы помещаем все источники свойств в src/main/resources/config. Имя файла YAML будет таким же, как и имя службы. Например, файл YAML для discovery-service будет находиться здесь: src/main/resources/config/discovery-service.yml.

И последние две важные вещи. Если вы хотите запустить конфигурационный сервер с серверной частью файловой системы, вам необходимо активировать собственный профиль. Это может быть достигнуто путем установки параметра во время загрузки приложения или установки его в файле свойств. Установите порт сервера, установив свойство server.port в файле bootstrap.yml, но мы будем использовать 8888. Теперь всем другим приложениям, включая discovery-service, необходимо добавить зависимость spring-cloud-starter-config, чтобы включить config client.

ШАГ 2: Создание службы обнаружения с помощью spring cloud Netflix Eureka

Для того, чтобы мы могли настроить службу обнаружения, мы также должны включить зависимость от spring-cloud-starter-netflix-eureka-server.


    org.springframework.cloud
    spring-cloud-starter-netflix-eureka-server

Затем вы должны включить запуск встроенного сервера обнаружения во время загрузки приложения, установив аннотацию @EnableEurekaServer в основном классе.

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

@SpringBootApplication
@EnableEurekaServer
public class DiscoveryServiceApplication {

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

}

Приложение должно получить источник свойства с сервера конфигурации. Минимальная конфигурация, необходимая на стороне клиента, – это имя приложения и настройки подключения сервера конфигурации.

spring:
  application:
    name: discovery-service
  cloud:
    config:
      uri: http://localhost:8888

Служба обнаружения конфигурационных файлов.yml должен содержать приведенные ниже конфигурации и должен быть размещен внутри модуля config-service. Для автономных экземпляров Eureka мы должны отключить регистрацию и выборку реестра.

server:
  port: 8761

eureka:
  instance:
    hostname: localhost
  client:
    registerWithEureka: false
    fetchRegistry: false
    serviceUrl:
      defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/

ШАГ 3: Создание микросервисов с использованием spring boot и spring cloud

Наш микросервис должен выполнять некоторые операции во время загрузки. Ему необходимо получить конфигурацию из config-service, зарегистрироваться в discovery-service и предоставить HTTP API. Чтобы включить все эти механизмы, нам нужно включить некоторые зависимости в pom.xml . Чтобы включить конфигурационный клиент, мы должны включить starter spring-cloud-starter-config. Клиент обнаружения будет включен для микросервиса после включения spring-cloud-starter-netflix-eureka-client и аннотирования основного класса с помощью @EnableDiscoveryClient. Вот список зависимостей, необходимых для примера микросервиса:


    org.springframework.cloud
    spring-cloud-starter-netflix-eureka-client


    org.springframework.cloud
    spring-cloud-starter-config


    org.springframework.boot
    spring-boot-starter-web

А вот основной класс приложения, который включает Discovery Client для микросервиса.

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;

@SpringBootApplication
@EnableDiscoveryClient
public class SiteServiceApplication {

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

}

Приложение должно получать конфигурацию с удаленного сервера, поэтому мы должны предоставить только файл bootstrap.yml с именем службы и URL-адресом сервера. Фактически, это пример подхода Config First Bootstrap , когда приложение сначала подключается к серверу конфигурации и получает адрес сервера обнаружения из удаленного источника свойств. Существует также подход Discovery First Bootstrap , при котором адрес сервера конфигурации извлекается с сервера обнаружения. bootstrap.yml

spring:
  application:
    name: site-service
  cloud:
    config:
      uri: http://localhost:8888

Существует не так много параметров конфигурации. Существует не так много параметров конфигурации. Вот файл конфигурации приложения (site-service.yml), хранящийся на сервере конфигурации. Существует не так много параметров конфигурации. Вот файл конфигурации приложения (site-service.yml), хранящийся на сервере конфигурации. Он хранит только порт запуска HTTP и URL-адрес Eureka.

server:
  port: 8090

eureka:
  client:
    serviceUrl:
      defaultZone: http://localhost:8761/eureka/

import java.util.List;
import java.util.Optional;

import com.cinema.site.model.Site;
import com.cinema.site.repository.SiteRepository;

import org.springframework.cloud.context.config.annotation.RefreshScope;
import org.springframework.http.HttpStatus;
import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import lombok.AllArgsConstructor;
import lombok.NonNull;

@AllArgsConstructor
@RestController
@RefreshScope
@RequestMapping("/api")
public class SiteController {

    private final SiteRepository siteRepository;

    @GetMapping("/sites/{userId}")
    public ResponseEntity> getSitesByUser(@NonNull @PathVariable Long userId) {
        return new ResponseEntity<>(siteRepository.findByUserId(userId) ,HttpStatus.OK);
    }
}

Существует не так много параметров конфигурации. Вот файл конфигурации приложения (site-service.yml), хранящийся на сервере конфигурации. Он хранит только порт запуска HTTP и URL-адрес Eureka. сайт-сервис.yml Вот код с реализацией класса REST controller. ШАГ 4: Связь между микросервисами с spring cloud и Существует не так много параметров конфигурации. Вот файл конфигурации приложения (site-service.yml), хранящийся на сервере конфигурации. Он хранит только порт запуска HTTP и URL-адрес Eureka. сайт-сервис.yml Вот код с реализацией класса REST controller. ШАГ 4: Совместите симулированную связь между микросервисами с spring cloud и


    org.springframework.cloud
    spring-cloud-starter-openfeign

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.cloud.openfeign.EnableFeignClients;

@SpringBootApplication
@EnableDiscoveryClient
@EnableFeignClients
public class UserServiceApplication {

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

}

Существует не так много параметров конфигурации. Вот файл конфигурации приложения (site-service.yml), хранящийся на сервере конфигурации. Он хранит только порт запуска HTTP и URL-адрес Eureka. сайт-сервис.yml Вот код с реализацией класса REST controller. ШАГ 4: Откройте симулированную связь между микросервисами с помощью spring Теперь мы добавим еще один микросервис (пользовательский сервис), который необходим пользовательской службе для получения списка сайтов для данного идентификатора пользователя. Вот почему нам нужно включить дополнительную зависимость для tSpring Cloud Open Feign – это декларативный клиент REST, который использует Now, нам нужно определить клиентский интерфейс. После включения требуемой зависимости мы также должны включить симулирование клиентов с помощью аннотации @EnableFeignClients. Однако Feign предоставляет более элегантный способ определения клиента, поэтому я предпочитаю использовать его вместо RestTemplate. Альтернативным решением для Open Feign является Spring RestTemplate с @LoadBalanced. Ленточный балансировщик нагрузки на стороне клиента для взаимодействия с другими микросервисами. модули шлангов: spring-cloud-starter-openfeign. взаимодействует с сервисом сайта. облако и Существует не так много параметров конфигурации. Вот файл конфигурации приложения (site-service.yml), хранящийся на сервере конфигурации. Он хранит только порт запуска HTTP и URL-адрес Eureka. сайт-сервис.yml Вот код с реализацией класса REST controller. ШАГ 4: Откройте симулированную связь между микросервисами с помощью spring Теперь мы добавим еще один микросервис (пользовательский сервис), который необходим пользовательской службе для получения списка сайтов для данного идентификатора пользователя. Вот почему нам нужно включить дополнительную зависимость для tSpring Cloud Open Feign – это декларативный клиент REST, который использует, поскольку пользовательский сервис взаимодействует со службой сайта, мы должны создать интерфейс. Теперь нам нужно определить клиентский интерфейс. После включения требуемой зависимости мы также должны включить симулирование клиентов с помощью аннотации @EnableFeignClients. Однако Feign предоставляет более элегантный способ определения клиента, поэтому я предпочитаю использовать его вместо RestTemplate. Альтернативным решением для Open Feign является Spring RestTemplate с @LoadBalanced. Ленточный балансировщик нагрузки на стороне клиента для взаимодействия с другими микросервисами. модули шлангов: spring-cloud-starter-openfeign. взаимодействует с сервисом сайта. облако и Существует не так много параметров конфигурации. Вот файл конфигурации приложения (site-service.yml), хранящийся на сервере конфигурации. Он хранит только порт запуска HTTP и URL-адрес Eureka. сайт-сервис.yml Вот код с реализацией класса REST controller. ШАГ 4: Откройте симулированную связь между микросервисами с помощью spring Теперь мы добавим еще один микросервис (пользовательский сервис), который необходим пользовательской службе для получения списка сайтов для данного идентификатора пользователя. Вот почему нам нужно включить дополнительную зависимость для tSpring Cloud Open Feign – это декларативный клиент REST, который использует интерфейс каждого клиента, который должен быть помечен @FeignClient. Поскольку пользовательский сервис взаимодействует со службой сайта, мы должны создать интерфейс. Теперь нам нужно определить клиентский интерфейс. После включения требуемой зависимости мы также должны включить симулирование клиентов с помощью аннотации @EnableFeignClients. Однако Feign предоставляет более элегантный способ определения клиента, поэтому я предпочитаю использовать его вместо RestTemplate. Альтернативным решением для Open Feign является Spring RestTemplate с @LoadBalanced. Ленточный балансировщик нагрузки на стороне клиента для взаимодействия с другими микросервисами. модули шлангов: spring-cloud-starter-openfeign. взаимодействует с сервисом сайта. облако и Существует не так много параметров конфигурации. Вот файл конфигурации приложения (site-service.yml), хранящийся на сервере конфигурации. Он хранит только порт запуска HTTP и URL-адрес Eureka. сайт-сервис.yml Вот код с реализацией класса REST controller. ШАГ 4: Откройте симулированную связь между микросервисами с помощью spring Теперь мы добавим еще один микросервис (пользовательский сервис), который необходим пользовательской службе для получения списка сайтов для данного идентификатора пользователя. Вот почему нам нужно включить дополнительную зависимость для tSpring Cloud Open Feign – это декларативный клиент REST, который использует одно поле внутри аннотации обязательно – name. Интерфейс каждого клиента должен быть помечен @FeignClient. Поскольку пользовательский сервис взаимодействует со службой сайта, мы должны создать интерфейс. Теперь нам нужно определить клиентский интерфейс. После включения требуемой зависимости мы также должны включить симулирование клиентов с помощью аннотации @EnableFeignClients. Однако Feign предоставляет более элегантный способ определения клиента, поэтому я предпочитаю использовать его вместо RestTemplate. Альтернативным решением для Open Feign является Spring RestTemplate с @LoadBalanced. Ленточный балансировщик нагрузки на стороне клиента для взаимодействия с другими микросервисами. модули шлангов: spring-cloud-starter-openfeign. взаимодействует с сервисом сайта. облако и Существует не так много параметров конфигурации. Вот файл конфигурации приложения (site-service.yml), хранящийся на сервере конфигурации. Он хранит только порт запуска HTTP и URL-адрес Eureka. сайт-сервис.yml Вот код с реализацией класса REST controller. ШАГ 4: Откройте симулированную связь между микросервисами с помощью spring Теперь мы добавим еще один микросервис (пользовательский сервис), который необходим пользовательской службе для получения списка сайтов для данного идентификатора пользователя. Вот почему нам нужно включить дополнительную зависимость для tSpring Cloud Open Feign – это декларативный клиент REST, который использует это имя, которое должно совпадать с именем целевой службы, зарегистрированной в service discovery. Одно поле внутри аннотации обязательно – имя. Интерфейс каждого клиента должен быть помечен @FeignClient. Поскольку пользовательский сервис взаимодействует со службой сайта, мы должны создать интерфейс. Теперь нам нужно определить клиентский интерфейс. После включения требуемой зависимости мы также должны включить симулирование клиентов с помощью аннотации @EnableFeignClients. Однако Feign предоставляет более элегантный способ определения клиента, поэтому я предпочитаю использовать его вместо RestTemplate. Альтернативным решением для Open Feign является Spring RestTemplate с @LoadBalanced. Ленточный балансировщик нагрузки на стороне клиента для взаимодействия с другими микросервисами. модули шлангов: spring-cloud-starter-openfeign. взаимодействует с сервисом сайта. облако и Существует не так много параметров конфигурации. Вот файл конфигурации приложения (site-service.yml), хранящийся на сервере конфигурации. Он хранит только порт запуска HTTP и URL-адрес Eureka. сайт-сервис.yml Вот код с реализацией класса REST controller. ШАГ 4: Откройте симулированную связь между микросервисами с помощью spring Теперь мы добавим еще один микросервис (пользовательский сервис), который необходим пользовательской службе для получения списка сайтов для данного идентификатора пользователя. Вот почему нам нужно включить дополнительную зависимость для tSpring Cloud Open Feign – это декларативный клиент REST, который использует вот интерфейс клиента, который вызывает конечную точку GET/api/sites/{userId}, предоставляемую пользовательской службой. Это имя должно совпадать с именем целевой службы, зарегистрированной в service discovery. Одно поле внутри аннотации обязательно – имя. Интерфейс каждого клиента должен быть помечен @FeignClient. Поскольку пользовательский сервис взаимодействует со службой сайта, мы должны создать интерфейс. Теперь нам нужно определить клиентский интерфейс. После включения требуемой зависимости мы также должны включить симулирование клиентов с помощью аннотации @EnableFeignClients. Однако Feign предоставляет более элегантный способ определения клиента, поэтому я предпочитаю использовать его вместо RestTemplate. Альтернативным решением для Open Feign является Spring RestTemplate с @LoadBalanced. Ленточный балансировщик нагрузки на стороне клиента для взаимодействия с другими микросервисами. модули шлангов: spring-cloud-starter-openfeign. взаимодействует с сервисом сайта. облако и

import java.util.List;

import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;

@FeignClient(name = "site-service", fallbackFactory = SiteClientFallbackFactory.class)
public interface SiteClient {

    @GetMapping("/api/sites/{userId}")
    List findAllByUser(@PathVariable(value="userId") Long userId);
}

import java.util.ArrayList;
import java.util.List;

import org.springframework.stereotype.Component;

import feign.hystrix.FallbackFactory;
import lombok.extern.slf4j.Slf4j;

@Component
@Slf4j
public class SiteClientFallbackFactory implements FallbackFactory {
    @Override
    public SiteClient create(Throwable cause) {
        return new SiteClient() {
            @Override
            public List findAllByUser(Long id) {
                log.error(cause.getMessage(), cause);
                return new ArrayList<>();
            }
        };
    }
}

import java.util.List;
import java.util.Optional;

import com.cinema.user.client.SiteClient;
import com.cinema.user.model.User;
import com.cinema.user.repository.UserRepository;

import org.springframework.stereotype.Service;

import lombok.AllArgsConstructor;

@AllArgsConstructor
@Service
public class UserServiceImpl implements UserService {

    private final UserRepository userRepository;
    private final SiteClient siteClient;

    @Override
    public List findAll() {
        return userRepository.findAll();
    }

    @Override
    public List findAllSitesByUser(final Long userId) {
        return siteClient.findAllByUser(userId);
    }
}

import java.util.List;
import java.util.Optional;

import com.cinema.user.model.User;
import com.cinema.user.service.UserService;

import org.springframework.cloud.context.config.annotation.RefreshScope;
import org.springframework.http.HttpStatus;
import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import lombok.AllArgsConstructor;
import lombok.NonNull;

@AllArgsConstructor
@RestController
@RefreshScope
@RequestMapping("/api")
public class UserController {

    private final UserService userService;

    @GetMapping("/users")
    public ResponseEntity> getUsers() {
        return new ResponseEntity<>(userService.findAll(), HttpStatus.OK);
    }

    @GetMapping("/users/sites/{userId}")
    public ResponseEntity getUserSites(@PathVariable("userId") Long id) {
        Optional user = userService.findOne(id);
        if(user.isPresent())
            return new ResponseEntity<>(userService.findAllSitesByUser(id), HttpStatus.OK);
        else
            return new ResponseEntity<>(HttpStatus.BAD_REQUEST);
    }
}

Существует не так много параметров конфигурации. Вот файл конфигурации приложения (site-service.yml), хранящийся на сервере конфигурации. Он хранит только порт запуска HTTP и URL-адрес Eureka. сайт-сервис.yml Вот код с реализацией класса REST controller. ШАГ 4: Откройте симулированную связь между микросервисами с помощью spring Теперь мы добавим еще один микросервис (пользовательский сервис), который необходим пользовательской службе для получения списка сайтов для данного идентификатора пользователя. Вот почему нам нужно включить дополнительную зависимость для tSpring Cloud Open Feign – это декларативный клиент REST, который использует ШАГ 5: Создание API-шлюза с использованием spring cloud Netflix Zuul (пограничный сервис) Теперь мы можем вызывать методы, определенные внутри SiteClient, что эквивалентно вызову конечных точек REST. Наконец, мы должны внедрить компоненты клиента Feign в контроллер REST через сервис. SiteClientFallbackFactory помогает в архивировании этого. Иногда мы хотим создать резервный метод, который будет выполняться, если притворный клиент не сможет подключиться к целевой службе. Вот интерфейс клиента, который вызывает конечную точку GET/api/sites/{userId}, предоставляемую пользовательской службой. Это имя должно совпадать с именем целевой службы, зарегистрированной в service discovery. Одно поле внутри аннотации обязательно – имя. Интерфейс каждого клиента должен быть помечен @FeignClient. Поскольку пользовательский сервис взаимодействует со службой сайта, мы должны создать интерфейс. Теперь нам нужно определить клиентский интерфейс. После включения требуемой зависимости мы также должны включить симулирование клиентов с помощью аннотации @EnableFeignClients. Однако Feign предоставляет более элегантный способ определения клиента, поэтому я предпочитаю использовать его вместо RestTemplate. Альтернативным решением для Open Feign является Spring RestTemplate с @LoadBalanced. Ленточный балансировщик нагрузки на стороне клиента для взаимодействия с другими микросервисами. модули шлангов: spring-cloud-starter-openfeign. взаимодействует с сервисом сайта. облако и

Существует не так много параметров конфигурации. Вот файл конфигурации приложения (site-service.yml), хранящийся на сервере конфигурации. Он хранит только порт запуска HTTP и URL-адрес Eureka. сайт-сервис.yml Вот код с реализацией класса REST controller. ШАГ 4: Откройте симулированную связь между микросервисами с помощью spring Теперь мы добавим еще один микросервис (пользовательский сервис), который необходим пользовательской службе для получения списка сайтов для данного идентификатора пользователя. Вот почему нам нужно включить дополнительную зависимость для tSpring Cloud Open Feign – это декларативный клиент REST, который использует Spring Cloud Netflix Zuul – это проект Spring Cloud, предоставляющий API-шлюз для микросервисов. ШАГ 5: Создание API gateway с использованием spring cloud Netflix Zuul (пограничный сервис) Теперь мы можем вызывать методы, определенные внутри SiteClient, что эквивалентно вызову конечных точек REST. Наконец, мы должны внедрить компоненты клиента Feign в контроллер REST через сервис. SiteClientFallbackFactory помогает в архивировании этого. Иногда мы хотим создать резервный метод, который будет выполняться, если притворный клиент не сможет подключиться к целевой службе. Вот интерфейс клиента, который вызывает конечную точку GET/api/sites/{userId}, предоставляемую пользовательской службой. Это имя должно совпадать с именем целевой службы, зарегистрированной в service discovery. Одно поле внутри аннотации обязательно – имя. Интерфейс каждого клиента должен быть помечен @FeignClient. Поскольку пользовательский сервис взаимодействует со службой сайта, мы должны создать интерфейс. Теперь нам нужно определить клиентский интерфейс. После включения требуемой зависимости мы также должны включить симулирование клиентов с помощью аннотации @EnableFeignClients. Однако Feign предоставляет более элегантный способ определения клиента, поэтому я предпочитаю использовать его вместо RestTemplate. Альтернативным решением для Open Feign является Spring RestTemplate с @LoadBalanced. Ленточный балансировщик нагрузки на стороне клиента для взаимодействия с другими микросервисами. модули шлангов: spring-cloud-starter-openfeign. взаимодействует с сервисом сайта. облако и Существует не так много параметров конфигурации. Вот файл конфигурации приложения (site-service.yml), хранящийся на сервере конфигурации. Он хранит только порт запуска HTTP и URL-адрес Eureka. сайт-сервис.yml Вот код с реализацией класса REST controller. ШАГ 4: Откройте симулированную связь между микросервисами с помощью spring Теперь мы добавим еще один микросервис (пользовательский сервис), который необходим пользовательской службе для получения списка сайтов для данного идентификатора пользователя. Вот почему нам нужно включить дополнительную зависимость для tSpring Cloud Open Feign – это декларативный клиент REST, который использует API gateway, реализованный внутри модуля edge-service. Spring Cloud Netflix Zuul – это проект Spring Cloud, предоставляющий API-шлюз для микросервисов. ШАГ 5: Создание API gateway с использованием spring cloud Netflix Zuul (пограничный сервис) Теперь мы можем вызывать методы, определенные внутри SiteClient, что эквивалентно вызову конечных точек REST. Наконец, мы должны внедрить компоненты клиента Feign в контроллер REST через сервис. SiteClientFallbackFactory помогает в архивировании этого. Иногда мы хотим создать резервный метод, который будет выполняться, если притворный клиент не сможет подключиться к целевой службе. Вот интерфейс клиента, который вызывает конечную точку GET/api/sites/{userId}, предоставляемую пользовательской службой. Это имя должно совпадать с именем целевой службы, зарегистрированной в service discovery. Одно поле внутри аннотации обязательно – имя. Интерфейс каждого клиента должен быть помечен @FeignClient. Поскольку пользовательский сервис взаимодействует со службой сайта, мы должны создать интерфейс. Теперь нам нужно определить клиентский интерфейс. После включения требуемой зависимости мы также должны включить симулирование клиентов с помощью аннотации @EnableFeignClients. Однако Feign предоставляет более элегантный способ определения клиента, поэтому я предпочитаю использовать его вместо RestTemplate. Альтернативным решением для Open Feign является Spring RestTemplate с @LoadBalanced. Ленточный балансировщик нагрузки на стороне клиента для взаимодействия с другими микросервисами. модули шлангов: spring-cloud-starter-openfeign. взаимодействует с сервисом сайта. облако и Существует не так много параметров конфигурации. Вот файл конфигурации приложения (site-service.yml), хранящийся на сервере конфигурации. Он хранит только порт запуска HTTP и URL-адрес Eureka. сайт-сервис.yml Вот код с реализацией класса REST controller. ШАГ 4: Откройте симулированную связь между микросервисами с помощью spring Теперь мы добавим еще один микросервис (пользовательский сервис), который необходим пользовательской службе для получения списка сайтов для данного идентификатора пользователя. Вот почему нам нужно включить дополнительную зависимость для tSpring Cloud Open Feign – это декларативный клиент REST, который сначала использует, мы должны включить starter spring-cloud-starter-netflix-zuul в зависимости проекта. API-шлюз реализован внутри модуля edge-service. Spring Cloud Netflix Zuul – это проект Spring Cloud, предоставляющий API-шлюз для микросервисов. ШАГ 5: Создание API gateway с использованием spring cloud Netflix Zuul (пограничный сервис) Теперь мы можем вызывать методы, определенные внутри SiteClient, что эквивалентно вызову конечных точек REST. Наконец, мы должны внедрить компоненты клиента Feign в контроллер REST через сервис. SiteClientFallbackFactory помогает в архивировании этого. Иногда мы хотим создать резервный метод, который будет выполняться, если притворный клиент не сможет подключиться к целевой службе. Вот интерфейс клиента, который вызывает конечную точку GET/api/sites/{userId}, предоставляемую пользовательской службой. Это имя должно совпадать с именем целевой службы, зарегистрированной в service discovery. Одно поле внутри аннотации обязательно – имя. Интерфейс каждого клиента должен быть помечен @FeignClient. Поскольку пользовательский сервис взаимодействует со службой сайта, мы должны создать интерфейс. Теперь нам нужно определить клиентский интерфейс. После включения требуемой зависимости мы также должны включить симулирование клиентов с помощью аннотации @EnableFeignClients. Однако Feign предоставляет более элегантный способ определения клиента, поэтому я предпочитаю использовать его вместо RestTemplate. Альтернативным решением для Open Feign является Spring RestTemplate с @LoadBalanced. Ленточный балансировщик нагрузки на стороне клиента для взаимодействия с другими микросервисами. модули шлангов: spring-cloud-starter-openfeign. взаимодействует с сервисом сайта. облако и


    org.springframework.cloud
    spring-cloud-starter-netflix-zuul

spring:
  application:
    name: edge-service
  cloud:
    config:
      uri: http://localhost:8888

server:
  port: 8190

eureka:
  client:
    serviceUrl:
      defaultZone: http://localhost:8761/eureka/

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.autoconfigure.liquibase.LiquibaseProperties;
import org.springframework.boot.context.properties.EnableConfigurationProperties;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.cloud.netflix.zuul.EnableZuulProxy;

@SpringBootApplication
@EnableDiscoveryClient
@EnableZuulProxy
@EnableConfigurationProperties({LiquibaseProperties.class, ApplicationProperties.class})
public class EdgeServiceApplication {

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

}

Существует не так много параметров конфигурации. Вот файл конфигурации приложения (site-service.yml), хранящийся на сервере конфигурации. Он хранит только порт запуска HTTP и URL-адрес Eureka. сайт-сервис.yml Вот код с реализацией класса REST controller. ШАГ 4: Откройте симулированную связь между микросервисами с помощью spring Теперь мы добавим еще один микросервис (пользовательский сервис), который необходим пользовательской службе для получения списка сайтов для данного идентификатора пользователя. Вот почему нам нужно включить дополнительную зависимость для tSpring Cloud Open Feign – это декларативный клиент REST, который использует ISTEP 6: Сопоставление журналов между различными микросервисами с использованием spring cloud sleuth, а zipkin t хранит только порт запуска HTTP и URL-адрес Eureka. Вот файл конфигурации приложения (edge-service.yml), хранящийся на сервере конфигурации. Нам также необходимо включить клиент обнаружения, поскольку пограничная служба интегрируется с Eureka, чтобы иметь возможность выполнять маршрутизацию к нижестоящим службам. Во-первых, мы должны включить starter spring-cloud-starter-netflix-zuul в зависимости проекта. API-шлюз реализован внутри модуля edge-service. Spring Cloud Netflix Zuul – это проект Spring Cloud, предоставляющий API-шлюз для микросервисов. ШАГ 5: Создание API gateway с использованием spring cloud Netflix Zuul (пограничный сервис) Теперь мы можем вызывать методы, определенные внутри SiteClient, что эквивалентно вызову конечных точек REST. Наконец, мы должны внедрить компоненты клиента Feign в контроллер REST через сервис. SiteClientFallbackFactory помогает в архивировании этого. Иногда мы хотим создать резервный метод, который будет выполняться, если притворный клиент не сможет подключиться к целевой службе. Вот интерфейс клиента, который вызывает конечную точку GET/api/sites/{userId}, предоставляемую пользовательской службой. Это имя должно совпадать с именем целевой службы, зарегистрированной в service discovery. Одно поле внутри аннотации обязательно – имя. Интерфейс каждого клиента должен быть помечен @FeignClient. Поскольку пользовательский сервис взаимодействует со службой сайта, мы должны создать интерфейс. Теперь нам нужно определить клиентский интерфейс. После включения требуемой зависимости мы также должны включить симулирование клиентов с помощью аннотации @EnableFeignClients. Однако Feign предоставляет более элегантный способ определения клиента, поэтому я предпочитаю использовать его вместо RestTemplate. Альтернативным решением для Open Feign является Spring RestTemplate с @LoadBalanced. Ленточный балансировщик нагрузки на стороне клиента для взаимодействия с другими микросервисами. модули шлангов: spring-cloud-starter-openfeign. взаимодействует с сервисом сайта. облако и


    org.springframework.cloud
    spring-cloud-starter-sleuth


    org.springframework.cloud
    spring-cloud-starter-zipkin

spring:
  zipkin:
    baseUrl: http://localhost:9411/
  sleuth:
    sampler:
      probability: 1

Существует не так много параметров конфигурации. Вот файл конфигурации приложения (site-service.yml), хранящийся на сервере конфигурации. Он хранит только порт запуска HTTP и URL-адрес Eureka. сайт-сервис.yml Вот код с реализацией класса REST controller. ШАГ 4: Откройте симулированную связь между микросервисами с помощью spring Теперь мы добавим еще один микросервис (пользовательский сервис), который необходим пользовательской службе для получения списка сайтов для данного идентификатора пользователя. Вот почему нам нужно включить дополнительную зависимость для tSpring Cloud Open Feign – это декларативный клиент REST, который использует ISTEP 7: Настройка микросервисов для отправки журналов в logstash При условии, что сервер zipkin отвечает на localhost на порту 9411, Затем добавьте следующее в файл yml каждого микросервиса на сервере конфигурации: Для того, чтобы чтобы настроить zipkin, добавьте приведенную ниже зависимость к каждому микросервису pom.xml файл На самом деле, единственное, что вам нужно сделать, это добавить starter spring-cloud-starter-sleuth к зависимостям каждого отдельного микросервиса и шлюза. Сопоставлять журналы между различными микросервисами с помощью Spring Cloud Sleuth очень просто. ШАГ 6: Сопоставление журналов между различными микросервисами с помощью spring cloud sleuth и zipkin t сохраняет только порт запуска HTTP и URL-адрес Eureka. Вот файл конфигурации приложения (edge-service.yml), хранящийся на сервере конфигурации. Нам также необходимо включить клиент обнаружения, поскольку пограничная служба интегрируется с Eureka, чтобы иметь возможность выполнять маршрутизацию к нижестоящим службам. Во-первых, мы должны включить starter spring-cloud-starter-netflix-zuul в зависимости проекта. API-шлюз реализован внутри модуля edge-service. Spring Cloud Netflix Zuul – это проект Spring Cloud, предоставляющий API-шлюз для микросервисов. ШАГ 5: Создание API gateway с использованием spring cloud Netflix Zuul (пограничный сервис) Теперь мы можем вызывать методы, определенные внутри SiteClient, что эквивалентно вызову конечных точек REST. Наконец, мы должны внедрить компоненты клиента Feign в контроллер REST через сервис. SiteClientFallbackFactory помогает в архивировании этого. Иногда мы хотим создать резервный метод, который будет выполняться, если притворный клиент не сможет подключиться к целевой службе. Вот интерфейс клиента, который вызывает конечную точку GET/api/sites/{userId}, предоставляемую пользовательской службой. Это имя должно совпадать с именем целевой службы, зарегистрированной в service discovery. Одно поле внутри аннотации обязательно – имя. Интерфейс каждого клиента должен быть помечен @FeignClient. Поскольку пользовательский сервис взаимодействует со службой сайта, мы должны создать интерфейс. Теперь нам нужно определить клиентский интерфейс. После включения требуемой зависимости мы также должны включить симулирование клиентов с помощью аннотации @EnableFeignClients. Однако Feign предоставляет более элегантный способ определения клиента, поэтому я предпочитаю использовать его вместо RestTemplate. Альтернативным решением для Open Feign является Spring RestTemplate с @LoadBalanced. Ленточный балансировщик нагрузки на стороне клиента для взаимодействия с другими микросервисами. модули шлангов: spring-cloud-starter-openfeign. взаимодействует с сервисом сайта. облако и


    net.logstash.logback
    logstash-logback-encoder
    5.3


    ch.qos.logback
    logback-core
    1.2.3



    
    
        localhost:5044
        
            
                
                
                
                
                
                
                
                    
                        {
                            "appName": "site-service"
                        }

Оригинал: “https://dev.to/dj_kev/how-to-set-up-distributed-tracing-in-microservices-with-spring-boot-zipkin-or-the-elk-stack-444a”