springcloud+eureka+ribbon多服务负载均衡（2）

╰+攻爆jí腚メ 2022-03-30 08:16 155阅读 0赞

这一次，我们的服务方有两个（8888,9999），然后都注册到eureka上，但是要注意是注册使用同一个服务名称，消费方可以通过ribbon，根据指定的负载均衡算法访问到服务方。  
所有服务如下图：  
![在这里插入图片描述][20190105135035526.png]

## 1eureka注册中心 microservicecloud-Eureka-7001 ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3d1MjM3NDYzMzU4Mw_size_16_color_FFFFFF_t_70]  
pom.xml

application.yml

server:
      port: 7001
    
    eureka:
      instance:
        hostname: localhost  #eureka服务端的实例名称
      client:
        register-with-eureka: false #false表示不向注册中心注册自己。
        fetch-registry: false #false表示自己端就是注册中心，我的职责就是维护服务实例，并不需要去检索服务
        service-url:
          defaultZone: http://${ eureka.instance.hostname}:${ server.port}/eureka/    #设置与Eureka Server交互的地址查询服务和注册服务都需要依赖这个地址。

EurekaServer7001\_App.java

package com.wuk;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;
    
    @SpringBootApplication
    @EnableEurekaServer //EurekaServer服务器端启动类,接受其它微服务注册进来
    public class EurekaServer7001_App { 
    
    	public static void main(String[] args) { 
    		
    		SpringApplication.run(EurekaServer7001_App.class, args);
    	}
    
    }

## 2 服务方8888 microservicecloud-dept-8888 ##

它有单独的数据库

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3d1MjM3NDYzMzU4Mw_size_16_color_FFFFFF_t_70 1]  
它的数据库

![在这里插入图片描述][20190105135633735.png]  
pom.xml

<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.wuk.springcloud</groupId>
    		<artifactId>microservicecloud</artifactId>
    		<version>0.0.1-SNAPSHOT</version>
    	</parent>
    	<artifactId>microservicecloud-dept-8888</artifactId>
    	<dependencies>
    		<dependency>
    			<groupId>com.wuk.springcloud</groupId>
    			<artifactId>microservicecloud-api</artifactId>
    			<version>${project.version}</version>
    		</dependency>
    		<dependency>
    			<groupId>junit</groupId>
    			<artifactId>junit</artifactId>
    		</dependency>
    		<dependency>
    			<groupId>mysql</groupId>
    			<artifactId>mysql-connector-java</artifactId>
    		</dependency>
    		<dependency>
    			<groupId>com.alibaba</groupId>
    			<artifactId>druid</artifactId>
    		</dependency>
    		<dependency>
    			<groupId>ch.qos.logback</groupId>
    			<artifactId>logback-core</artifactId>
    		</dependency>
    		<dependency>
    			<groupId>org.mybatis.spring.boot</groupId>
    			<artifactId>mybatis-spring-boot-starter</artifactId>
    		</dependency>
    		<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter-jetty</artifactId>
    		</dependency>
    		<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter-web</artifactId>
    		</dependency>
    		<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter-test</artifactId>
    		</dependency>
    		
    		<dependency>
    			<groupId>org.springframework</groupId>
    			<artifactId>springloaded</artifactId>
    		</dependency>
    		<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-devtools</artifactId>
    		</dependency>
    		
    	   <dependency>
    	     <groupId>org.springframework.cloud</groupId>
    	     <artifactId>spring-cloud-starter-eureka</artifactId>
    	   </dependency>
    	   <dependency>
    	     <groupId>org.springframework.cloud</groupId>
    	     <artifactId>spring-cloud-starter-config</artifactId>
    	   </dependency>
    	</dependencies>
    </project>

application.yml  
要注意的地方就是两个服务要注册到一个服务名上

server:
      port: 8888
      
    mybatis:
      config-location: classpath:mybatis/mybatis.cfg.xml        # mybatis配置文件所在路径
      type-aliases-package: com.wuk.entity    # 所有Entity别名类所在包
      mapper-locations: 
      - classpath:mybatis/mapper/**/*.xml
       
    spring:
       application:
        name: producers    #注册在eureka上的服务名称,后续消费方访问要用它,如果多个服务负载均衡，就要保持一致
       datasource:
        type: com.alibaba.druid.pool.DruidDataSource            # 当前数据源操作类型
        driver-class-name: org.gjt.mm.mysql.Driver              # mysql驱动包
        url: jdbc:mysql://127.0.0.1:3306/cloudDB01              # 数据库名称
        username: root
        password: 123456
        dbcp2:
          min-idle: 5 # 数据库连接池的最小维持连接数
          initial-size: 5 # 初始化连接数
          max-total: 5 # 最大连接数
          max-wait-millis: 200 # 等待连接获取的最大超时时间
          
    eureka:
      client: #客户端注册进eureka服务列表内
        service-url: 
          defaultZone: http://localhost:7001/eureka
      instance:
        instance-id: microservicecloud-dept-8888 #自定义服务名称 
        prefer-ip-address: true #显示服务ip

其他的文件上一篇有，不做赘述。

## 3 服务9999 microservicecloud-dept-9999 ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3d1MjM3NDYzMzU4Mw_size_16_color_FFFFFF_t_70 2]  
数据库如下：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3d1MjM3NDYzMzU4Mw_size_16_color_FFFFFF_t_70 3]  
pom.xml

<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.wuk.springcloud</groupId>
        <artifactId>microservicecloud</artifactId>
        <version>0.0.1-SNAPSHOT</version>
      </parent>
      <artifactId>microservicecloud-dept-9999</artifactId>
      <dependencies>
    		<dependency>
    			<groupId>com.wuk.springcloud</groupId>
    			<artifactId>microservicecloud-api</artifactId>
    			<version>${project.version}</version>
    		</dependency>
    		<dependency>
    			<groupId>junit</groupId>
    			<artifactId>junit</artifactId>
    		</dependency>
    		<dependency>
    			<groupId>mysql</groupId>
    			<artifactId>mysql-connector-java</artifactId>
    		</dependency>
    		<dependency>
    			<groupId>com.alibaba</groupId>
    			<artifactId>druid</artifactId>
    		</dependency>
    		<dependency>
    			<groupId>ch.qos.logback</groupId>
    			<artifactId>logback-core</artifactId>
    		</dependency>
    		<dependency>
    			<groupId>org.mybatis.spring.boot</groupId>
    			<artifactId>mybatis-spring-boot-starter</artifactId>
    		</dependency>
    		<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter-jetty</artifactId>
    		</dependency>
    		<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter-web</artifactId>
    		</dependency>
    		<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter-test</artifactId>
    		</dependency>
    		
    		<dependency>
    			<groupId>org.springframework</groupId>
    			<artifactId>springloaded</artifactId>
    		</dependency>
    		<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-devtools</artifactId>
    		</dependency>
    		
    	   <dependency>
    	     <groupId>org.springframework.cloud</groupId>
    	     <artifactId>spring-cloud-starter-eureka</artifactId>
    	   </dependency>
    	   <dependency>
    	     <groupId>org.springframework.cloud</groupId>
    	     <artifactId>spring-cloud-starter-config</artifactId>
    	   </dependency>
    	</dependencies>
    </project>

application.yml

server:
      port: 9999
      
    mybatis:
      config-location: classpath:mybatis/mybatis.cfg.xml        # mybatis配置文件所在路径
      type-aliases-package: com.wuk.entity    # 所有Entity别名类所在包
      mapper-locations: 
      - classpath:mybatis/mapper/**/*.xml
       
    spring:
       application:
        name: producers  #注册在eureka上的服务名称,后续消费方访问要用它,如果多个服务负载均衡，就要保持一致
       datasource:
        type: com.alibaba.druid.pool.DruidDataSource            # 当前数据源操作类型
        driver-class-name: org.gjt.mm.mysql.Driver              # mysql驱动包
        url: jdbc:mysql://127.0.0.1:3306/cloudDB02              # 数据库名称
        username: root
        password: 123456
        dbcp2:
          min-idle: 5 # 数据库连接池的最小维持连接数
          initial-size: 5 # 初始化连接数
          max-total: 5 # 最大连接数
          max-wait-millis: 200 # 等待连接获取的最大超时时间
          
    eureka:
      client: #客户端注册进eureka服务列表内
        service-url: 
          defaultZone: http://localhost:7001/eureka
      instance:
        instance-id: microservicecloud-dept-9999 #自定义服务名称 
        prefer-ip-address: true #显示服务ip

## 4 消费方 microservicecloud-consumer-dept-80 ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3d1MjM3NDYzMzU4Mw_size_16_color_FFFFFF_t_70 4]  
ConfigBean.java  
注意这里ribbon提供的几个负载均衡算法  
算法有：

1.  RoundRobinRule()轮询
2.  RandomRule()随机
3.  AvailabilityFilteringRule()先轮询，过滤掉故障服务，然后再按照轮询方式
4.  WeightedResponseTimeRule()在最开始先轮询，然后统计响应时间，等到数据足够,计算出权重，然后切换到该算法，响应时间短的容易被选中
5.  RetryRule() 先轮询，如果服务失败，然后在指定时间内进行重试，获取可用服务
6.  BestAvailableRule()先过滤掉由于多次访问故障而处于断路或者跳闸的服务，然后选择一个并发量小的服务

package com.wuk.cfgbeans;
    
    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.AvailabilityFilteringRule;
    import com.netflix.loadbalancer.BestAvailableRule;
    import com.netflix.loadbalancer.IRule;
    import com.netflix.loadbalancer.RandomRule;
    import com.netflix.loadbalancer.RetryRule;
    import com.netflix.loadbalancer.RoundRobinRule;
    import com.netflix.loadbalancer.WeightedResponseTimeRule;
    
    
    @Configuration
    public class ConfigBean { 
    	/** * RestTemplate提供了多种便捷访问远程Http服务的方法， 是一种简单便捷的访问restful服务模板类，是Spring提供的用于访问Rest服务的客户端模板工具集 * @return */
    	@LoadBalanced
    	@Bean
    	public RestTemplate getRestTemplate() { 
    		return new RestTemplate();
    	}
    
    	@Bean
    	public IRule myRule() { 
    		
    		//RoundRobinRule()轮询
    		//RandomRule()随机
    		//AvailabilityFilteringRule()先轮询，过滤掉故障服务，然后再按照轮询方式
    		//WeightedResponseTimeRule()在最开始先轮询，然后统计响应时间，等到数据足够,计算出权重，然后切换到该算法，响应时间短的容易被选中
    		//RetryRule() 先轮询，如果服务失败，然后在指定时间内进行重试，获取可用服务
    		//BestAvailableRule()先过滤掉由于多次访问故障而处于断路或者跳闸的服务，然后选择一个并发量小的服务
    		return new RandomRule();
    	}
    }

DeptController\_Consumer.java

package com.wuk.controller;
    
    import java.util.List;
    
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.web.bind.annotation.PathVariable;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RestController;
    import org.springframework.web.client.RestTemplate;
    
    import com.wuk.entity.Dept;
    
    @RestController
    public class DeptController_Consumer { 
    	//之前我们采用的是ip+端口，现在直接采用服务名
    	private static final String REST_URL_PREFIX = "http://producers";
    
    	@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);
    	}
    }

CusumerDeptApplication.java

package com.wuk;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
    
    @SpringBootApplication
    @EnableEurekaClient
    public class CusumerDeptApplication { 
    
    	public static void main(String[] args) { 
    		
    		SpringApplication.run(CusumerDeptApplication.class, args);
    	}
    }

[20190105135035526.png]: /images/20220330/9f799cbda4744b23acf31f5c9be7935f.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3d1MjM3NDYzMzU4Mw_size_16_color_FFFFFF_t_70]: /images/20220330/3c800fe665fd48eeb11df426432e4119.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3d1MjM3NDYzMzU4Mw_size_16_color_FFFFFF_t_70 1]: /images/20220330/4daef50790ab443b96ce59befded6947.png
[20190105135633735.png]: /images/20220330/7d221dcc06064d4d826ea641684560a3.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3d1MjM3NDYzMzU4Mw_size_16_color_FFFFFF_t_70 2]: /images/20220330/f3cf4703b7974de7b7a35f0c100de5fd.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3d1MjM3NDYzMzU4Mw_size_16_color_FFFFFF_t_70 3]: /images/20220330/96c3cfd4afb648a6801f1e8f521bb686.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3d1MjM3NDYzMzU4Mw_size_16_color_FFFFFF_t_70 4]: /images/20220330/07d4ece29c4743a48ef18bf370aa15fe.png