程序员社区

SpringCloud Ribbon 配置和详解

Ribbon 是一个客户端的负载均衡解决方案实现。它提供了我们很多已经实现好的负载方案,我们可以直接拿来用,或者自定义自己的负载均衡规则。Ribbon客户端在启动的时候会从Eureka Server端获取它需要调用服务的列表,并且做缓存,所以在Ribbon客户端启动以后,即使Eureka服务出现问题或者停掉,只要调用的服务没有问题,还是可以保证客户端的正常调用,这样做主要是为了保证CAP中的Availability。

  • Ribbon 配置

这里我们为了演示轮询的负载均衡方案,我们需要启动两个服务的provider,设置不同的端口,下面我们通过 Active profiles 来启动服务,配置如下:

application-7011.yml

spring:
  application:
    name: provider-service

server:
  port: 7011

eureka:
  client:
    register-with-eureka: true
    fetch-registry: true
    service-url:
      defaultZone:  http://eureka01:7001/eureka/,http://eureka02:7002/eureka/,http://eureka03:7003/eureka/

application-7012.yml

spring:
  application:
    name: provider-service

server:
  port: 7012

eureka:
  client:
    register-with-eureka: true
    fetch-registry: true
    service-url:
      defaultZone:  http://eureka01:7001/eureka/,http://eureka02:7002/eureka/,http://eureka03:7003/eureka/

在启动Application类中添加注解 @EnableDiscoveryClient,然后我们添加一个测试的Controllers类,代码如下:

//java项目www.fhadmin.org
@RestController
public class RibbonTest {

    @Autowired
    ApplicationContext applicationContext;

    @RequestMapping(value = "/provider/ribbon/printLog", method = RequestMethod.GET)
    public String printLog() throws UnknownHostException {
        String IPAddress = InetAddress.getLocalHost().getHostAddress();
        String port = applicationContext.getEnvironment().getProperty("local.server.port");
        return "Hello Provider ".concat(IPAddress).concat(":").concat(port);
    }

}

至此,我们的provider service配置好了,接下来我们来配置 consumer service,首先我们需要在 pom.xml 添加 ribbon 依赖:

pom.xml

<dependency>
   <groupId>org.springframework.cloud</groupId>
   <artifactId>spring-cloud-starter-netflix-ribbon</artifactId>
</dependency>

application.yml

spring:
  application:
    name: consumer-service

server:
  port: 7021

eureka:
  client:
    register-with-eureka: true
    fetch-registry: true
    service-url:
      defaultZone:  http://eureka01:7001/eureka/,http://eureka02:7002/eureka/,http://eureka03:7003/eureka/

添加 Ribbon 的配置类:

//java项目www.fhadmin.org
@Configuration
// 如果多个服务可以选择不同的策略
/*@RibbonClients({
        @RibbonClient(name = "other",configuration = OtherConfig.class),
        @RibbonClient(name = "provider",configuration = ProviderConfig.class)
})*/
@RibbonClient(name = "provider-service")
public class RibbonConfig {

    //定义负载均衡规则
    @Bean
    public IRule ribbonRule(){
        return new RoundRobinRule();
    }

    @Bean
    @LoadBalanced
    public RestTemplate restTemplate(){
        return new RestTemplate();
    }

}

这里我们主要介绍一下 Irule:

RoundRobinRule:轮询规则
RandomRule:随机规则
WeightedResponseTimeRule:使用响应时间的平均或者百分比为每个服务分配权重的规则,如果没法收集响应时间信息,会默认使用轮询规则
BestAvailableRule:会先根据断路器过滤掉处于故障的服务,然后选择并发量最小的服务
ZoneAvoidanceRule:根据server所在Zone和其性能,选择服务器,默认规则
AvailabilityFilteringRule:先根据断路器规则过滤掉有问题的服务,然后对剩余的服务按照轮询的策略进行访问
RetryRule:先按照RoundRobinRule规则进行服务获取,如果调用服务失败会在指定时间内进行重试,直到获取到可用的服务。

Consumer service的Controller演示类:

//java项目www.fhadmin.org
@RestController
public class RibbonTest {

    @Autowired
    private RestTemplate restTemplate;

    @GetMapping(value = "/consumer/ribbon/printLog")
    public String printProviderLog(){
        String result = restTemplate.getForObject("http://provider-service/provider/ribbon/printLog", String.class);
        return result;
    }

}
  • 演示Ribbon的轮询负载均衡

此时我们首先启动的的Eureka服务,然后通过Active Profiles启动两个不同端口的provider service,最后启动我们的consumer service,然后访问 http://localhost:7021/consumer/ribbon/printLog ,然后不断刷新,我们会看到端口7011和7012的不断变化。

赞(0) 打赏
未经允许不得转载:IDEA激活码 » SpringCloud Ribbon 配置和详解

相关推荐

  • 暂无文章

一个分享Java & Python知识的社区