1.Ribbon簡介

(1).Ribbon介紹

Spring Cloud Ribbon是基于Netflix Ribbon實作的一套客戶端負載均衡的工具，

Ribbon是Netflix發布的開源專案，主要功能是提供客戶端的軟體負載均衡演算法，將Netflix的中間層服務連接在一起，Ribbon客戶端組件提供一系列完善的配置項如連接超時，重試等，簡單的說，就是在組態檔中列出Load Balancer（簡稱LB）后面所有的機器，Ribbon會自動的幫助你基于某種規則（如簡單輪詢，隨機連接等）去連接這些機器，我們也很容易使用Ribbon實作自定義的負載均衡演算法，

(2).Ribbon作用

Ribbon是基于Netflix Ribbon實作的一套客戶端負載均衡(LB)的工具，

LB(負載均衡):集中式LB和行程內LB，

集中式LB：即在服務的消費方和提供方之間使用獨立的LB設施(可以是硬體，如F5, 也可以是軟體，如nginx), 由該設施負責把訪問請求通過某種策略轉發至服務的提供方；

F5:https://baike.baidu.com/item/F5%E6%96%B9%E6%A1%88/1121377?fr=aladdin

行程內LB：將LB邏輯集成到消費方，消費方從服務注冊中心獲知有哪些地址可用，然后自己再從這些地址中選擇出一個合適的服務器，

Ribbon就屬于行程內LB，它只是一個類別庫，集成于消費方行程，消費方通過它來獲取到服務提供方的地址，

官方檔案：

https://github.com/Netflix/ribbon/wiki

https://github.com/Netflix/ribbon/wiki/Getting-Started

2.Ribbon配置

修改microservicecloud-consumer-dept-80工程

(1).修改pom.xml檔案

修改部分：

<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>

</dependencies>

完整部分：

<?xml version="1.0" encoding="UTF-8"?>

<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">

<parent>

<artifactId>microservicecloud</artifactId>

<groupId>com.hosystem</groupId>

<version>1.0-SNAPSHOT</version>

</parent>

<modelVersion>4.0.0</modelVersion>

<artifactId>microservicecloud-consumer-dept-80</artifactId>

<dependencies>

<dependency>

<groupId>com.hosystem</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>

</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-ribbon</artifactId>

</dependency>

<dependency>

<groupId>org.springframework.cloud</groupId>

<artifactId>spring-cloud-starter-config</artifactId>

</dependency>

</dependencies>

</project>

(2).修改application.yml

追加eureka的服務注冊地址，

修改部分：

eureka:

client:

register-with-eureka: false

service-url:

defaultZone: http://eureka7001.com:7001/eureka/,http://eureka7002.com:7002/eureka/,http://eureka7003.com:7003/eureka/

完整部分：

server:

port: 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.java

對ConfigBean進行新注解@LoadBalanced,獲得Rest時加入Ribbon的配置;

package com.hosystem.springcloud.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;

@Configuration

public class ConfigBean //boot ---> spring applicationContext.xml === @Configuration配置 ConfigBean = applicationContext.xml

{

@Bean

@LoadBalanced //Spring Cloud Ribbon是基于Netflix Ribbon實作的一套客戶端負載均衡的工具，

public RestTemplate getRestTemplate()

{

return new RestTemplate();

}

//applicationContext.xml ---> @Configuration public class ConfigBean {}

//<bean id=UserService" font-size: 18px"> 主啟動類DeptConsumer80_App添加@EnableEurekaClient

package com.hosystem.springcloud;

import org.springframework.boot.SpringApplication;

import org.springframework.boot.autoconfigure.SpringBootApplication;

import org.springframework.cloud.netflix.eureka.EnableEurekaClient;

@SpringBootApplication

@EnableEurekaClient

public class DeptConsumer80_App

{

    public static void main(String[] args)

    {

        SpringApplication.run(DeptConsumer80_App.class, args);

    }

}

(5).修改DeptController_Consumer.java

  修改DeptController_Consumer客戶端訪問類

package com.hosystem.springcloud.controller;

import com.hosystem.springcloud.entities.Dept;

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;

@RestController //注:這里一定不能忘記注解@RestController 否則出現404;

public class DeptController_Consumer {

    /**

     * 使用restTemplate訪問restful介面非常的簡單;

     * (url, requestMap, ResponseBean.class)三個引數代表REST請求地址、請求引數、HTTP回應轉換被轉換成的物件型別

     */

//    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=https://www.cnblogs.com/HOsystem/p/"/consumer/dept/add")

    public boolean add(Dept dept)

    {

        return restTemplate.postForObject(REST_URL_PREFIX+"/dept/add", dept, Boolean.class);

    }

    @RequestMapping(value=https://www.cnblogs.com/HOsystem/p/"/consumer/dept/get/{id}")

    public Dept get(@PathVariable("id") Long id)

    {

        return restTemplate.getForObject(REST_URL_PREFIX+"/dept/get/"+id, Dept.class);

    }

    //@SuppressWarnings("unchecked"):壓制警告，因為我們使用了過期的方法

    @SuppressWarnings("unchecked")

    @RequestMapping(value=https://www.cnblogs.com/HOsystem/p/"/consumer/dept/list")

    public List<Dept> list()

    {

        return restTemplate.getForObject(REST_URL_PREFIX+"/dept/list", List.class);

    }

    //測驗@EnableDiscoveryClient,消費端可以呼叫服務發現

    @RequestMapping(value=https://www.cnblogs.com/HOsystem/p/"/consumer/dept/discovery")

    public Object discovery()

    {

        return restTemplate.getForObject(REST_URL_PREFIX+"/dept/discovery", Object.class);

    }

}

/**

* JDBC    Spring JDBCTemplate

*          Spring RestTemplate

*/

(6).啟動eureka、provider、consumer

  先啟動3個eureka7001、eureka7002、eureka7003集群后，再啟動microservicecloud-provider-dept-8001并注冊進eureka，最后啟動microservicecloud-consumer-dept-80，

(7).測驗

http://localhost/consumer/dept/get/1

http://localhost/consumer/dept/list

http://localhost/consumer/dept/add?dname=大資料部

(8).總結

  Ribbon和Eureka整合后Consumer可以直接呼叫服務而不用再關心地址和埠號

3.Ribbon負載均衡

(1).Ribbon架構介紹

  Ribbon在作業時分成兩步：第一步先選擇 EurekaServer ,它優先選擇在同一個區域內負載較少的server.第二步再根據用戶指定的策略，在從server取到的服務注冊串列中選擇一個地址，其中Ribbon提供了多種策略：比如輪詢、隨機和根據回應時間加權，

(2).創建provider8002、provider8003

[1].創建工程provider8002

[2].創建工程provider8003

(3).配置pom檔案

[1].配置provider8002 pom檔案

<?xml version="1.0" encoding="UTF-8"?>

<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">

    <parent>

        <artifactId>microservicecloud</artifactId>

        <groupId>com.hosystem</groupId>

        <version>1.0-SNAPSHOT</version>

    </parent>

    <modelVersion>4.0.0</modelVersion>

    <artifactId>microservicecloud-provider-dept-8002</artifactId>

    <dependencies>

        <dependency>

            <groupId>com.hosystem</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>

        

        <dependency>

            <groupId>org.springframework.boot</groupId>

            <artifactId>spring-boot-starter-actuator</artifactId>

        </dependency>

    </dependencies>

</project>

[2].配置provider8003 pom檔案

<?xml version="1.0" encoding="UTF-8"?>

<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">

    <parent>

        <artifactId>microservicecloud</artifactId>

        <groupId>com.hosystem</groupId>

        <version>1.0-SNAPSHOT</version>

    </parent>

    <modelVersion>4.0.0</modelVersion>

    <artifactId>microservicecloud-provider-dept-8003</artifactId>

    <dependencies>

        <dependency>

            <groupId>com.hosystem</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>

        

        <dependency>

            <groupId>org.springframework.boot</groupId>

            <artifactId>spring-boot-starter-actuator</artifactId>

        </dependency>

    </dependencies>

</project>

(4).配置yml檔案

  修改的地方有埠、資料庫鏈接、實體id(instance-id)；對外暴露的統一服務實體名一定不能修改(name: microservicecloud-dept)

[1].配置provider8002 yml檔案

server:

  port: 8002

mybatis:

  config-location: classpath:mybatis/mybatis.cfg.xml        # mybatis組態檔所在路徑

  type-aliases-package: com.hosytem.springcloud.entities    # 所有Entity別名類所在包

  mapper-locations:

  - classpath:mybatis/mapper/**/*.xml                       # mapper映射檔案

#name spring.application.name=microservicecloud-dept 很重要很重要很重要

spring:

   application:

    name: microservicecloud-dept

   datasource:

    type: com.alibaba.druid.pool.DruidDataSource            # 當前資料源操作型別

    driver-class-name: org.gjt.mm.mysql.Driver              # mysql驅動包

    url: jdbc:mysql://192.168.188.188: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

      defaultZone: http://eureka7001.com:7001/eureka/,http://eureka7002.com:7002/eureka/,http://eureka7003.com:7003/eureka/

  instance:

    instance-id: microservicecloud-dept8002

    prefer-ip-address: true     #訪問路徑可以顯示IP地址

info:

  app.name: hosystem-microservicecloud

  company.name: www.hosystem.com

  build.artifactId: $project.artifactId$

  build.version: $project.version$

[2].配置provider8003 yml檔案

server:

  port: 8003

mybatis:

  config-location: classpath:mybatis/mybatis.cfg.xml        # mybatis組態檔所在路徑

  type-aliases-package: com.hosytem.springcloud.entities    # 所有Entity別名類所在包

  mapper-locations:

  - classpath:mybatis/mapper/**/*.xml                       # mapper映射檔案

#name spring.application.name=microservicecloud-dept 很重要很重要很重要

spring:

   application:

    name: microservicecloud-dept

   datasource:

    type: com.alibaba.druid.pool.DruidDataSource            # 當前資料源操作型別

    driver-class-name: org.gjt.mm.mysql.Driver              # mysql驅動包

    url: jdbc:mysql://192.168.188.188:3306/cloudDB03              # 資料庫名稱

    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

      defaultZone: http://eureka7001.com:7001/eureka/,http://eureka7002.com:7002/eureka/,http://eureka7003.com:7003/eureka/

  instance:

    instance-id: microservicecloud-dept8003

    prefer-ip-address: true     #訪問路徑可以顯示IP地址

info:

  app.name: hosystem-microservicecloud

  company.name: www.hosystem.com

  build.artifactId: $project.artifactId$

  build.version: $project.version$

(5).配置主啟動類

[1].DeptProvider8002_App

[2].DeptProvider8002_App

(6).創建資料庫database8002、database8003

  新建8002/8003資料庫，各自微服務分別連各自的資料庫，

[1].創建database8002

DROP DATABASE IF EXISTS cloudDB02;

CREATE DATABASE cloudDB02 CHARACTER SET UTF8;

USE cloudDB02;

CREATE TABLE dept

(

  deptno BIGINT NOT NULL PRIMARY KEY AUTO_INCREMENT,

  dname VARCHAR(60),

  db_source   VARCHAR(60)

);

INSERT INTO dept(dname,db_source) VALUES('開發部',DATABASE());

INSERT INTO dept(dname,db_source) VALUES('人事部',DATABASE());

INSERT INTO dept(dname,db_source) VALUES('財務部',DATABASE());

INSERT INTO dept(dname,db_source) VALUES('市場部',DATABASE());

INSERT INTO dept(dname,db_source) VALUES('運維部',DATABASE());

SELECT * FROM dept;

[2].創建database8003

DROP DATABASE IF EXISTS cloudDB03;

CREATE DATABASE cloudDB03 CHARACTER SET UTF8;

USE cloudDB03;

CREATE TABLE dept

(

  deptno BIGINT NOT NULL PRIMARY KEY AUTO_INCREMENT,

  dname VARCHAR(60),

  db_source   VARCHAR(60)

);

INSERT INTO dept(dname,db_source) VALUES('開發部',DATABASE());

INSERT INTO dept(dname,db_source) VALUES('人事部',DATABASE());

INSERT INTO dept(dname,db_source) VALUES('財務部',DATABASE());

INSERT INTO dept(dname,db_source) VALUES('市場部',DATABASE());

INSERT INTO dept(dname,db_source) VALUES('運維部',DATABASE());

SELECT * FROM dept;

(7).啟動eureka、provider、consumer

  啟動3個eureka集群配置區,在啟動provider后，我們需要隨便打開一個eureka看provider是否都注冊上了，

  啟動3個provider微服務并各自測驗通過

http://localhost:8001/dept/list

http://localhost:8002/dept/list

http://localhost:8003/dept/list

  啟動microservicecloud-consumer-dept-80

(8).訪問Dept微服務

  客戶端通過Ribbo完成負載均衡并訪問上一步的Dept微服務

http://localhost/consumer/dept/list

  注意觀察看到回傳的資料庫名字，各不相同，負載均衡實作

(9).總結

  Ribbon其實就是一個軟負載均衡的客戶端組件，他可以和其他所需請求的客戶端結合使用，和eureka結合只是其中的一個實體，

4.Ribbon核心組件

(1).查看IRle介面

(2).查看IRleILoadBalancer介面

(3).查看AbstractLoadBalancer介面

(4).使用RandomRule演算法

  修改consumer-dept-80的ConfigBean.java.

package com.hosystem.springcloud.cfgbeans;

import com.netflix.loadbalancer.IRule;

import com.netflix.loadbalancer.RandomRule;

import com.netflix.loadbalancer.RetryRule;

import com.netflix.loadbalancer.RoundRobinRule;

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 ConfigBean //boot ---> spring applicationContext.xml === @Configuration配置 ConfigBean = applicationContext.xml

{

    @Bean

    @LoadBalanced   //Spring Cloud Ribbon是基于Netflix Ribbon實作的一套客戶端負載均衡的工具，

    public RestTemplate getRestTemplate()

    {

        return new RestTemplate();

    }

    //選擇我們使用的演算法

    // RoundRobinRule:輪詢

    // RandomRule:隨機

    // AvailabilityFilteringRule:先過濾多次訪問故障處于斷路器跳閘狀態的服務，還有并發的連接數量超過閾值的服務，然后對剩余的服務串列按照輪詢策略進行訪問

    // WeightedResponseTimeRule:根據平均回應時間計算所有服務的權重，回應時間越快服務權重越大被選中的概率越高，剛啟動時如果統計資訊不足，則使用RoundRobinRule策略，等統計資訊足夠,會切換到WeightedResponseTimeRule

    // RetryRule:先按照RoundRobinRule的策略獲取服務，如果獲取服務失敗則在指定時間內會進行重試，獲取可用的服務

    // BestAvailableRule:會先過濾掉由于多次訪問故障而處于斷路器跳閘狀態的服務，然后選擇一個并發量最小的服務

    // ZoneAvoidanceRule:默認規則,復合判斷server所在區域的性能和server的可用性選擇服務器

    @Bean

    public IRule myRule(){

//        return new RoundRobinRule(); //輪詢演算法

//        return new RandomRule();    //隨機演算法

        return new RetryRule();     //先按照RoundRobinRule的策略獲取服務，如果獲取服務失敗則在指定時間內會進行重試，獲取可用的服務

    }

}

//applicationContext.xml ---> @Configuration public class ConfigBean {}

//<bean id=UserService" font-size: 18px">

  修改microservicecloud-consumer-dept-80

(1).修改主啟動類

  修改consumer-dept-80的主啟動類

package com.hosystem.springcloud;

import org.springframework.boot.SpringApplication;

import org.springframework.boot.autoconfigure.SpringBootApplication;

import org.springframework.cloud.netflix.eureka.EnableEurekaClient;

import org.springframework.cloud.netflix.ribbon.RibbonClient;

@SpringBootApplication

@EnableEurekaClient

@RibbonClient(name="MICROSERVICECLOUD-DEPT",configuration=MySelfRule.class) //在啟動該微服務的時候就能去加載我們的自定義Ribbon配置類，從而使配置生效

public class DeptConsumer80_App

{

    public static void main(String[] args)

    {

        SpringApplication.run(DeptConsumer80_App.class, args);

    }

}

(2).配置事項

  官方檔案明確給出了警告：這個自定義配置類不能放在@ComponentScan所掃描的當前包下以及子包下，否則我們自定義的這個配置類就會被所有的Ribbon客戶端所共享，也就是說我們達不到特殊化定制的目的了，

  簡單說，就是我們不能夠在主啟動類(DeptConsumer80_App)所在的包及其子包下創建我們自定義規則類，

  如，我們新創建了myrule包，不能夠創建在springcloud包下，因為主啟動類在springcloud包下了，

(3).自定義步驟

[1].新建package

  根據配置事項，我們得知需要重新創建一個包不能和主啟動類在一個包下，我們創建com.hosystem.myrule包，

[2].自定義Robbin規則類

package com.hosystem.myrule;

import com.netflix.loadbalancer.IRule;

import com.netflix.loadbalancer.RandomRule;

import org.springframework.context.annotation.Bean;

import org.springframework.context.annotation.Configuration;

@Configuration

public class MySelfRule

{

    @Bean

    public IRule myRule()

    {

        return new RandomRule();//Ribbon默認是輪詢，我自定義為隨機

    }

}

[3].修改主啟動類

package com.hosystem.springcloud;

import org.springframework.boot.SpringApplication;

import org.springframework.boot.autoconfigure.SpringBootApplication;

import org.springframework.cloud.netflix.eureka.EnableEurekaClient;

import org.springframework.cloud.netflix.ribbon.RibbonClient;

@SpringBootApplication

@EnableEurekaClient

@RibbonClient(name="MICROSERVICECLOUD-DEPT",configuration=MySelfRule.class) //在啟動該微服務的時候就能去加載我們的自定義Ribbon配置類，從而使配置生效

public class DeptConsumer80_App

{

    public static void main(String[] args)

    {

        SpringApplication.run(DeptConsumer80_App.class, args);

    }

}

[4].測驗

http://localhost/consumer/dept/list

(4).自定義規則深度決議

  依舊輪詢策略，但是加上新需求，每個服務器要求被呼叫5次，也即以前是每臺機器一次，現在是每臺機器5次，

[1].原始碼決議

https://github.com/Netflix/ribbon/blob/master/ribbon-loadbalancer/src/main/java/com/netflix/loadbalancer/RandomRule.java

[2].RandomRule_Hosystem.java

  參考原始碼修改為我們需求要求的RandomRule_Hosystem.java

package com.hosystem.myrule;

import com.netflix.client.config.IClientConfig;

import com.netflix.loadbalancer.AbstractLoadBalancerRule;

import com.netflix.loadbalancer.ILoadBalancer;

import com.netflix.loadbalancer.Server;

import java.util.List;

import java.util.concurrent.ThreadLocalRandom;

public class RandomRule_Hosystem extends AbstractLoadBalancerRule{

    //total = 0 當total==5時指向才能往下走

    //index = 0 當前對外提供的服務器地址

    //當total從5置為0時我們index=1

    private int total = 0;    //總共被呼叫的次數，目前要求每臺被呼叫5次

    private int currentIndex = 0;//當前提供服務的機器號

    /**

     * Randomly choose from all living servers

     */

//    @edu.umd.cs.findbugs.annotations.SuppressWarnings(value = "https://www.cnblogs.com/HOsystem/p/RCN_REDUNDANT_NULLCHECK_OF_NULL_VALUE")

    public Server choose(ILoadBalancer lb, Object key) {

        if (lb == null) {

            return null;

        }

        Server server = null;

        while (server == null) {

            if (Thread.interrupted()) {

                return null;

            }

            List<Server> upList = lb.getReachableServers();

            List<Server> allList = lb.getAllServers();

            int serverCount = allList.size();

            if (serverCount == 0) {

                /*

                 * No servers. End regardless of pass, because subsequent passes

                 * only get more restrictive.

                 */

                return null;

            }

//            int index = chooseRandomInt(serverCount);

//            server = upList.get(index);

//            private int total = 0;    //總共被呼叫的次數，目前要求每臺被呼叫5次

//            private int currentIndex = 0;//當前提供服務的機器號

            //分析，因為我們需要訪問5次但是微服務只有8001 8002 8003三臺所以我們需要設定currentIndex>=upList.size()時重新從8001開始

            if(total < 5)

            {

                server = upList.get(currentIndex);

                total++;

            }else {

                total = 0;

                currentIndex++;

                if(currentIndex >= upList.size())

                {

                    currentIndex = 0;

                }

            }

            if (server == null) {

                /*

                 * The only time this should happen is if the server list were

                 * somehow trimmed. This is a transient condition. Retry after

                 * yielding.

                 */

                Thread.yield();

                continue;

            }

            if (server.isAlive()) {

                return (server);

            }

            // Shouldn't actually happen.. but must be transient or a bug.

            server = null;

            Thread.yield();

        }

        return server;

    }

    protected int chooseRandomInt(int serverCount) {

        return ThreadLocalRandom.current().nextInt(serverCount);

    }

    @Override

    public Server choose(Object key) {

        return choose(getLoadBalancer(), key);

    }

    @Override

    public void initWithNiwsConfig(IClientConfig iClientConfig) {

    }

}

[3].MySelfRule.java

package com.hosystem.myrule;

import com.netflix.loadbalancer.IRule;

import com.netflix.loadbalancer.RandomRule;

import org.springframework.context.annotation.Bean;

import org.springframework.context.annotation.Configuration;

@Configuration

public class MySelfRule

{

    @Bean

    public IRule myRule()

    {

//        return new RandomRule();//Ribbon默認是輪詢，我自定義為隨機

        return new RandomRule_Hosystem(); //自定義每臺機器訪問5次

    }

}

[4].測驗

http://localhost/consumer/dept/list

參考檔案：

https://baike.baidu.com/item/F5%E6%96%B9%E6%A1%88/1121377?fr=aladdin

https://github.com/Netflix/ribbon/wiki

https://github.com/Netflix/ribbon/wiki/Getting-Started

https://github.com/Netflix/ribbon/blob/master/ribbon-loadbalancer/src/main/java/com/netflix/loadbalancer/RandomRule.java

轉載請註明出處，本文鏈接：https://www.uj5u.com/houduan/231300.html
標籤：Java

上一篇：mediasoup-client android studio java開發
下一篇：大佬們救救孩子吧

標籤雲

其他(157675) Python(38076) JavaScript(25376) Java(17977) C(15215) 區塊鏈(8255) C＃(7972) AI(7469) 爪哇(7425) MySQL(7132) html(6777) 基礎類(6313) sql(6102) 熊猫(6058) PHP(5869) 数组(5741) R(5409) Linux(5327) 反应(5209) 腳本語言(PerlPython)(5129) 非技術區(4971) Android(4554) 数据框(4311) css(4259) 节点.js(4032) C語言(3288) json(3245) 列表(3129) 扑(3119) C++語言(3117) 安卓(2998) 打字稿(2995) VBA(2789) Java相關(2746) 疑難問題(2699) 细绳(2522) 單片機工控(2479) iOS(2429) ASP.NET(2402) MongoDB(2323) 麻木的(2285) 正则表达式(2254) 字典(2211) 循环(2198) 迅速(2185) 擅长(2169) 镖(2155) 功能(1967) .NET技术(1958) Web開發(1951) python-3.x(1918) HtmlCss(1915) 弹簧靴(1913) C++(1909) xml(1889) PostgreSQL(1872) .NETCore(1853) 谷歌表格(1846) Unity3D(1843) for循环(1842)

熱門瀏覽

【C++】Microsoft C++、C 和匯編程式檔案
......
uj5u.com 2020-09-10 00:57:23 more

例外宣告
相比于斷言適用于排除邏輯上不可能存在的狀態，例外通常是用于邏輯上可能發生的錯誤。例外宣告 Item 1：當函式不可能拋出例外或不能接受拋出例外時，使用noexcept 理由如果不打算拋出例外的話，程式就會認為無法處理這種錯誤，并且應當盡早終止，如此可以有效地阻止例外的傳播與擴散。示例 //不可 ......
uj5u.com 2020-09-10 00:57:27 more

Codeforces 1400E Clear the Multiset(貪心 + 分治)
鏈接：https://codeforces.com/problemset/problem/1400/E 來源：Codeforces 思路：給你一個陣列，現在你可以進行兩種操作，操作1：將一段沒有 0 的區間進行減一的操作，操作2：將 i 位置上的元素歸零。最終問：將這個陣列的全部元素歸零后操作的最少 ......
uj5u.com 2020-09-10 00:57:30 more

UVA11610 【Reverse Prime】
本人看到此題沒有翻譯，就附帶了一個自己的翻譯版本思考這一題，它的第一個要求是找出所有 $7$ 位反向質數及其質因數的個數。我們應該需要質數篩篩選1~$10^{7}$的所有數，這里就不慢慢介紹了。但是，重讀題，我們突然發現反向質數都是 $7$ 位，而將它反過來后的數字卻是 $6$ 位數，這就說明 ......
uj5u.com 2020-09-10 00:57:36 more

統計區間素數數量
1 #pragma GCC optimize(2) 2 #include <bits/stdc++.h> 3 using namespace std; 4 bool isprime[1000000010]; 5 vector<int> prime; 6 inline int getlist(int ......
uj5u.com 2020-09-10 00:57:47 more

C/C++編程筆記：C++中的 const 變數詳解，教你正確認識const用法
1、C中的const 1、區域const變數存放在堆疊區中，會分配記憶體（也就是說可以通過地址間接修改變數的值）。測驗代碼如下：運行結果： 2、全域const變數存放在只讀資料段（不能通過地址修改，會發生寫入錯誤），默認為外部聯編，可以給其他源檔案使用（需要用extern關鍵字修飾）運行結果： ......
uj5u.com 2020-09-10 00:58:04 more

【C++犯錯記錄】VS2019 MFC添加資源不懂如何修改資源宏ID
1. 首先在資源視圖中，添加資源 2. 點擊新添加的資源，復制自動生成的ID 3. 在解決方案資源管理器中找到Resource.h檔案，編輯，使用整個專案搜索和替換的方式快速替換宏宣告 4. Ctrl+Shift+F 全域搜索，點擊查找全部，然后逐個替換 5. 為什么使用搜索替換而不使用屬性視窗直 ......
uj5u.com 2020-09-10 00:59:11 more

【C++犯錯記錄】VS2019 MFC不懂的批量添加資源
1. 打開資源頭檔案Resource.h，在其中預先定義好宏 ID（不清楚其實ID值應該設定多少，可以先新建一個相同的資源項，再在這個資源的ID值的基礎上遞增即可） 2. 在資源視圖中選中專案資源，按F7編輯資源檔案，按 ID 型別相對路徑的形式添加資源。（別忘了先把檔案拷貝到專案中的res檔案 ......
uj5u.com 2020-09-10 01:00:19 more

C/C++編程筆記：關于C++的參考型別，專供新手入門使用
今天要講的是C++中我最喜歡的一個用法——參考，也叫別名。參考就是給一個變數名取一個變數名，方便我們間接地使用這個變數。我們可以給一個變數創建N個參考，這N + 1個變數共享了同一塊記憶體區域。(參考型別的變數會占用記憶體空間，占用的記憶體空間的大小和指標型別的大小是相同的。雖然參考是一個物件的別名，但 ......
uj5u.com 2020-09-10 01:00:22 more

【C/C++編程筆記】從頭開始學習C ++：初學者完整指南
眾所周知，C ++的學習曲線陡峭，但是花時間學習這種語言將為您的職業帶來奇跡，并使您與其他開發人員區分開。您會更輕松地學習新語言，形成真正的解決問題的技能，并在編程的基礎上打下堅實的基礎。 C ++將幫助您養成良好的編程習慣（即清晰一致的編碼風格，在撰寫代碼時注釋代碼，并限制類內部的可見性），并且由 ......
uj5u.com 2020-09-10 01:00:41 more

最新发布

Rust中的智能指標:Box<T> Rc<T> Arc<T> Cell<T> RefCell<T> Weak
Rust中的智能指標是什么智能指標（smart pointers）是一類資料結構，是擁有資料所有權和額外功能的指標。是指標的進一步發展指標（pointer）是一個包含記憶體地址的變數的通用概念。這個地址參考，或 ” 指向”（points at）一些其他資料。參考以 & 符號為標志并借用了他們所 ......
uj5u.com 2023-04-20 07:24:10 more

Java的值傳遞和參考傳遞
值傳遞不會改變本身，參考傳遞（如果傳遞的值需要實體化到堆里）如果發生修改了會改變本身。 1.基本資料型別都是值傳遞 package com.example.basic; public class Test { public static void main(String[] args) { int ......
uj5u.com 2023-04-20 07:24:04 more

[2]SpinalHDL教程——Scala簡單入門
第一個 Scala 程式 shell里面輸入 $ scala scala> 1 + 1 res0: Int = 2 scala> println("Hello World!") Hello World! 檔案形式 object HelloWorld { /* 這是我的第一個 Scala 程式 * 以 ......
uj5u.com 2023-04-20 07:23:58 more

理解函式指標和回呼函式
理解函式指標指向函式的指標。比如：理解函式指標的偽代碼 void (*p)(int type, char *data); // 定義一個函式指標p void func(int type, char *data); // 宣告一個函式func p = func; // 將指標p指向函式func ......
uj5u.com 2023-04-20 07:23:52 more

Django筆記二十五之資料庫函式之日期函式
本文首發于公眾號：Hunter后端原文鏈接：Django筆記二十五之資料庫函式之日期函式日期函式主要介紹兩個大類，Extract() 和 Trunc() Extract() 函式作用是提取日期，比如我們可以提取一個日期欄位的年份，月份，日等資料 Trunc() 的作用則是截取，比如 2022-0 ......
uj5u.com 2023-04-20 07:23:45 more

一天吃透JVM面試八股文
什么是JVM？ JVM，全稱Java Virtual Machine（Java虛擬機），是通過在實際的計算機上仿真模擬各種計算機功能來實作的。由一套位元組碼指令集、一組暫存器、一個堆疊、一個垃圾回收堆和一個存盤方法域等組成。JVM屏蔽了與作業系統平臺相關的資訊，使得Java程式只需要生成在Java虛擬機 ......
uj5u.com 2023-04-20 07:23:31 more

使用Java接入小程式訂閱訊息！
更新完微信服務號的模板訊息之后，我又趕緊把微信小程式的訂閱訊息給實作了！之前我一直以為微信小程式也是要企業才能申請，沒想到小程式個人就能申請。訊息推送平臺🔥推送下發【郵件】【短信】【微信服務號】【微信小程式】【企業微信】【釘釘】等訊息型別。 https://gitee.com/zhongfuch ......
uj5u.com 2023-04-20 07:22:59 more

java -- 緩沖流、轉換流、序列化流
緩沖流緩沖流, 也叫高效流, 按照資料型別分類：位元組緩沖流：BufferedInputStream，BufferedOutputStream 字符緩沖流：BufferedReader，BufferedWriter 緩沖流的基本原理，是在創建流物件時，會創建一個內置的默認大小的緩沖區陣列，通過緩沖 ......
uj5u.com 2023-04-20 07:22:49 more

Java-SpringBoot-Range請求頭設定實作視頻分段傳輸
老實說，人太懶了，現在基本都不喜歡寫筆記了，但是網上有關Range請求頭的文章都太水了下面是抄的一段StackOverflow的代碼...自己大修改過的，寫的注釋挺全的，應該直接看得懂，就不解釋了寫的不好...只是希望能給視頻網站開發的新手一點點幫助吧. 業務場景：視頻分段傳輸、視頻多段傳輸（理 ......
uj5u.com 2023-04-20 07:22:42 more

Windows 10開發教程_編程入門自學教程_菜鳥教程-免費教程分享
教程簡介 Windows 10開發入門教程 - 從簡單的步驟了解Windows 10開發，從基本到高級概念，包括簡介，UWP，第一個應用程式，商店，XAML控制元件，資料系結，XAML性能，自適應設計，自適應UI，自適應代碼，檔案管理，SQLite資料庫，應用程式到應用程式通信，應用程式本地化，應用程式 ......
uj5u.com 2023-04-20 07:22:35 more

友情鏈接

有解無憂

Copyright © 2010-2020 有解無憂

5、Spring Cloud Ribbon

1.Ribbon簡介

(1).Ribbon介紹

(2).Ribbon作用

2.Ribbon配置

(1).修改pom.xml檔案

(2).修改application.yml

(3).修改ConfigBean.java

(5).修改DeptController_Consumer.java

(6).啟動eureka、provider、consumer

(7).測驗

(8).總結

3.Ribbon負載均衡

(1).Ribbon架構介紹

(2).創建provider8002、provider8003

[1].創建工程provider8002

[2].創建工程provider8003

(3).配置pom檔案

[1].配置provider8002 pom檔案

[2].配置provider8003 pom檔案

(4).配置yml檔案

[1].配置provider8002 yml檔案

[2].配置provider8003 yml檔案

(5).配置主啟動類

[1].DeptProvider8002_App

[2].DeptProvider8002_App

(6).創建資料庫database8002、database8003

[1].創建database8002

[2].創建database8003

(7).啟動eureka、provider、consumer

(8).訪問Dept微服務

(9).總結

4.Ribbon核心組件

(1).查看IRle介面

(2).查看IRleILoadBalancer介面

(3).查看AbstractLoadBalancer介面

(4).使用RandomRule演算法

(1).修改主啟動類

(2).配置事項

(3).自定義步驟

[1].新建package

[2].自定義Robbin規則類

[3].修改主啟動類

[4].測驗

(4).自定義規則深度決議

[1].原始碼決議

[2].RandomRule_Hosystem.java

[3].MySelfRule.java