当前位置: 首页 > news >正文

微服务项目远程调用时的负载均衡是如何实现的?

负载均衡概述

负载均衡是微服务架构中的核心组件,用于将请求合理分配到多个服务实例上,提高系统的可用性和性能。


负载均衡的分类

负载均衡大致可以分为两类

1. 服务端负载均衡

  • 实现位置:独立部署的负载均衡服务器(位于客户端和服务端之间)
  • 工作原理:客户端请求先到达负载均衡器,由负载均衡器选择具体的服务实例
  • 代表产品:Nginx、HAProxy、F5、阿里云SLB
  • 优点:集中管理、配置简单
  • 缺点:增加网络延迟、单点故障风险
客户端
负载均衡器
Nginx/HAProxy/F5
服务实例1
192.168.1.10:8080
服务实例2
192.168.1.11:8080
服务实例3
192.168.1.12:8080

2. 客户端负载均衡

  • 实现位置:集成在客户端应用程序内部
  • 工作原理:客户端维护服务提供者列表,根据算法选择服务实例
  • 代表产品:Ribbon、Spring Cloud LoadBalancer
  • 优点:无单点故障、减少网络跳转
  • 缺点:客户端复杂度增加
获取服务列表
服务注册
服务注册
服务注册
客户端应用
内置负载均衡组件
Ribbon/LoadBalancer
注册中心
Eureka/Nacos
服务实例1
payment-service:8001
服务实例2
payment-service:8002
服务实例3
payment-service:8003

Spring Cloud中的负载均衡实现

1. Feign + Ribbon(Spring Cloud 2020之前)

// 依赖配置
<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-openfeign</artifactId>
</dependency>
<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-ribbon</artifactId>
</dependency>// 主启动类
@SpringBootApplication
@EnableFeignClients
public class OrderApplication {public static void main(String[] args) {SpringApplication.run(OrderApplication.class, args);}
}// Feign客户端定义
@FeignClient(name = "payment-service")
public interface PaymentService {@GetMapping("/payment/get/{id}")String getPaymentById(@PathVariable("id") Long id);
}

工作原理

  1. Feign接收到对服务名(“payment-service”)的调用请求
  2. Ribbon的LoadBalancerFeignClient通过拦截器机制自动拦截HTTP请求,识别服务名
  3. Ribbon从服务注册中心获取该服务(“payment-service”)的可用实例列表
  4. 使用默认的轮询算法或配置的其他算法选择目标实例
  5. 将HTTP请求路由到选中的服务实例并返回结果

2. Feign + Spring Cloud LoadBalancer(Spring Cloud 2020之后)

// 依赖配置
<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-openfeign</artifactId>
</dependency>
<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-loadbalancer</artifactId>
</dependency>// 主启动类
@SpringBootApplication
@EnableFeignClients
public class OrderApplication {public static void main(String[] args) {SpringApplication.run(OrderApplication.class, args);}
}// Feign客户端定义
@FeignClient(name = "payment-service")
public interface PaymentService {@GetMapping("/payment/get/{id}")String getPaymentById(@PathVariable("id") Long id);
}

工作原理

  1. Feign接收到对服务名(“payment-service”)的调用请求
  2. Spring Cloud LoadBalancer的LoadBalancerInterceptor通过拦截器机制自动拦截HTTP请求,提取服务名
  3. Spring Cloud LoadBalancer从服务注册中心获取该服务(“payment-service”)的可用实例列表
  4. 使用轮询算法或配置的其他算法选择目标实例
  5. 将HTTP请求路由到选中的服务实例并返回结果

3. Feign + 自定义负载均衡策略

// 依赖配置
<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-openfeign</artifactId>
</dependency>
<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-loadbalancer</artifactId>
</dependency>// 主启动类
@SpringBootApplication
@EnableFeignClients
public class OrderApplication {public static void main(String[] args) {SpringApplication.run(OrderApplication.class, args);}
}// 自定义负载均衡配置
@Configuration
public class CustomLoadBalancerConfig {@Beanpublic ReactorLoadBalancer<ServiceInstance> randomLoadBalancer(Environment environment,LoadBalancerClientFactory clientFactory) {String name = environment.getProperty(LoadBalancerClientFactory.PROPERTY_NAME);return new RandomLoadBalancer(clientFactory.getLazyProvider(name, ServiceInstanceListSupplier.class), name);}
}// Feign客户端定义
@FeignClient(name = "payment-service", configuration = CustomLoadBalancerConfig.class)
public interface PaymentService {@GetMapping("/payment/get/{id}")String getPaymentById(@PathVariable("id") Long id);
}

工作原理

  1. Feign接收到对服务名(“payment-service”)的调用请求
  2. Spring Cloud LoadBalancer的LoadBalancerInterceptor通过拦截器机制自动拦截HTTP请求,并提取服务名
  3. 自定义LoadBalancer从服务注册中心获取该服务(“payment-service”)的可用实例列表
  4. 使用自定义负载均衡策略选择目标实例
  5. 将HTTP请求路由到选中的服务实例并返回结果
http://www.lryc.cn/news/584575.html

相关文章:

  • Prompt提示词的主要类型和核心原则
  • 【WEB】Polar靶场 Day8 详细笔记
  • Docker 镜像加速站汇总与使用指南
  • SpringBoot系列—MyBatis(xml使用)
  • Flink自定义函数
  • 一个编辑功能所引发的一场知识探索学习之旅(JavaScript、HTML)
  • Android 插件化实现原理详解
  • 虚拟储能与分布式光伏协同优化:新型电力系统的灵活性解决方案
  • Datawhale AI 夏令营:基于带货视频评论的用户洞察挑战赛 Notebook(下篇)
  • Chromium 引擎启用 Skia Graphite后性能飙升
  • 【TGRS 2025】新型:残差Haar离散小波变换下采样,即插即用!
  • 从零构建MVVM框架:深入解析前端数据绑定原理
  • 深入理解 Linux 中的 stat 函数与文件属性操作
  • NGINX系统基于PHP部署应用
  • 开发需要写单元测试吗?
  • Camera2API笔记
  • 记录一下openGauss自启动的设置
  • 《测试开发:从技术角度提升测试效率与质量》
  • io_helper说明
  • 使用Word/Excel管理需求的10个痛点及解决方案Perforce ALM
  • 二层环路避免-STP技术
  • LangChain框架 Prompts、Agents 应用
  • Selenium 4 教程:自动化 WebDriver 管理与 Cookie 提取 || 用于解决chromedriver版本不匹配问题
  • C++实习面试题
  • dexie 前端数据库封装
  • 【前端】jQuery数组合并去重方法总结
  • MinerU2将PDF转成md文件,并分拣图片
  • uniapp滚动组件, HuimayunScroll:高性能移动端滚动组件的设计与实现
  • 【Fargo】发送一个rtp包的过程1:怎么统一加twcc序号
  • 创始人IP如何进阶?三次关键突破实现高效转化