博客
关于我
【4】ribbon负载均衡
阅读量:227 次
发布时间:2019-02-28

本文共 1334 字,大约阅读时间需要 4 分钟。

Spring Cloud Ribbon 提供了一种简便的方式来实现客户端负载均衡在微服务架构中的使用。以下是使用步骤和相关配置说明:

使用步骤概述

  • 服务提供者配置

    • 需要启动多个服务实例,并将它们注册到一个或多个相关联的服务注册中心(如Eureka)。
  • 服务消费者配置

    • 在消费者应用中,通过使用被 @LoadBalanced 注解修饰的 RestTemplate 进行远程调用。
  • 详细配置步骤

  • 引入依赖:在客户端的 pom.xml 中添加 spring-cloud-starter-netflix-ribbon 依赖:

    org.springframework.cloud
    spring-cloud-starter-netflix-ribbon
  • 配置 RestTemplate:在配置类中注入 RestTemplate 并添加 @LoadBalanced 注解:

    @Configurationpublic class ConfigProperties {    @Bean    @LoadBalanced    public RestTemplate restTemplate() {        return new RestTemplate();    }}
  • 修改远程调用方式:将原来的固定 IP 地址替换为服务名(如 producerService),并通过 RestTemplate 进行调用:

    @RequestMapping("/LoadBalanced/{id}")public String getId1(@PathVariable String id) {    String url = "http://producerService/test/" + id;    String id1 = restTemplate.getForObject(url, String.class);    return "服务端返回ID为" + id1;}
  • 负载均衡原理

    RestTemplate 被注入 @LoadBalanced 时,其请求会被拦截。系统会从目标 URL 中提取服务名(如 producerService),通过负载均衡算法从注册中心(如 Eureka)中获取对应的服务实例。然后,系统会替换目标 URL 中的 IP 地址和端口,完成最终的请求。

    负载均衡算法选择

    Ribbon 提供了多种负载均衡策略,默认使用轮询算法。可以通过配置指定不同的策略:

    ribbon:    NFLoadBalancerRuleClassName: com.netflix.loadbalancer.WeightedResponseTimeRule

    样例配置说明

    以下是一个使用 WeightedResponseTimeRule 负载均衡策略的示例:

    users:    ribbon:        NFLoadBalancerRuleClassName: com.netflix.loadbalancer.WeightedResponseTimeRule

    转载地址:http://azji.baihongyu.com/

    你可能感兴趣的文章
    org.apache.ibatis.exceptions.TooManyResultsException: Expected one result (or null) to be returned
    查看>>
    org.apache.ibatis.type.TypeException: Could not resolve type alias 'xxxx'异常
    查看>>
    org.apache.poi.hssf.util.Region
    查看>>
    org.apache.xmlbeans.XmlOptions.setEntityExpansionLimit(I)Lorg/apache/xmlbeans/XmlOptions;
    查看>>
    org.apache.zookeeper.KeeperException$ConnectionLossException: KeeperErrorCode = ConnectionLoss for /
    查看>>
    org.gradle.api.tasks.TaskExecutionException: Execution failed for task ':app:processDebugManifest'
    查看>>
    org.hibernate.HibernateException: Unable to get the default Bean Validation factory
    查看>>
    org.hibernate.ObjectNotFoundException: No row with the given identifier exists:
    查看>>
    org.springframework.amqp.AmqpConnectException:java.net.ConnectException:Connection timed out:connect
    查看>>
    org.springframework.beans.factory.BeanDefinitionStoreException
    查看>>
    org.springframework.boot.context.properties.ConfigurationBeanFactoryMetadata
    查看>>
    org.springframework.boot:spring boot maven plugin丢失---SpringCloud Alibaba_若依微服务框架改造_--工作笔记012
    查看>>
    SQL-CLR 类型映射 (LINQ to SQL)
    查看>>
    org.springframework.orm.hibernate3.support.OpenSessionInViewFilter
    查看>>
    org.springframework.orm.hibernate3.support.OpenSessionInViewFilter
    查看>>
    org.springframework.web.multipart.MaxUploadSizeExceededException: Maximum upload size exceeded
    查看>>
    org.tinygroup.serviceprocessor-服务处理器
    查看>>
    org/eclipse/jetty/server/Connector : Unsupported major.minor version 52.0
    查看>>
    org/hibernate/validator/internal/engine
    查看>>
    Orleans框架------基于Actor模型生成分布式Id
    查看>>