基于Eureka和restTemple的负载均衡

 

在微服务架构中,基于 Eureka(服务注册中心)和 RestTemplate(HTTP 客户端)实现负载均衡是常见的方案,核心是通过 Eureka 获取服务实例列表,再结合负载均衡策略选择具体服务实例进行调用。以下是详细实现方式和原理:

一、核心组件角色

  1. Eureka Server:服务注册中心,负责接收服务提供者的注册信息,并维护服务实例列表(健康状态、网络地址等)。
  2. 服务提供者:向 Eureka Server 注册自身信息(如服务名、IP、端口),并定期发送心跳证明存活。
  3. 服务消费者:通过 Eureka Server 获取目标服务的实例列表,使用 RestTemplate 发起 HTTP 请求,同时结合负载均衡策略选择实例。
  4. RestTemplate:Spring 提供的 HTTP 客户端工具,用于简化服务间的 RESTful 接口调用。
  5. 负载均衡策略:从服务实例列表中选择一个实例的规则(如轮询、随机、权重等)。

二、实现步骤

1. 搭建 Eureka Server
  • 引入依赖(Maven):
<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
</dependency>
  • 启动类注解:添加@EnableEurekaServer开启注册中心功能。
  • 配置文件(application.yml):

    yaml

server:port: 8761  # Eureka Server默认端口
eureka:client:register-with-eureka: false  # 自身不注册到Eurekafetch-registry: false  # 不获取服务列表(纯注册中心模式)server:enable-self-preservation: false  # 关闭自我保护模式(开发环境用)
2. 服务提供者注册到 Eureka
  • 引入依赖

    xml

<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>
  • 启动类注解:添加@EnableEurekaClient(或@SpringBootApplication,Spring Cloud 2.0 + 可省略)。
  • 配置文件

    yaml

spring:application:name: service-provider  # 服务名(消费者将通过该名称调用)
server:port: 8081  # 多个实例需不同端口(如8081、8082)
eureka:client:service-url:defaultZone: http://localhost:8761/eureka/  # Eureka Server地址
  • 启动多个实例:通过--server.port=8081--server.port=8082启动同一服务的多个实例,模拟集群。
3. 服务消费者配置(核心)
  • 引入依赖:除 Eureka Client 依赖外,需添加负载均衡依赖(Spring Cloud 默认集成 Ribbon 作为负载均衡器):

    xml

<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-ribbon</artifactId>
</dependency>
  • 配置 RestTemplate:通过@LoadBalanced注解开启负载均衡功能(底层会自动结合 Ribbon):

    java

    运行

@Configuration
public class RestTemplateConfig {@Bean@LoadBalanced  // 关键:开启负载均衡,自动集成Ribbonpublic RestTemplate restTemplate() {return new RestTemplate();}
}
  • 调用服务:使用服务名(而非具体 IP: 端口)作为 URL,RestTemplate 会自动从 Eureka 获取实例并负载均衡:

    java

    运行

@Service
public class ConsumerService {@Autowiredprivate RestTemplate restTemplate;public String callProvider() {// 服务名"service-provider"对应提供者的spring.application.nameString url = "http://service-provider/hello";  // 无需写具体IP:端口return restTemplate.getForObject(url, String.class);}
}
4. 负载均衡策略配置

默认情况下,Ribbon 使用轮询策略(依次调用每个实例),可通过配置修改策略:

  • 全局配置(所有服务生效):

    yaml

ribbon:NFLoadBalancerRuleClassName: com.netflix.loadbalancer.RandomRule  # 随机策略
  • 针对特定服务配置(仅对 "service-provider" 生效):

    yaml

service-provider:  # 服务名ribbon:NFLoadBalancerRuleClassName: com.netflix.loadbalancer.WeightedResponseTimeRule  # 权重响应时间策略

常见策略类:

  • RoundRobinRule:轮询(默认)
  • RandomRule:随机
  • WeightedResponseTimeRule:根据响应时间加权(响应快的实例权重高)
  • RetryRule:重试机制(失败后重试其他实例)
  • BestAvailableRule:选择并发量最低的实例

三、原理说明

  1. 服务注册与发现

    • 服务提供者启动时,向 Eureka Server 注册自身信息(服务名、IP、端口等)。
    • Eureka Server 维护服务实例列表,并定期检查心跳(默认 30 秒一次),移除无心跳的实例。
    • 服务消费者启动时,向 Eureka Server 订阅服务,定期拉取(默认 30 秒一次)服务实例列表到本地缓存。
  2. 负载均衡执行流程

    • 消费者调用restTemplate.getForObject("http://service-provider/hello")时,@LoadBalanced注解会触发 Ribbon 的拦截器。
    • 拦截器将服务名 "service-provider" 解析为 Eureka 中的实例列表。
    • 根据配置的负载均衡策略(如轮询),从列表中选择一个实例(如 192.168.1.100:8081)。
    • 将 URL 替换为具体 IP: 端口(如http://192.168.1.100:8081/hello),发起实际请求。

四、注意事项

  1. 服务名大小写:Eureka 中服务名默认不区分大小写,但建议统一使用小写(避免配置错误)。
  2. 健康检查:默认 Eureka 仅通过心跳判断存活,可结合 Spring Boot Actuator 开启健康检查(eureka.client.healthcheck.enabled=true),更精准反映服务状态。
  3. 超时配置:当服务响应慢时,需配置 Ribbon 超时(避免请求卡顿):

    yaml

service-provider:ribbon:ConnectTimeout: 2000  # 连接超时(毫秒)ReadTimeout: 5000     # 读取超时(毫秒)

  1. 替代方案:Spring Cloud 中,@LoadBalanced+RestTemplate 的组合可被@FeignClient替代(Feign 默认集成 Ribbon,语法更简洁),但底层负载均衡原理类似。

通过以上配置,即可基于 Eureka 和 RestTemplate 实现服务间的负载均衡调用,提升系统的可用性和扩展性。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。
如若转载,请注明出处:http://www.pswp.cn/bicheng/89712.shtml
繁体地址,请注明出处:http://hk.pswp.cn/bicheng/89712.shtml

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

相关文章

子线程不能直接 new Handler(),而主线程可以

在 Android 中&#xff0c;子线程不能直接 new Handler()&#xff0c;而主线程可以&#xff0c;原因在于 Looper 机制。下面详细解释&#xff1a;1. 为什么主线程可以直接 new Handler()&#xff1f; 主线程&#xff08;UI 线程&#xff09;在启动时&#xff0c;系统会自动调用…

Android无需授权直接访问Android/data目录漏洞

从android11开始&#xff0c;访问/sdcard/Android/data目录需要URI授权&#xff0c;而从更高的版本开始甚至URI权限也被收回&#xff0c;返回“无法使用此文件夹”的提示&#xff0c;这里提供一种方法&#xff0c;可以越权强制访问data目录&#xff0c;当然也包括obb、media等目…

本地部署 Kimi K2 全指南(llama.cpp、vLLM、Docker 三法)

Kimi K2 是 Moonshot AI 于2025年7月11日发布的高性能多专家语言模型&#xff08;MoE&#xff09;&#xff0c;支持最大 128K 上下文&#xff0c;激活参数规模为 32B&#xff0c;具备极强的推理、代码生成与多轮对话能力。自从其权重以多种格式开源以来&#xff0c;许多开发者希…

使用python的pillow模块将图片转化为灰度图和相关的操作

使用python的pillow模块可以将图片转化为灰度图&#xff0c; 可以获取灰度图的特定点值&#xff0c;区域值&#xff0c; 修改值并保存到图片 图片转换为灰度图 from PIL import Image# 打开图片 image Image.open("d://python//2//1.jpg")gray_image image.convert…

【网络安全】大型语言模型(LLMs)及其应用的红队演练指南

未经许可,不得转载。 文章目录 什么是红队演练? 为什么 RAI 红队演练是一项重要实践? 如何开展和规划 LLM 的红队演练 1.测试前的准备 规划:由谁负责测试 规划:测试内容 规划:测试方式 规划:数据记录方式 2.测试过程中 3.每轮测试后 报告数据 区分“识别”与“测量” 本…

ROS2安装ros-humble-usb-cam 404错误导致失败的解决方法

ROS2安装ros-humble-usb-cam遇到404错误导致安装失败&#xff0c;如图&#xff1a;解决方法&#xff1a; 备份 sources.list sudo cp /etc/apt/sources.list.d/ros2.list /etc/apt/sources.list.d/ros2.list.bak替换为清华源 sudo sed -i s|http://packages.ros.org/ros2/ubunt…

OllyDbg技巧学习

1 尝试在反汇编代码中找到一个函数的二进制代码 有的时候需要一个函数的二进制代码&#xff0c;注入到另外的一些地方&#xff1b;以此程序为示例&#xff0c; 八叉树的C实现与原理解析-CSDN博客 Ollydbg打开可执行文件&#xff0c;我想先找到此函数的二进制代码体&#xff0…

数据分析智能体:让AI成为你的数据科学家

数据分析智能体&#xff1a;让AI成为你的数据科学家 &#x1f31f; 嗨&#xff0c;我是IRpickstars&#xff01; &#x1f30c; 总有一行代码&#xff0c;能点亮万千星辰。 &#x1f50d; 在技术的宇宙中&#xff0c;我愿做永不停歇的探索者。 ✨ 用代码丈量世界&#xff0c…

K8s与Helm实战:从入门到精通

Kubernetes 简介 Kubernetes(简称 K8s)是一个开源的容器编排平台,用于自动化部署、扩展和管理容器化应用。最初由 Google 设计并捐赠给云原生计算基金会(CNCF),现已成为容器编排领域的事实标准。 核心功能 自动化容器部署:支持声明式配置和自动化部署,减少人工干预。…

根据ARM手册,分析ARM架构中,原子操作的软硬件实现的底层原理

目录 1.问题背景&#xff1a; 2.原子操作 2.1 硬件操作 2.1.1 LDREX/LDXR指令 2.1.2 STREX/STXR指令 2.2 软件操作 2.3 软件硬件操作的各性能对比 3.总结 1.问题背景&#xff1a; 我们知道&#xff0c;RTOS的任务调度算法是抢占式优先级调度算法。 既然是抢占了&…

iOS 抓包工具选择与配置指南 从零基础到高效调试的完整流程

iOS 抓包&#xff1a;复杂网络调试的必要技能 随着移动端应用越来越依赖网络交互&#xff0c;iOS 抓包作为核心调试工具之一&#xff0c;变得尤为重要。无论是调试 App 与后端的接口通信、排查 HTTPS 请求加密问题&#xff0c;还是定位网络连接超时、请求异常&#xff0c;抓包都…

Java使用FastExcel实现Excel文件导入

依赖配置 (Maven pom.xml)<dependencies><!-- FastExcel 核心库 --><dependency><groupId>cn.idev.excel</groupId><artifactId>fastexcel</artifactId><version>1.0.0</version></dependency><!-- Apache POI…

【60】MFC入门到精通——运行后 button按键上不显示 按键名, 控件上的文字不显示

文章目录运行后&#xff0c;button按键上不显示 “Test”原因是属性&#xff0c;图标–>True&#xff0c;改为False就好了。

抖音回应:没有自建外卖,就是在团购的基础上增加的配送功能

今年以来&#xff0c;外卖行业竞争愈加激烈&#xff0c;市场格局风云变幻。在这一背景下&#xff0c;外卖行业动向备受关注。近日&#xff0c;针对抖音上线团购版外卖的消息引发公众关注。为此&#xff0c;大公科技以商家身份咨询了抖店客服&#xff0c;对方回应称&#xff0c;…

中间件安全攻防全解:从Tomcat到Weblogic反序列化漏洞介绍

本文仅用于技术研究&#xff0c;禁止用于非法用途。 Author:枷锁 文章目录什么是中间件中间件漏洞(1) Tomcat(2) Weblogic(3) JBoss漏洞什么是中间件 中间件&#xff08;Middleware&#xff09;是指一种软件组件&#xff0c;其作用是在不同的系统、应用程序或服务之间传递数据…

现代前端开发流程:CI/CD与自动化部署实战

目录 引言现代前端开发面临的挑战CI/CD基础概念前端CI/CD流程设计实战案例&#xff1a;构建前端CI/CD管道自动化部署策略监控与回滚机制最佳实践与优化建议总结 引言 随着前端技术的飞速发展&#xff0c;现代Web应用变得越来越复杂。前端项目不再只是简单的HTML、CSS和JavaS…

MySQL EXPLAIN深度解析:优化SQL性能的核心利器

MySQL EXPLAIN深度解析&#xff1a;优化SQL性能的核心利器 引言&#xff1a;数据库性能优化的关键 在数据库应用开发中&#xff0c;SQL查询性能往往是系统瓶颈的关键所在。当面对慢查询问题时&#xff0c;EXPLAIN命令就像数据库工程师的X光机&#xff0c;能够透视SQL语句的执行…

Sentinel配置Nacos持久化

前言&#xff1a; Sentinel在使用控制台时进行配置是纯内存操作&#xff0c;并没有提供默认的持久化措施&#xff0c;一旦服务重启会导致配置的流控、熔断等策略失效。Sentinel官方提供了多种持久化方式如&#xff1a;Redis、Zookeeper、Etcd、Nacos以及其他方式等。此文以Naco…

Java学习第五十五部分——在软件开发中的作用

目录 一. 前言提要 二. 主要作用 1. 跨平台能力&#xff08;核心优势&#xff09; 2. 企业级应用开发&#xff08;主导领域&#xff09; 3. 安卓应用开发&#xff08;关键角色&#xff09; 4. 大数据处理&#xff08;重要组件&#xff09; 5. 嵌入式系统 & IoT 6. 桌…

Keil编译文件格式转换全解析

目录 介绍 Keil自带常用命令概览 fromelf介绍 Keil可烧录文件概述 核心差异概览 .axf文件获取 .hex文件获取 .bin文件生成 ​编辑 补充:生成可执行文件的汇编代码&#xff08;.asm文件&#xff09; Keil自带常用命令详解 核心功能​​ ​​格式转换​​ ​​输出路…