Обмен технологиями

SpringCloud — кластер Эврика

2024-07-12

한어Русский языкEnglishFrançaisIndonesianSanskrit日本語DeutschPortuguêsΕλληνικάespañolItalianoSuomalainenLatina

Кластер регистрационного центра Эврика

Зачем кластеризовать

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

Как кластеризовать

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

Код:

Здесь используется модуль Eureka, который настраивает несколько файлов yml для достижения эффекта кластеризации.

Стартап-класс

  1. package org.example;
  2.  
  3. import org.springframework.boot.SpringApplication;
  4. import org.springframework.boot.autoconfigure.SpringBootApplication;
  5. import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;
  6.  
  7. /**
  8.  * @ClassName EurekaStart
  9.  * @Author 23
  10.  * @Date 2024/7/10 19:12
  11.  * @Version 1.0
  12.  * @Description TODO
  13.  **/
  14. @SpringBootApplication
  15. @EnableEurekaServer
  16. public class EurekaStart {
  17.     public static void main(String[] args) {
  18.         SpringApplication.run(EurekaStart.class,args);
  19.     }
  20. }

yml

  1. spring:
  2.   profiles:
  3.     active: peer3
  4. ---
  5. spring:
  6.   profiles: peer1
  7.   application:
  8.     name: Eureka1
  9. eureka:
  10.   instance:
  11.     hostname: localhost
  12.   client:
  13.     serviceUrl:
  14.       defaultZone: http://localhost:10070/eureka/
  15. server:
  16.   port: 10070
  17. ---
  18. spring:
  19.   profiles: peer2
  20.   application:
  21.     name: Eureka2
  22. eureka:
  23.   instance:
  24.     hostname: localhost
  25.   client:
  26.     serviceUrl:
  27.       defaultZone: http://localhost:10071/eureka/
  28. server:
  29.   port: 10071
  30. ---
  31. spring:
  32.   profiles: peer3
  33.   application:
  34.     name: Eureka3
  35. eureka:
  36.   instance:
  37.     hostname: localhost
  38.   client:
  39.     serviceUrl:
  40.       defaultZone: http://localhost:10072/eureka/
  41. server:
  42.   port: 10072

pom.xml

  1. <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  2.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  3.     <modelVersion>4.0.0</modelVersion>
  4.     <parent>
  5.         <groupId>org.example</groupId>
  6.         <artifactId>Springcloud-Netflix</artifactId>
  7.         <version>1.0-SNAPSHOT</version>
  8.     </parent>
  9.  
  10.     <artifactId>Eureka-Service</artifactId>
  11.     <packaging>jar</packaging>
  12.  
  13.     <name>Eureka-Service</name>
  14.     <url>http://maven.apache.org</url>
  15.  
  16.     <properties>
  17.         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
  18.     </properties>
  19.  
  20.     <dependencies>
  21.         <dependency>
  22.             <groupId>junit</groupId>
  23.             <artifactId>junit</artifactId>
  24.             <version>3.8.1</version>
  25.             <scope>test</scope>
  26.         </dependency>
  27.         <dependency>
  28.             <groupId>org.springframework.boot</groupId>
  29.             <artifactId>spring-boot-starter-web</artifactId>
  30.         </dependency>
  31.         <dependency>
  32.             <groupId>org.springframework.boot</groupId>
  33.             <artifactId>spring-boot-starter-test</artifactId>
  34.         </dependency>
  35.         <!-- Eureka服务端支持 -->
  36.         <dependency>
  37.             <groupId>org.springframework.cloud</groupId>
  38.             <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
  39.         </dependency>
  40.     </dependencies>
  41. </project>

Балансировка нагрузки сервиса

Зачем нужна балансировка нагрузки

Чтобы обеспечить параллелизм, иногда один и тот же поставщик услуг может развернуть несколько (товарных сервисов). Этот клиент должен завершить вызов нагрузки в соответствии с определенной стратегией ответственной балансировки при вызове.

Конфигурация поставщика услуг

  1. spring:
  2.   profiles:
  3.     active: order2
  4. ---
  5. server:
  6.   port: 10010
  7. spring:
  8.   profiles: order1
  9.   application:
  10.     name: order-service
  11. eureka:
  12.   client:
  13.     service-url:
  14.       defaultZone:  http://localhost:10072/eureka
  15.   instance:
  16.     prefer-ip-address: true
  17. ---
  18. server:
  19.   port: 10012
  20. spring:
  21.   profiles: order2
  22.   application:
  23.     name: order-service
  24. eureka:
  25.   client:
  26.     service-url:
  27.       defaultZone: http://localhost:10072/eureka
  28.   instance:
  29.     prefer-ip-address: true

Общие технологии реализации балансировки нагрузки

Лента

Через RestTmplate завершите вызов службы с помощью URL-адреса.

Реализация кода (сторона потребителя сервиса):

  1. package org.example.Controller;
  2.  
  3. import org.example.domain.Order;
  4. import org.springframework.beans.factory.annotation.Autowired;
  5. import org.springframework.cloud.client.ServiceInstance;
  6. import org.springframework.cloud.client.discovery.DiscoveryClient;
  7. import org.springframework.web.bind.annotation.GetMapping;
  8. import org.springframework.web.bind.annotation.PathVariable;
  9. import org.springframework.web.bind.annotation.RequestMapping;
  10. import org.springframework.web.bind.annotation.RestController;
  11. import org.springframework.web.client.RestTemplate;
  12.  
  13. import java.util.Arrays;
  14. import java.util.List;
  15.  
  16. /**
  17.  * @ClassName UserController
  18.  * @Author 23
  19.  * @Date 2024/7/10 18:52
  20.  * @Version 1.0
  21.  * @Description TODO
  22.  **/
  23. @RestController
  24. @RequestMapping("/User")
  25. public class UserControllerrlb {
  26.     @Autowired
  27.     private RestTemplate restTemplate;
  28. //    @Autowired
  29. //    private DiscoveryClient discoveryClient;
  30.     @GetMapping("/getOrder/{id}")
  31.     public List<Order> getOrderById(@PathVariable("id") Integer id) {
  32. //        Order[] order = restTemplate.getForObject("http://localhost:10010/OrderService/user/" + id, Order[].class);
  33. //        return Arrays.asList(order);
  34. //        List<ServiceInstance> instances=discoveryClient.getInstances("order-service");//通过服务的名字去获取服务实例
  35. //        ServiceInstance serviceInstance=instances.get(0);//定死只获取第一个服务实例对象
  36. //        String ip=serviceInstance.getHost();//获取服务对象ip
  37. //        int port=serviceInstance.getPort();//获取获取的实例对象的服务端口号
  38.         Order[] orders=restTemplate.getForObject("http://Order-Service/OrderService/user/"+id,Order[].class);
  39.         return Arrays.asList(orders);
  40.  
  41.     }
  42. }

Вызов балансировки нагрузки ленты

Ribbon — это проект облачной службы среднего уровня с открытым исходным кодом, выпущенный Netflix. Его основная функция — предоставить алгоритм балансировки нагрузки клиента. Клиентский компонент ленты предоставляет ряд полных элементов конфигурации, таких как время ожидания соединения, повторная попытка и т. д. Проще говоря, Ribbon — это клиентский балансировщик нагрузки. Мы можем перечислить все машины, стоящие за балансировщиком нагрузки, в файле конфигурации, и Ribbon автоматически поможет вам подключиться на основе определенных правил (таких как простой опрос, случайные соединения и т. д.). машинах, мы можем легко использовать Ribbon для реализации пользовательских алгоритмов балансировки нагрузки. Лента — это клиентский балансировщик нагрузки, который может выполнять вызовы балансировки нагрузки для нескольких экземпляров службы в соответствии с определенными правилами. Эти правила также поддерживают настройку.

Схема:

Балансировка нагрузки OpenFeign

OpenFeign — это декларативный клиент веб-службы, цель которого — упростить вызовы веб-службы. Feign предоставляет шаблон интерфейса для HTTP-запросов (на нем отмечен адрес доступа). Написав простой интерфейс и вставив аннотации, вы можете определить параметры, формат, адрес и другую информацию HTTP-запроса. OpenFeign будет полностью проксировать (динамический прокси) HTTP-запросы. Нам нужно только вызвать его как метод для завершения запроса на обслуживание и соответствующей обработки. Feign интегрирует Ribbon и Hystrix (о Hystrix мы поговорим позже), так что нам больше не нужно явно использовать эти два компонента.

Стратегия балансировки нагрузки

IПравило

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

Встроенная стратегия балансировки нагрузки

 

Личный профиль

Он посвятил себя исследованию технологий более 30 лет и владеет различными языками, такими как Java, Linux, Javascript, php, css и т. д. Он внес большой вклад в область открытого исходного кода. Станция документации для разработчиков, где можно поделиться некоторыми проблемами в разработке технологий для дальнейшего использования. Все ознакомьтесь.

моя контактная информация

Почта