SpringBoot实战（二十四）集成 LoadBalancer

2023-09-18 10:45:52

目录

一、简介

1.定义

Spring Cloud LoadBalancer 是 Spring Cloud 框架提供的负载均衡组件，用于在微服务框架中实现服务之间的负载均衡。

2.取代 Ribbon

Spring Cloud LoadBalancer 的设计目标是简化和统一负载均衡的使用方式，并提供良好的扩展性。从 Spring Cloud 2020.0 版本、Spring Boot 2.4.x 版本开始，Spring Boot 框架官方放弃了对 Ribbon 的支持，转而使用 Spring Cloud LoadBalancer 作为默认的负载均衡器。虽然提供了与 Ribbon 类似的功能，但是与 Ribbon 相比，Spring Cloud LoadBalancer 具有更轻量级的实现，更好的性能表现，并且更适合与 Spring Cloud Gateway 等其他组件集成使用。

3.主要特点与功能

Spring Cloud LoadBalancer 的主要特点和功能包括：

1）简化集成：Spring Cloud LoadBalancer 可以与 Spring Cloud 服务注册与发现组件（如 Eureka、Consul）集成，从注册中心获取服务信息，并进行负载均衡。
2）内置负载均衡策略：Spring Cloud LoadBalancer 提供了一些内置的负载均衡策略，如轮询（Round Robin）、随机（Random） 等，可以根据需要选择合适的负载均衡策略。
3）定制负载均衡策略：Spring Cloud LoadBalancer 还支持定制负载均衡策略，开发人员可以根据实际需求自定义负载均衡算法。
4）故障转移：当某个服务节点不可用时，Spring Cloud LoadBalancer 可以自动将请求发送到其他可用的节点，提高系统的可靠性和容错性。
5）可扩展性：Spring Cloud LoadBalancer 提供了扩展点，开发人员可以根据需要进行扩展和定制，以满足特定的负载均衡需求。

在使用 Spring Cloud LoadBalancer 时，可以通过相关的依赖和配置来进行集成和使用。它可以与其他 Spring Cloud 组件（如 Spring Cloud Gateway、Spring Cloud OpenFeign 等）一起使用，为应用程序提供完整的微服务环境。

4.LoadBalancer 和 OpenFeign 的关系

很多人一直认为 OpenFeign 和 LoadBalancer 的关系就是简单的包含，其实这种看法是错误的。我们可以看看 Spring Cloud 里产品 Map 图里的关系，就一目了然了。

在这里插入图片描述

OpenFeign 的定位是 annotation 化的 RESTFUL Client。需要认识到 OpenFeign 的本质其实是 Spring Cloud 里面比 RestTemplate 更高阶的一个升级组件，实现的是 RESTFUL Client，只是通过 Open Feign 的一些 annotaion 可以实现的比较简单而已。

在这里插入图片描述

而 LoadBalancer 是 Spring Cloud 里的一个 Common 组件，是可以给其他组件提供服务的基础组件。使用 LoadBalancer 无需 Open Feign 的集成，打开 LoadBalancer 的支持功能，有关 RestTemplate 的地方就可以实现客户端的负载均衡了，OpenFeign 是 RestTemplate 的扩展，当然也就同样可以支持到负载均衡。

细心的朋友可以发现，咱们下面介绍的有关 Loadbalance 的使用，基本上都是和 OpenFeign 没有任何联系的； OpenFeign 只是我们后来进行验证效果的方式。

二、使用场景一：Eureka + LoadBalancer

服务架构图如下：

在这里插入图片描述

服务列表如下：

在这里插入图片描述

服务A：loadbalancer-consumer 消费者

1.Maven依赖

注意：这里的 LoadBalancer 依赖必须引入，否则即使编译不报错，负载均衡也是失效的。

<!-- Web -->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-test</artifactId>
    <scope>test</scope>
</dependency>

<!-- Eureka -->
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>

<!-- LoadBalancer -->
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-loadbalancer</artifactId>
</dependency>
2.application.yml配置
server:
  port: 8081

spring:
  application:
    name: loadbalancer-consumer

#eureka client
eureka:
  client:
    service-url:
      defaultZone: http://demo:Demo2023@localhost:1001/eureka/
  instance:
    hostname: localhost
    prefer-ip-address: true # 是否使用 ip 地址注册
    instance-id: ${spring.cloud.client.ip-address}:${server.port} # ip:port
    lease-renewal-interval-in-seconds: 5 # 实例续期心跳间隔（默认30s），设置之后启动服务不需要等很久就可以访问到服务的内容
    lease-expiration-duration-in-seconds: 15 # 实例续期持续多久后失效（默认90s）
3.RestTemplateConfig.java
import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.client.RestTemplate;

/**
 * <p> @Title RestTemplateConfig
 * <p> @Description RestTemplate配置类
 *
 * @author zhj
 * @date 2023/9/17 20:58
 */
@Configuration
public class RestTemplateConfig {

    @Bean
    @LoadBalanced
    public RestTemplate restTemplate() {
        return new RestTemplate();
    }
}
4.DemoController.java
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;

/**
 * <p> @Title DemoController
 * <p> @Description 测试Controller
 *
 * @author ACGkaka
 * @date 2023/4/24 18:02
 */
@Slf4j
@RestController
@RequestMapping("/demo")
public class DemoController {

    @Autowired
    private RestTemplate restTemplate;

    @RequestMapping("/consumeTest")
    public Object test() {
        log.info(">>>>>>>>>>【INFO】DemoController.consumeTest()...");
        String url = "http://loadbalancer-producer/demo/produceTest";
        return restTemplate.getForObject(url, Object.class);
    }
}

服务B：loadbalancer-producer 生产者

1.Maven依赖
<!-- Web -->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-test</artifactId>
    <scope>test</scope>
</dependency>

<!-- Eureka -->
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>
2.application.yml配置
server:
  port: 8082

spring:
  application:
    name: loadbalancer-producer

#eureka client
eureka:
  client:
    service-url:
      defaultZone: http://demo:Demo2023@localhost:1001/eureka/
  instance:
    hostname: localhost
    prefer-ip-address: true # 是否使用 ip 地址注册
    instance-id: ${spring.cloud.client.ip-address}:${server.port} # ip:port
    lease-renewal-interval-in-seconds: 5 # 实例续期心跳间隔（默认30s），设置之后启动服务不需要等很久就可以访问到服务的内容
    lease-expiration-duration-in-seconds: 15 # 实例续期持续多久后失效（默认90s）
3.DemoController.java
import com.demo.common.Result;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

/**
 * <p> @Title DemoController
 * <p> @Description 测试Controller
 *
 * @author ACGkaka
 * @date 2023/4/24 18:02
 */
@Slf4j
@RestController
@RequestMapping("/demo")
public class DemoController {

    @Value("${server.port}")
    private String port;

    @RequestMapping("/produceTest")
    public Result<Object> produceTest() {
        Result<Object> result = Result.succeed();
        log.info(">>>>>>>>>>【INFO】DemoController.produceTest()...");
        return result.setData("Hello, I'm from port: " + port);
    }
}

调用测试

请求地址：http://localhost:8081/demo/consumeTest

可以发现分别打印了不同的服务端口，说明负载生效：

在这里插入图片描述

在这里插入图片描述

三、使用场景二：Eureka + LoadBalancer + OpenFeign

服务架构图如下：

在这里插入图片描述

服务列表如下：

在这里插入图片描述

服务A：loadbalancer-feign-a

1.Maven依赖
<!-- Web -->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-test</artifactId>
    <scope>test</scope>
</dependency>

<!-- Eureka -->
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>

<!-- OpenFeign -->
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-openfeign</artifactId>
</dependency>
2.application.yml配置
server:
  port: 8081

spring:
  application:
    name: loadbalancer-feign-a

#eureka client
eureka:
  client:
    service-url:
      defaultZone: http://demo:Demo2023@localhost:1001/eureka/
  instance:
    hostname: localhost
    prefer-ip-address: true # 是否使用 ip 地址注册
    instance-id: ${spring.cloud.client.ip-address}:${server.port} # ip:port
    lease-renewal-interval-in-seconds: 5 # 实例续期心跳间隔（默认30s），设置之后启动服务不需要等很久就可以访问到服务的内容
    lease-expiration-duration-in-seconds: 15 # 实例续期持续多久后失效（默认90s）

##feign参数优化
feign:
  client:
    config:
      # 这里用 default 就是全局配置，如果是写服务名称，则是针对某个服务的配置。
      default:
        # 日志级别（忽略大小写），包括：NONE（默认）、BASIC、HEADERS、FULL
        loggerLevel: FULL
3.DemoController.java
import com.demo.common.Result;
import com.demo.feign.DemoFeignClient;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

@Slf4j
@RestController
@RequestMapping("/demo")
public class DemoController {

    @Value("${server.port:}")
    private String port;

    @Autowired
    private DemoFeignClient demoFeignClient;

    @GetMapping("/feignTest")
    public Result<Object> feignTest() {
        return demoFeignClient.test();
    }
}
4.DemoFeignClient.java
import com.demo.common.Result;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.GetMapping;

@FeignClient(value = "loadbalancer-feign-b")
public interface DemoFeignClient {

    @GetMapping("/demo/test")
    Result<Object> test();
}

服务B：loadbalancer-feign-b

1.Maven依赖
<!-- Web -->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-test</artifactId>
    <scope>test</scope>
</dependency>

<!-- Eureka -->
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>
2.application.yml配置
server:
  port: 8082

spring:
  application:
    name: loadbalancer-feign-b

#eureka client
eureka:
  client:
    service-url:
      defaultZone: http://demo:Demo2023@localhost:1001/eureka/
  instance:
    hostname: localhost
    prefer-ip-address: true # 是否使用 ip 地址注册
    instance-id: ${spring.cloud.client.ip-address}:${server.port} # ip:port
    lease-renewal-interval-in-seconds: 5 # 实例续期心跳间隔（默认30s），设置之后启动服务不需要等很久就可以访问到服务的内容
    lease-expiration-duration-in-seconds: 15 # 实例续期持续多久后失效（默认90s）
3.DemoController.java
import com.demo.common.Result;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

@Slf4j
@RestController
@RequestMapping("/demo")
public class DemoController {

    @Value("${server.port:}")
    private String port;

    @GetMapping("/test")
    public Result<Object> test() {
        String data = "This is a test! port:" + port;
        log.info(">>>>>>>>>> 【INFO】data:{}", data);
        return Result.succeed().setData(data);
    }
}

调用测试

请求地址：http://localhost:8081/demo/feignTest

可以发现分别打印了不同的服务端口，说明负载生效：

在这里插入图片描述

在这里插入图片描述

整理完毕，完结撒花~ 🌻





参考地址：

1.SpringCloud集成LoadBalance，负载均衡，https://blog.csdn.net/inthirties/article/details/126821335

2.SpringBoot 2 使用 SpringCloud LoadBalancer 实现客户端负载均衡，https://blog.csdn.net/stevenchen1989/article/details/105009292

更多推荐

多输入多输出 | MATLAB实现LSSVM最小二乘支持向量机多输入多输出

多输入多输出|MATLAB实现LSSVM最小二乘支持向量机多输入多输出目录多输入多输出|MATLAB实现LSSVM最小二乘支持向量机多输入多输出预测效果基本介绍程序设计往期精彩参考资料预测效果基本介绍MATLAB实现LSSVM最小二乘支持向量机多输入多输出1.data为数据集，10个输入特征，3个输出变量。2.main

安防监控视频系统EasyCVR+AI算法智能分析网关助力智慧校园建设

学生是祖国的未来，学校就是培育学生的地方。随着校园信息化建设的不断发展，信息服务在校园管理中的作用也越来越强。在保障学生安全与校园高效管理上，人工智能做出了极大贡献，旭帆科技安防监控系统/视频汇聚/云存储/AI智能视频分析平台EasyCVR基于互联网、大数据、云计算的智慧管理，为提高校园监管标准，推进学校信息化建设，打

redis桌面连接工具Another Redis Desktop Manager使用介绍

AnotherRedisDesktopManager是一种类似于navicat的数据库连接工具，专门用来连接redis，使用起来非常简单方便，在这里推荐给大家。没有用过这个软件的，首先通过下面的网盘链接下载AnotherRedisDesktopManager百度网盘redis下载地址https://pan.baidu.

基于图的基础推荐方式

文章目录1.基于图的基础推荐方式1.1链路预测（LinkPrediction）1.2什么是路径1.3基于路径的基础链路预测1.4图游走算法DeepWalk1.4.1Word2Vec1.4.2DeepWalk原理1.4.3DeepWalk代码示例1.5图游走算法Node2Vec1.5.1Node2Vec原理1.5.2No

视频编辑SDK：轻松打造专业级视频处理能力

视频编辑SDK是一款强大的技术工具，可以帮助开发者轻松实现视频剪辑、特效处理等功能。美摄科技作为业内知名的视频技术公司，其视频编辑SDK凭借独特的功能和易用性，受到了广大开发者的欢迎。美摄科技的视频编辑SDK支持多种视频格式导入，可实现视频剪辑、拼接、变速、调色等基本功能。同时，它还提供了丰富的特效插件，如文字、滤镜、

python基础

一，什么是pythonPython是一种高级、通用且解释型的编程语言，由GuidovanRossum于1991年首次发布。它具有简洁的语法、清晰的代码结构和强大的功能，被广泛应用于各种领域，包括软件开发、数据分析、人工智能、网络编程等。以下是Python的一些特点和优势：简单易学：Python具有直观、简洁的语法，易于

GDPU 数据结构 天码行空2

实验内容用顺序表实现病历信息的管理与查询功能。具体要求如下:利用教材中定义顺序表类型存储病人病历信息(病历号,姓名，症状)；要求使用头文件。设计顺序表定位查找算法，写成一个函数，完成的功能为:在线性表L中查找数据元素x，如果存在则返回线性表中和x值相等的第1个数据元素的序号；如果不存在，则返回-1。函数定义为intLi

数据结构之-----二叉树

目录本章内容如下：1：树的相关概念与结构2：二叉树的概念与结构3：二叉树的链式结构与实现文章正式开始，让我们一起学习树吧！！一：树的概念树是一种非线性结构，与我们前面所学的顺序表与链表不同，数据元素的对应是1对多的关系，只有一个根结点，且除了根节点其它的结点有且仅有1个前驱结点(父结点)。我们可以将一棵树看作由很多个结

计算机和编程语言初见

学习程序设计的目的是什么呢？不一定要做出一个软件或系统出来，更重要的是理解计算机是如何工作的以及它的长处和短处。计算机本身是无意识的，因此我们要求它为我们做事时：应该将步骤细化、“直”化（规律化）；其实计算机什么也不会，我们必须手把手地教他一步一步的做。而计算机的某个优点也正是如此——听话，你叫它往东它绝不往西。然后我

Stellar Toolkit for MySQL 9.0 Crack 3in1

面向数据库管理员的MySQL工具包StellarToolkitforMySQL是一款三合一软件套件，用于修复损坏的MySQL和MariaDB数据库、从MySQL数据库的InnoDB和MyISAM表恢复数据以及分析MySQL数据库日志文件。该软件还可以以最高的安全性和完整性相互转换MySQL/MariaDB、MSSQL(

【跟晓月学数据库】基于book库的mysql进阶实战

前言上篇文章中，我们已经导入了book库，如果你还没有导入book库，参考：【跟晓月学数据库】使用MySQLdump对数据导入导出这篇文章，主要是基于book库的操作，希望对你有用。🏠个人主页：我是沐风晓月🧑个人简介：大家好，我是沐风晓月，阿里云社区专家博主😉😉💕座右铭：先努力成长自己，再帮助更多的人，一起加

热文推荐
  1. 设计模式：责任链模式

    目录组件代码示例源码中使用优缺点总结责任链模式（ChainofResponsibilityPattern）是一种行为型设计模式，它允许多个对象按照顺序处理请求，直到其中一个对象能够处理该请求为止。责任链模式将请求发送者和接收者解耦，使得多个对象都有机会处理请求，同时避免了请求发送者与接收者之间的直接耦合关系。在责任链模

  2. influxdb2.7基本介绍安装与启动

    概念timestamp:influxdb所有的数据都会有一个列_time来存timestamp。默认是以nanosecond格式存储的。field:field就是mysql中的字段，fieldkey存储在_field字段中，fieldvalue就是字段值，存储在_value字段中。fieldkey和fieldvalue

  3. 如何在微软Edge浏览器上一键观看高清视频？

    编者按：视频是当下最流行的媒体形式之一。但由于视频压缩、网络不稳定等原因，我们常常可以看到互联网上的很多视频其画面质量并不理想，尤其是在浏览器端，这极大地影响了观看体验。不过，近期微软Edge浏览器推出了一项新功能，一键就可以让浏览器中的视频变为高清版。这项神奇功能背后的技术秘诀是什么？今天，让我们一起来了解一下微软E

  4. selenium学习

    selenium模块和爬虫之间的关联便捷的获取网站中动态加载的数据便捷实现模拟登录什么是selenium模块基于浏览器自动化的一个模块selenium使用流程：-环境安装：pipinstallselenium-下载一个浏览器的驱动程序（谷歌浏览器）-下载路径：http://chromedriver.storage.go

  5. C++版本的OpenCV实现二维图像的卷积定理(通过傅里叶变换实现二维图像的卷积过程，附代码！！)

    C++版本的OpenCV库实现二维图像的卷积定理过程详解前言一、卷积定理简单介绍二、不同卷积过程对应的傅里叶变换过程1、“Same”卷积2、“Full”卷积3、“Valid”卷积三、基于OpenCV库实现的二维图像卷积定理四、基于FFTW库实现的二维图像卷积定理五、总结与讨论前言工作中用到许多卷积过程，需要转成C++代

  6. SpringBoot的配置环境属性

    SpringBoot的配置环境属性在本文中，我们将讨论SpringBoot的配置环境属性。我们将了解如何使用这些属性来配置我们的应用程序，以便在不同的环境中运行。我们还将了解如何使用SpringBoot的配置文件来管理这些属性。最后，我们将介绍一些最佳实践，以帮助您更有效地使用这些属性。理解SpringBoot的配置环

  7. 《C和指针》笔记28：可变参数和stdarg宏

    可变参数列表可以通过宏来实现，这些宏定义于stdarg.h头文件，它是标准库的一部分。这个头文件声明了一个类型va_list和三个宏——va_start、va_arg和va_end。我们可以声明一个类型为va_list的变量，与这几个宏配合使用，访问参数的值。下面的程序使用这三个宏计算指定数量的值的平均值。注意参数列表

  8. linux和windows选哪个？

    linux和windows选哪个？每年在大学中都会有这么一批学生：沉浸在安装Linux系统，安装双系统，使用Linux系统看看电影，搞一搞炫酷的桌面效果。最后收获了啥？怕是啥也没有，命令学会了几个？能不能写shell？这些才有点价值。最近很多小伙伴找我，说想要一些linux学习资料，然后我根据自己从业十年经验，熬夜搞了

  9. 【第四阶段】kotlin语言的Map集合学习

    1.Map集合的创建packageKotlin.Stage4funmain(){valmap=mapOf("java"to1,"kotlin"to2)//java代表键1代表值valmap2=mapOf(Pair("java",1),Pair("kotlin",2))//和上面写法等价}2.读取map的值方式1：使用[