SpringBoot实战（二十四）集成 LoadBalancer

目录

  • 官方文档： https://spring.io/guides/gs/spring-cloud-loadbalancer/
  • GitHub： https://github.com/spring-cloud/spring-cloud-commons/tree/main/spring-cloud-loadbalancer

一、简介

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: 8081spring:application:name: loadbalancer-consumer#eureka client
eureka:client:service-url:defaultZone: http://demo:Demo2023@localhost:1001/eureka/instance:hostname: localhostprefer-ip-address: true # 是否使用 ip 地址注册instance-id: ${spring.cloud.client.ip-address}:${server.port} # ip:portlease-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@LoadBalancedpublic 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 {@Autowiredprivate 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: 8082spring:application:name: loadbalancer-producer#eureka client
eureka:client:service-url:defaultZone: http://demo:Demo2023@localhost:1001/eureka/instance:hostname: localhostprefer-ip-address: true # 是否使用 ip 地址注册instance-id: ${spring.cloud.client.ip-address}:${server.port} # ip:portlease-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: 8081spring:application:name: loadbalancer-feign-a#eureka client
eureka:client:service-url:defaultZone: http://demo:Demo2023@localhost:1001/eureka/instance:hostname: localhostprefer-ip-address: true # 是否使用 ip 地址注册instance-id: ${spring.cloud.client.ip-address}:${server.port} # ip:portlease-renewal-interval-in-seconds: 5 # 实例续期心跳间隔（默认30s），设置之后启动服务不需要等很久就可以访问到服务的内容lease-expiration-duration-in-seconds: 15 # 实例续期持续多久后失效（默认90s）##feign参数优化
feign:client:config:# 这里用 default 就是全局配置，如果是写服务名称，则是针对某个服务的配置。default:# 日志级别（忽略大小写），包括：NONE（默认）、BASIC、HEADERS、FULLloggerLevel: 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;@Autowiredprivate 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: 8082spring:application:name: loadbalancer-feign-b#eureka client
eureka:client:service-url:defaultZone: http://demo:Demo2023@localhost:1001/eureka/instance:hostname: localhostprefer-ip-address: true # 是否使用 ip 地址注册instance-id: ${spring.cloud.client.ip-address}:${server.port} # ip:portlease-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

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.rhkb.cn/news/135899.html

如若内容造成侵权/违法违规/事实不符，请联系长河编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

计算机专业毕业设计项目推荐07-科研成果管理系统（JavaSpringBoot+Vue+Mysql）

计算机专业毕业设计项目推荐07-科研成果管理系统（JavaSpringBoot+Vue+Mysql）

科研成果管理系统&#xff08;JavaSpringBootVueMysql&#xff09; **介绍****系统总体开发情况-功能模块****各部分模块实现****最后想说的****联系方式** 介绍 本系列(后期可能博主会统一为专栏)博文献给即将毕业的计算机专业同学们,因为博主自身本科和硕士也是科班出生,所以…
阅读更多...
Mybatis学习笔记8 查询返回专题

Mybatis学习笔记8 查询返回专题

1.返回实体类 2.返回List<实体类> 3.返回Map 4.返回List<Map> 5.返回Map<String,Map> 6.resultMap结果集映射 7.返回总记录条数 新建模块 依赖 目录结构 1.返回实体类 如果返回多条,用单个实体接收会出异常 2.返回List<实体类> 即使返回一条记…
阅读更多...
​bing许少辉乡村振兴战略下传统村落文化旅游设计images

​bing许少辉乡村振兴战略下传统村落文化旅游设计images

​bing许少辉乡村振兴战略下传统村落文化旅游设计images
阅读更多...
PHP8的类与对象的基本操作之成员方法-PHP8知识详解

PHP8的类与对象的基本操作之成员方法-PHP8知识详解

成员方法是指在类中声明的函数。 在类中可以声明多个函数&#xff0c;所以对象中可以存在多个成员方法。类的成员方法可以通过关键字进行修饰&#xff0c;从而控制成员方法的商用权限。 函数和成员方法唯一的区别就是&#xff0c;函数实现的是某个独立的功能&#xff0c;而成…
阅读更多...
【Gradle-8】Gradle插件开发指南

【Gradle-8】Gradle插件开发指南

1、前言 Gradle插件开发在Android进阶知识中是占有一定比例的&#xff0c;特别是在性能优化领域&#xff0c;基本都会涉及&#xff0c;而且跟我们日常的编译打包也息息相关&#xff0c;加上有不少招聘要求里也明确要有Gradle插件开发经验&#xff0c;所以即使大部分人的日常开…
阅读更多...
Vue3_vite

Vue3_vite

使用Vue-cli创建 使用vite创建 Composition API 组合API setup 1.Vue3中的一个新的配置项,值为一个函数 2.可以将组件中所用到的数据,方法等配置在setup中. 3.setup函数的两种返回值 3.1若返回一个对象,则对象中的属性,方法,在模板中均可以直接使用. 3.2若返回一个渲染函数…
阅读更多...
【数据库系统概论】数据模型

【数据库系统概论】数据模型

数据模型是什么两类数据模型两步抽象概念模型数据模型 常用的数据模型感谢 &#x1f496; 数据模型是什么 模型是对现实世界中某个对象特征的模拟和抽象。比如飞机模型就体现了飞机的特性&#xff0c;它模拟飞机的起飞、飞行和降落&#xff0c;它抽象了飞机的基本特征——机头…
阅读更多...
前端录入音频并上传

前端录入音频并上传

目录 纯 js 实现&#xff08;有问题&#xff09;使用插件 recorder-core &#xff08;没问题&#xff09; 纯 js 实现&#xff08;有问题&#xff09; 上传音频文件时 blob 数据中 size 一直是0&#xff0c;导致上传之后音频不可播放&#xff08;本地录制后本地是可以播放的&am…
阅读更多...
【基于MBD开发模式的matlab持续集成（一）】

【基于MBD开发模式的matlab持续集成（一）】

基于MBD开发模式的matlab持续集成 引言 或许是感受到行业内卷的愈加激烈&#xff0c;在传统制造和高新技术相结合的新能源领域对软件工程开发的要求也愈加提高&#xff0c;尤其在互联网已经大行 其道的敏捷开发&#xff0c;便顺其自然的被新能源的老板们所看重。 概述 本文…
阅读更多...
浅述数据中心供配电系统解决方案及产品选型

浅述数据中心供配电系统解决方案及产品选型

安科瑞 华楠 【摘 要】现如今&#xff0c;社会主要领域已从对单个设备的关注转化为对于系统解决方案的关注&#xff0c;数据中心的供应商们也想尽办法去满足所面对的各方面需求。基于此&#xff0c;主要提出了云计算数据中心供配电解决方案&#xff0c;同时还对数据中心供配电…
阅读更多...
系统架构设计师（第二版）学习笔记----信息安全系统及信息安全技术

系统架构设计师（第二版）学习笔记----信息安全系统及信息安全技术

【原文链接】系统架构设计师&#xff08;第二版&#xff09;学习笔记----信息加解密技术 文章目录 一、信息安全系统的组成框架1.1 信息安全系统组成框架1.2 信息安全系统技术内容1.3 常用的基础安全设备1.4 网络安全技术内容1.5 操作系统安全内容1.6 操作系统安全机制1.7 数据…
阅读更多...
I Pa?sWorD

I Pa?sWorD

2023icpc网络赛第一场 I 题意&#xff1a;题目给出只包含大小写字母&#xff0c;数字以及?的字符串&#xff0c;对于每一个小写字母&#xff0c;这一位字符既有可能是该小写字母&#xff0c;也有可能是该小写字母的对应大写字母&#xff0c;也就是该位的字符有两种可能&#x…
阅读更多...
Android studio Mac 快捷键对应截图

Android studio Mac 快捷键对应截图

Android
阅读更多...
基于Java+SpringBoot+Vue的旧物置换网站设计和实现

基于Java+SpringBoot+Vue的旧物置换网站设计和实现

基于JavaSpringBootVue的旧物置换网站设计和实现 源码传送入口前言主要技术系统设计功能截图数据库设计代码论文目录订阅经典源码专栏Java项目精品实战案例《500套》 源码获取 源码传送入口 前言 摘 要 随着时代在一步一步在进步&#xff0c;旧物也成人们的烦恼&#xff0c;…
阅读更多...
多线程的学习上篇

多线程的学习上篇

座右铭: 天行健&#xff0c;君子以自强不息;地势坤&#xff0c;君子以厚德载物. 引入进程这个概念的目的 引入进程这个概念,最主要的目的,是为了解决“并发编程"这样的问题. 这是因为CPU进入了多核心的时代 要想进一步提高程序的执行速度,就需要充分的利用CPU 的多核资源…
阅读更多...
《PostgreSQL中的JSON处理：技巧与应用》

《PostgreSQL中的JSON处理：技巧与应用》

&#x1f337;&#x1f341; 博主猫头虎&#xff08;&#x1f405;&#x1f43e;&#xff09;带您 Go to New World✨&#x1f341; &#x1f405;&#x1f43e;猫头虎建议程序员必备技术栈一览表&#x1f4d6;&#xff1a; &#x1f6e0;️ 全栈技术 Full Stack: &#x1f4da…
阅读更多...
为什么qt设置了utf-8 bom 格式后还是有乱码

为什么qt设置了utf-8 bom 格式后还是有乱码

有乱码 void SingleApplication::_showInstanceRunningDialog() {// 创建一个提示窗口QMessageBox msgBox;msgBox.setIcon(QMessageBox::Information);msgBox.setWindowTitle("应用已运行");msgBox.setText("应用程序已经在运行中。");msgBox.setStandardB…
阅读更多...
【深度学习实验】线性模型（二）：使用NumPy实现线性模型：梯度下降法

【深度学习实验】线性模型（二）：使用NumPy实现线性模型：梯度下降法

目录 一、实验介绍 二、实验环境 1. 配置虚拟环境 2. 库版本介绍 三、实验内容 0. 导入库 1. 初始化参数 2. 线性模型 linear_model 3. 损失函数loss_function 4. 梯度计算函数compute_gradients 5. 梯度下降函数gradient_descent 6. 调用函数 一、实验介绍 使用Nu…
阅读更多...
RocketMQ 发送顺序消息

RocketMQ 发送顺序消息

文章目录 顺序消息应用场景消息组&#xff08;MessageGroup&#xff09;顺序性生产的顺序性MQ 存储的顺序性消费的顺序性 rocketmq-client-java 示例&#xff08;gRPC 协议&#xff09;1. 创建 FIFO 主题生产者代码消费者代码解决办法解决后执行结果 rocketmq-client 示例&…
阅读更多...
【结构型】代理模式(Proxy)

【结构型】代理模式(Proxy)

目录 代理模式(Proxy)适用场景代理模式实例代码&#xff08;Java&#xff09; 代理模式(Proxy) 为其他对象提供一种代理以控制对这个对象的访问。Proxy 模式适用于在需要比较通用和复杂的对象指针代替简单的指针的时候。 适用场景 远程代理 (Remote Proxy) 为一个对象在不同…
阅读更多...
最新文章
推荐文章

Copyright @ 2022~2023