SpringCloud之负载均衡

负载均衡

概念：

简单来说，就是把服务分散在不同的服务器上，让根据负载均衡算法实现服务器的选择；

spring cloud ribbon

依赖

<dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-ribbon</artifactId>
            <version>1.4.7.RELEASE</version>
</dependency>
<dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-eureka</artifactId>
            <version>1.4.7.RELEASE</version>
</dependency>

一个是spring-cloud-starter-ribbon，一个是spring-cloud-starter-eureka

使用服务的名字去访问服务，而不是通过http的地址来访问；

1.首先使用的微服务的话，就需要使用RestTemplate,我们只要在注入的时候添加 @LoadBalanced就可以实现负载均衡

package com.saxon.springcloud.configuration;

import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.client.RestTemplate;

@Configuration
public class config {
    @Bean
    @LoadBalanced
    public RestTemplate getRestTemplate () {
        return new RestTemplate ();
    }
}

2.配置文件application.yaml

server:
  port: 80

eureka:
  client:
    register-with-eureka: false
    service-url:
      defaultZone: http://localhost7002.com:7002/eureka/,http://localhost7003.com:7003/eureka/,http://localhost7003.com:7003/eureka/

defaultZone里面的就是服务的位置；

3.服务消费端，地址改为使用服务名称

package com.saxon.springcloud.controller;

import com.saxon.springcloud.pojo.Dept;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;

@RestController
public class ConsumerDept {
    @Autowired
    RestTemplate restTemplate;

    public static final String REQUEST_URL="http://SAXON";

    @GetMapping("/consumer/dept/get/{id}")
    public Dept queryDeptById(@PathVariable("id") long id){
        return restTemplate.getForObject (REQUEST_URL+"/get/ "+id,Dept.class,Long.class);
    }
}