SpringBoot 2 使用 SpringCloud LoadBalancer 实现客户端负载均衡

2024-02-04 08:38
文章标签 java 实现 使用 springboot 负载 spring 客户端 springcloud 均衡 loadbalancer

本文主要是介绍SpringBoot 2 使用 SpringCloud LoadBalancer 实现客户端负载均衡，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

开篇词

该指南将引导你创建负载均衡的微服务。
 

你将创建的应用

我们将构建一个使用 Spring Cloud LoadBalancer 的微服务应用，以在对另一个微服务的调用中提供客户端负载均衡。
 

你将需要的工具

  • 大概 15 分钟左右；
  • 你最喜欢的文本编辑器或集成开发环境（IDE）
  • JDK 1.8 或更高版本；
  • Gradle 4+ 或 Maven 3.2+
  • 你还可以将代码直接导入到 IDE 中：
    • Spring Too Suite (STS)
    • IntelliJ IDEA
       

如何完成这个指南

像大多数的 Spring 入门指南一样，你可以从头开始并完成每个步骤，也可以绕过你已经熟悉的基本设置步骤。如论哪种方式，你最终都有可以工作的代码。

  • 要从头开始，移步至用 Gradle 来构建；
  • 要跳过基础，执行以下操作：
    • 下载并解压缩该指南将用到的源代码，或借助 Git 来对其进行克隆操作：git clone https://github.com/spring-guides/gs-spring-cloud-loadbalancer.git
    • 切换至 gs-spring-cloud-loadbalancer/initial 目录；
    • 跳转至该指南的实现 “问好” 服务。

待一切就绪后，可以检查一下 gs-spring-cloud-loadbalancer/complete 目录中的代码。
 

用 Gradle 来构建

首先，我们设置一个基本的构建脚本。在使用 Spring 构建应用时可以使用任何喜欢的构建系统，但此处包含使用 Gradle 和 Maven 所需的代码。如果你都不熟悉，请参阅使用 Gradle 构建 Java 项目或使用 Maven 构建 Java 项目。

创建目录结构

在我们选择的项目目录中，创建以下自目录结构；例如，在 *nix 系统上使用 mkdir -p src/main/java/hello：

└── src└── main└── java└── hello

创建 Gradle 构建文件

以下是初始 Gradle 构建文件。
build.gradle

Spring Boot gradle 插件提供了许多方便的功能：

  • 它收集类路径上的所有 jar，并构建一个可运行的单个超级 jar，这使执行和传输服务更加方便；
  • 它搜索 public static void main() 方法并将其标记为可运行类；
  • 它提供了一个内置的依赖解析器，用于设置版本号以及匹配 Spring Boot 依赖。我们可以覆盖所需的任何版本，但默认为 Boot 选择的一组版本。
     

用 Maven 来构建

首先，我们搭建一个基本的构建脚本。使用 Spring 构建应用时，可以使用任何喜欢的构建系统，但是此处包含了使用 Maven 所需的代码。如果你不熟悉 Maven，请参阅使用 Maven 构建 Java 项目。

创建目录结构

在我们选择的项目目录中，创建以下自目录结构；例如，在 *nix 系统上使用 mkdir -p src/main/java/hello：

└── src└── main└── java└── hello

创建 Maven 构建文件

以下是初始 Maven 构建文件。
pom.xml

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><groupId>org.springframework</groupId><artifactId>gs-spring-cloud-loadbalancer</artifactId><version>0.1.0</version><packaging>pom</packaging><modules><module>say-hello</module><module>user</module></modules></project>

Spring Boot Maven 插件提供了许多方便的功能：

  • 它收集类路径上的所有 jar，并构建一个可运行的单个超级 jar，这使执行和传输服务更加方便；
  • 它搜索 public static void main() 方法并将其标记为可运行类；
  • 它提供了一个内置的依赖解析器，用于设置版本号以及匹配 Spring Boot 依赖。我们可以覆盖所需的任何版本，但默认为 Boot 选择的一组版本。
     

用 IDE 来构建

  • 阅读如何将该指南直接导入 Spring Tool Suite；
  • 阅读如何在 IntelliJ IDEA 中使用该指南。
     

实现 “问好” 服务

我们的 “服务器” 服务称为 “问好”。它将从可通过 /greeting 访问的端点返回随机问候（从三个静态列表中挑选）。

在 src/main/java/hello 中，创建文件 SayHelloApplication.java。它看起来应该像这样：

say-hello/src/main/java/hello/SayHelloApplication.java

package hello;import java.util.Arrays;
import java.util.List;
import java.util.Random;import org.slf4j.Logger;
import org.slf4j.LoggerFactory;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;@RestController
@SpringBootApplication
public class SayHelloApplication {private static Logger log = LoggerFactory.getLogger(SayHelloApplication.class);public static void main(String[] args) {SpringApplication.run(SayHelloApplication.class, args);}@GetMapping("/greeting")public String greet() {log.info("Access /greeting");List<String> greetings = Arrays.asList("Hi there", "Greetings", "Salutations");Random rand = new Random();int randomNum = rand.nextInt(greetings.size());return greetings.get(randomNum);}@GetMapping("/")public String home() {log.info("Access /");return "Hi!";}
}

这是一个简单的 @RestController，其中一个 @RequestMapping 方法用于 /greeting，然后另一个用于根路径 /。

我们将在本地与客户端服务应用一起运行该应用的多个实例，因此创建目录 src/main/resources，在其中创建文件 application.yml，然后在该文件中为 server.port 设置默认值。（我们还将指示该应用的其他示例也可以在其他端口上运行，这样，当我们使该 Say Hello 实例运行时，不会与客户端发生冲突）。在该文件中时，我们还将为我们的服务设置 spring.application.name。

say-hello/src/main/resources/application.yml

spring:application:name: say-helloserver:port: 8090

 

从客户端服务访问

用户将看到 “用户” 应用。它将调用 Say Hello 应用获取问候语，然后在用户访问 /hi 和 /hello 的端点时将其发送给我们的用户。

在用户应用目录的 src/main/java/hello 下，添加文件 UserApplication.java：

user/src/main/java/hello/UserApplication.java

package hello;import reactor.core.publisher.Mono;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.loadbalancer.reactive.ReactorLoadBalancerExchangeFilterFunction;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.reactive.function.client.WebClient;/*** @author Olga Maciaszek-Sharma*/
@SpringBootApplication
@RestController
public class UserApplication {private final WebClient.Builder loadBalancedWebClientBuilder;private final ReactorLoadBalancerExchangeFilterFunction lbFunction;public UserApplication(WebClient.Builder webClientBuilder,ReactorLoadBalancerExchangeFilterFunction lbFunction) {this.loadBalancedWebClientBuilder = webClientBuilder;this.lbFunction = lbFunction;}public static void main(String[] args) {SpringApplication.run(UserApplication.class, args);}@RequestMapping("/hi")public Mono<String> hi(@RequestParam(value = "name", defaultValue = "Mary") String name) {return loadBalancedWebClientBuilder.build().get().uri("http://say-hello/greeting").retrieve().bodyToMono(String.class).map(greeting -> String.format("%s, %s!", greeting, name));}@RequestMapping("/hello")public Mono<String> hello(@RequestParam(value = "name", defaultValue = "John") String name) {return WebClient.builder().filter(lbFunction).build().get().uri("http://say-hello/greeting").retrieve().bodyToMono(String.class).map(greeting -> String.format("%s, %s!", greeting, name));}
}

我们还添加一个 @Configuration 类，在其中将设置负载均衡的 WebClient.Builder 实例：

user/src/main/java/hello/WebClientConfig.java

package hello;import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.cloud.loadbalancer.annotation.LoadBalancerClient;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.reactive.function.client.WebClient;@Configuration
@LoadBalancerClient(name = "say-hello", configuration = SayHelloConfiguration.class)
public class WebClientConfig {@LoadBalanced@BeanWebClient.Builder webClientBuilder() {return WebClient.builder();}}

该配置提供了 @LoadBalanced WebClient.Builder 实例，当有人点击 UserApplication.java 的 hi 端点时使用该实例。命中 hi 端点后，我们将使用该构建器创建一个 WebClient 实例，该实例将用于向 Say Hello 服务的 URL 发出 HTTP GET 请求，并将结果作为 String 提供给我们。

在 UserApplication.java 中，我们还添加了一个 /hello 端点，该端点在下面执行相同的操作，但是，我们没有使用 @Loadbalanced 注解，而是使用了 @Autowired 负载均很器交换过滤函数的 lbFunction，该函数通过 filter() 方法以编程方式构建一个 WebClient 实例。

即使我们为两个端点设置的负载均衡 WebClient 实例略有不同，但两个端点的最终行为是完全相同的。在下面使用 Spring Cloud LoadBalancer 来选择 “Say Hello” 服务的适当实例。

将 spring.application.name 和 server.port 属性添加到 src/main/resources/application.properties 或 src/main/resources/application.yml：

user/src/main/resources/application.yml

spring:application:name: userserver:port: 8888

 

跨服务器实例负载均衡

如我们所见，在 WebClientConfig.java 中，我们使用 @LoadBalancerClient 注解传递了 LoadBalancer 的自定义配置：

@LoadBalancerClient(name = "say-hello", configuration = SayHelloConfiguration.class)。这意味着每当与名为 say-hello 的服务联系时，Spring Cloud LoadBalancer 都将使用 SayHelloConfiguration.java 中提供的配置，而不是使用默认配置运行：

user/src/main/java/hello/SayHelloConfiguration.java

package hello;import java.util.Arrays;
import java.util.List;import reactor.core.publisher.Flux;import org.springframework.cloud.client.DefaultServiceInstance;
import org.springframework.cloud.client.ServiceInstance;
import org.springframework.cloud.loadbalancer.core.ServiceInstanceListSupplier;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;/*** @author Olga Maciaszek-Sharma*/
@Configuration
public class SayHelloConfiguration {@Bean@PrimaryServiceInstanceListSupplier serviceInstanceListSupplier() {return new DemoServiceInstanceListSuppler("say-hello");}}class DemoServiceInstanceListSuppler implements ServiceInstanceListSupplier {private final String serviceId;DemoServiceInstanceListSuppler(String serviceId) {this.serviceId = serviceId;}@Overridepublic String getServiceId() {return serviceId;}@Overridepublic Flux<List<ServiceInstance>> get() {return Flux.just(Arrays.asList(new DefaultServiceInstance(serviceId + "1", serviceId, "localhost", 8090, false),new DefaultServiceInstance(serviceId + "2", serviceId, "localhost", 9092, false),new DefaultServiceInstance(serviceId + "3", serviceId, "localhost", 9999, false)));}
}

这里，我们提供了一个自定义 ServiceInstancedListSupplier，其中包含三个硬编码实例，Spring Cloud LoadBalancer 将在调用 “Say Hello” 服务时从中选择这些实例。

添加了该步骤以说明如何将自己的自定义配置传递给 Spring Cloud LoadBalancer。但是，我们不需要使用 @LoadBalancerClient 注解并为 LoadBalancer 创建自己的配置。最典型的方法是将 Spring Cloud LoadBalancer 与服务发现一起使用。如果我们的类路径上有任何 DiscoveryClient，默认的 Spring Cloud LoadBalancer 配置将在后台使用它来检查服务实例。这样，我们还将仅从已启动并正在运行的实例中进行选择。我们可以通过该指南学习如何使用 ServiceDiscovery。

我们还添加了一个具有默认 server.port 和 spring.application.name 的 application.yml 文件：

user/src/main/resources/application.yml

spring:application:name: userserver:port: 8888

 

尝试一下

可以使用 Gradle 运行 Say Hello 服务：

./gradlew :say-hello:bootRun
SERVER_PORT=9092 ./gradlew :say-hello:bootRun
SERVER_PORT=9999 ./gradlew :say-hello:bootRun
./gradlew :user:bootRun

或 Maven：

./mvnw spring-boot:run -pl say-hello
SERVER_PORT=9092 ./mvnw spring-boot:run -pl say-hello
SERVER_PORT=9999 ./mvnw spring-boot:run -pl say-hello
./mvnw spring-boot:run -pl user

然后启动用户服务。访问 http://localhost:8888/hi，然后查看 Say Hello 服务实例。

而且我们对用户服务的请求应导致对 “问好” 的调用以循环形式分布在正在运行的实例中：

2016-03-09 21:15:28.915  INFO 90046 --- [nio-8090-exec-7] hello.SayHelloApplication                : Access /greeting

 

测试应用

现在该应用正在运行，我们可以对其进行测试。

现在，我们可以在用户服务上访问 /hi 或 /hello 并看到有好的问候：

$ curl http://localhost:8888/hi
Greetings, Mary!$ curl http://localhost:8888/hi?name=Orontes
Salutations, Orontes!

 

概述

恭喜你！我们刚刚开发了一个 Spring 应用！
 

想看指南的其他内容？请访问该指南的所属专栏：《Spring 官方指南》

这篇关于SpringBoot 2 使用 SpringCloud LoadBalancer 实现客户端负载均衡的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/676916。

相关文章

JVM 的类初始化机制

JVM 的类初始化机制

前言 当你在 Java 程序中new对象时，有没有考虑过 JVM 是如何把静态的字节码（byte code）转化为运行时对象的呢，这个问题看似简单，但清楚的同学相信也不会太多，这篇文章首先介绍 JVM 类初始化的机制，然后给出几个易出错的实例来分析，帮助大家更好理解这个知识点。 JVM 将字节码转化为运行时对象分为三个阶段，分别是：loading 、Linking、initialization
阅读更多...
Spring Security 基于表达式的权限控制

Spring Security 基于表达式的权限控制

前言 spring security 3.0已经可以使用spring el表达式来控制授权，允许在表达式中使用复杂的布尔逻辑来控制访问的权限。 常见的表达式 Spring Security可用表达式对象的基类是SecurityExpressionRoot。 表达式描述hasRole([role])用户拥有制定的角色时返回true （Spring security默认会带有ROLE_前缀）,去
阅读更多...
浅析Spring Security认证过程

浅析Spring Security认证过程

类图 为了方便理解Spring Security认证流程，特意画了如下的类图，包含相关的核心认证类 概述 核心验证器 AuthenticationManager 该对象提供了认证方法的入口，接收一个Authentiaton对象作为参数; public interface AuthenticationManager {Authentication authenticate(Authenti
阅读更多...
Spring Security--Architecture Overview

Spring Security--Architecture Overview

1 核心组件 这一节主要介绍一些在Spring Security中常见且核心的Java类，它们之间的依赖，构建起了整个框架。想要理解整个架构，最起码得对这些类眼熟。 1.1 SecurityContextHolder SecurityContextHolder用于存储安全上下文（security context）的信息。当前操作的用户是谁，该用户是否已经被认证，他拥有哪些角色权限…这些都被保
阅读更多...
Spring Security基于数据库验证流程详解

Spring Security基于数据库验证流程详解

Spring Security 校验流程图 相关解释说明（认真看哦） AbstractAuthenticationProcessingFilter 抽象类 /*** 调用 #requiresAuthentication(HttpServletRequest, HttpServletResponse) 决定是否需要进行验证操作。* 如果需要验证，则会调用 #attemptAuthentica
阅读更多...
Spring Security 从入门到进阶系列教程

Spring Security 从入门到进阶系列教程

Spring Security 入门系列 《保护 Web 应用的安全》 《Spring-Security-入门（一）：登录与退出》 《Spring-Security-入门（二）：基于数据库验证》 《Spring-Security-入门（三）：密码加密》 《Spring-Security-入门（四）：自定义-Filter》 《Spring-Security-入门（五）：在 Sprin
阅读更多...
Java架构师知识体认识

Java架构师知识体认识

源码分析 常用设计模式 Proxy代理模式Factory工厂模式Singleton单例模式Delegate委派模式Strategy策略模式Prototype原型模式Template模板模式 Spring5 beans 接口实例化代理Bean操作 Context Ioc容器设计原理及高级特性Aop设计原理Factorybean与Beanfactory Transaction 声明式事物
阅读更多...
中文分词jieba库的使用与实景应用（一）

中文分词jieba库的使用与实景应用（一）

知识星球：https://articles.zsxq.com/id_fxvgc803qmr2.html 目录 一.定义： 精确模式（默认模式）： 全模式： 搜索引擎模式： paddle 模式（基于深度学习的分词模式）： 二 自定义词典 三.文本解析   调整词出现的频率 四. 关键词提取 A. 基于TF-IDF算法的关键词提取 B. 基于TextRank算法的关键词提取
阅读更多...
使用SecondaryNameNode恢复NameNode的数据

使用SecondaryNameNode恢复NameNode的数据

1）需求： NameNode进程挂了并且存储的数据也丢失了，如何恢复NameNode 此种方式恢复的数据可能存在小部分数据的丢失。 2）故障模拟 （1）kill -9 NameNode进程 [lytfly@hadoop102 current]$ kill -9 19886 （2）删除NameNode存储的数据（/opt/module/hadoop-3.1.4/data/tmp/dfs/na
阅读更多...
Hadoop集群数据均衡之磁盘间数据均衡

Hadoop集群数据均衡之磁盘间数据均衡

生产环境，由于硬盘空间不足，往往需要增加一块硬盘。刚加载的硬盘没有数据时，可以执行磁盘数据均衡命令。（Hadoop3.x新特性） plan后面带的节点的名字必须是已经存在的，并且是需要均衡的节点。 如果节点不存在，会报如下错误： 如果节点只有一个硬盘的话，不会创建均衡计划： （1）生成均衡计划 hdfs diskbalancer -plan hadoop102 （2）执行均衡计划 hd
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2