SpringCloud入门（二）：Ribbon负载均衡

Ribbon是基于Netflix Ribbon实现的一套客户端 的负载均衡的工具。也就是在服务消费端(Consumer)实现负载均衡，不需要在服务提供端(Provider)做任何特殊处理。

服务消费端CloudConsumer：

pom文件：

<!-- Ribbon相关 --> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-eureka</artifactId> </dependency> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-ribbon</artifactId> </dependency> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-config</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency>

启动类：

@SpringBootApplication @EnableEurekaClient public class cloudConsumer { public static void main(String[] args) { SpringApplication.run(cloudConsumer.class,args); } }

 

配置类config，注入RestTemplate实例：

@Configuration public class config { @Bean(name="restTemplate") @LoadBalanced //负载均衡，默认负载均衡策略为RoundRobinRule--轮询策略 public RestTemplate restTemplate(){ return new RestTemplate(); } }

application.yml:

server: port: 8083 spring: application: name: cloudConsumer eureka: client: register-with-eureka: false #服务消费者不注册进eureka service-url: defaultZone: http://eurekaServer7003:7003/eureka/ instance: instance-id: cloudConsumer-${server.port}dept prefer-ip-address: true

controller：

@RestController public class CloudConsumerController { @Autowired private RestTemplate restTemplate; private final static String REST_URL_PREFIX = "http://cloud-provider"; @GetMapping("/consumer/get/{message}") public String getString(@PathVariable("message") String message){ return restTemplate.getForObject(REST_URL_PREFIX+"/provider/get/"+message,String.class); } }

这里定义了一个常量REST_URL_PREFIX，赋值是服务提供者注册进Eureka的微服务名。可以看出，这里处理服务调用地址换成了微服务名外，其他操作与服务消费者直接调用服务提供者(可参考博客：SpringCloud入门（一）：服务创建、注册)操作并没有太大区别。

服务提供者cloudProvider集群：

既然是客户端的负载均衡，那么服务端即服务提供者必然是有超过一个节点供服务消费者调用。这里的微服务集群，只需要多个节点注册进Eureka的微服务名相同，并有相同的访问路径即可。

创建两个cloudProvider节点，注册进Eureka：8080和8082节点

application.yml配置分别为：

server: port: 8080 spring: application: name: cloud-provider #集群中的服务名要相同 eureka: client: service-url: defaultZone: http://eurekaServer7003:7003/eureka/ instance: instance-id: cloudProvider-${server.port}dept prefer-ip-address: true server: port: 8082 spring: application: name: cloud-provider #集群中的服务名要相同 eureka: client: service-url: defaultZone: http://eurekaServer7003:7003/eureka/ instance: instance-id: cloudProvider-${server.port}dept prefer-ip-address: true

其他信息与单节点服务注册相同。

依次启动Eureka注册中心、服务提供者、服务消费者，进入Eureka管理界面：

可以看到，cloud-provider服务，status下有两个节点8080和8082。再在浏览器中访问服务消费者cloudConsumer：

刷新，再次访问：

这里使用的事Ribbon默认的负责均衡策略：RoundRobinRule轮询策略。Ribbon中内置的负载均衡策略还有：

如何制定Ribbon使用的负载均衡算法：将想要使用的算法实例注入容器容器中。

制定Ribbon负载均衡算法：

将要使用的算法实例注入容器中，即在配置类中添加一个@Bean

config配置文件：

@Configuration public class config { @Bean(name="restTemplate") @LoadBalanced public RestTemplate restTemplate(){ return new RestTemplate(); } @Bean(name="iRule") public IRule getRiule(){ return new RandomRule(); //使用随机算法 } }