四（1）、springcloud之Ribbon初步配置

落日映苍穹つ 2023-06-11 08:25 35阅读 0赞

## 1、概述 ##

Spring Cloud Ribbon是基于Netflix Ribbon实现的一套客户端 -负载均衡的工具。Ribbon是Netflix发布的开源项目，主要功能是提供客户端的软件负载均衡算法，将Netflix的中间层服务连接在一起。Ribbon客户端组件提供一系列完善的配置项如连接超时，重试等。简单的说，就是在配置文件中列出Load Balancer（简称LB）后面所有的机器，Ribbon会自动的帮助你基于某种规则（如简单轮询，随机连接等）去连接这些机器。我们也很容易使用Ribbon实现自定义的负载均衡算法。

**LB：**，即负载均衡(Load Balance)，在微服务或分布式集群中经常用的一种应用。负载均衡简单的说就是将用户的请求平摊的分配到多个服务上，从而达到系统的HA。常见的负载均衡有软件Nginx，LVS，硬件 F5等。相应的在中间件，例如：dubbo和SpringCloud中均给我们提供了负载均衡，SpringCloud的负载均衡算法可以自定义。

*  集中式LB：即在服务的消费方和提供方之间使用独立的LB设施(可以是硬件，如F5, 也可以是软件，如nginx), 由该设施负责把访问请求通过某种策略转发至服务的提供方；
 *  进程内LB： 将LB逻辑集成到消费方，消费方从服务注册中心获知有哪些地址可用，然后自己再从这些地址中选择出一个合适的服务器。Ribbon就属于进程内LB，它只是一个类库，集成于消费方进程，消费方通过它来获取到服务提供方的地址。

## 2、配置Ribbon ##

修改microservicecloud-consumer-dept-80工程修改如下：

**1）修改pom文件，添加Ribbon依赖：**

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
      <modelVersion>4.0.0</modelVersion>
      <parent>
        <groupId>com.jiatp.springcloud</groupId>
        <artifactId>microservicecloud</artifactId>
        <version>0.0.1-SNAPSHOT</version>
      </parent>
      <artifactId>microservicecloud-consumer-dept-80</artifactId>
      <description>部门微服务消费者</description>
      
      <dependencies>
       <dependency>
         <groupId>com.jiatp.springcloud</groupId>
         <artifactId>microservicecloud-api</artifactId>
         <version>${project.version}</version>
       </dependency> 
       <dependency>
         <groupId>org.springframework.boot</groupId>
         <artifactId>spring-boot-starter-web</artifactId>
       </dependency>
       
      <dependency>
         <groupId>org.springframework</groupId>
         <artifactId>springloaded</artifactId>
         <version>1.2.6.RELEASE</version>
       </dependency>
       <dependency>
         <groupId>org.springframework.boot</groupId>
         <artifactId>spring-boot-devtools</artifactId>
       </dependency>
       
       <dependency>
         <groupId>org.springframework.cloud</groupId>
         <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
       </dependency>
       <dependency>
         <groupId>org.springframework.cloud</groupId>
         <artifactId>spring-cloud-starter-netflix-ribbon</artifactId>
       </dependency>
       <dependency>
         <groupId>org.springframework.cloud</groupId>
         <artifactId>spring-cloud-starter-config</artifactId>
       </dependency>
      </dependencies>
    </project>

**2）修改yml，追加eureka的服务注册地址：**

server:
      port: 80 # 消费者的端口80
      
    eureka:
      client:
        register-with-eureka: false
        service-url: 
          defaultZone: http://eureka7001.com:7001/eureka/,http://eureka7002.com:7002/eureka/,http://eureka7003.com:7003/eureka/

**3）添加ConfigBean配置类，使用@LoadBalanced注解开启负载均衡**

package com.jiatp.springcloud.cfgbeans;
    
    import java.lang.reflect.Method;
    
    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;
    
    import com.netflix.loadbalancer.IRule;
    import com.netflix.loadbalancer.RandomRule;
    
    @Configuration
    public class ConfigBean {   //优化spring,从spring(applicationContext.xml)== @Configuration配置 
    	
    	@Bean
    	@LoadBalanced    //开启负载聚哼
        public RestTemplate restTemplate(){ 
    
            return new RestTemplate();
        }
    	
    }

![在这里插入图片描述][20191029214521873.png]

对应spring.application.name 微服务名字

**4）主启动类DeptConsumer80\_App添加@EnableEurekaClient**

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

**5）修改DeptController\_Consumer客户端controller**

@RestController
    public class DeptController_Consumer
    { 
      //private static final String REST_URL_PREFIX = "http://localhost:8001";
      private static final String REST_URL_PREFIX = "http://MICROSERVICECLOUD-DEPT";
      
      @Autowired
      private RestTemplate restTemplate;
      
      @RequestMapping(value="/consumer/dept/add")
      public boolean add(Dept dept)
      { 
       return restTemplate.postForObject(REST_URL_PREFIX+"/dept/add", dept, Boolean.class);
      }
      
      @RequestMapping(value="/consumer/dept/get/{id}")
      public Dept get(@PathVariable("id") Long id)
      { 
       return restTemplate.getForObject(REST_URL_PREFIX+"/dept/get/"+id, Dept.class);
      }
      
      @SuppressWarnings("unchecked")
      @RequestMapping(value="/consumer/dept/list")
      public List<Dept> list()
      { 
       return restTemplate.getForObject(REST_URL_PREFIX+"/dept/list", List.class);
      } 
      
      //测试@EnableDiscoveryClient,消费端可以调用服务发现
      @RequestMapping(value="/consumer/dept/discovery") 
      public Object discovery()
      { 
       return restTemplate.getForObject(REST_URL_PREFIX+"/dept/discovery", Object.class);
      }  
      
    }

启动测试：顺序先启动3个eureka集群后，再启动microservicecloud-provider-dept-8001并注册进eureka，再启动microservicecloud-consumer-dept-80，浏览器输入http://localhost/consumer/dept/list

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2phdHBlbg_size_16_color_FFFFFF_t_70]  
**总结：Ribbon和Eureka整合后Consumer可以直接调用服务而不用再关心地址和端口号**

[20191029214521873.png]: /images/20230531/1df9e9981a0c4b0fbc77eb38cf5a27b7.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2phdHBlbg_size_16_color_FFFFFF_t_70]: /images/20230531/afdfbc7c2f9449c69db5cbb2ffb72cca.png