亚洲乱码中文字幕综合,中国熟女仑乱hd,亚洲精品乱拍国产一区二区三区,一本大道卡一卡二卡三乱码全集资源,又粗又黄又硬又爽的免费视频

SpringCloud Netflix Ribbon超詳細講解

 更新時間：2022年10月31日 08:34:44   作者：游坦之  
這篇文章主要介紹了SpringCloud筆記HoxtonNetflix之Ribbon負載均衡,Ribbon是管理HTTP和TCP服務客戶端的負載均衡器，Ribbon具有一系列帶有名稱的客戶端(Named Client)，對SpringCloud Ribbon負載均衡相關知識感興趣的朋友一起看看吧

一、Ribbon簡介

1、什么是Ribbon

Spring Cloud Ribbon 是基于Netflix Ribbon 實現(xiàn)的一套客戶端負載均衡的工具,它可以很好地控制HTTP和TCP客戶端的行為。

簡單的說，Ribbon 是 Netflix 發(fā)布的開源項目，主要功能是提供客戶端的軟件負載均衡算法，將 Netflix 的中間層服務連接在一起。Ribbon 的客戶端組件提供一系列完整的配置項，如：連接超時、重試等。簡單的說，就是在配置文件中列出 LoadBalancer (簡稱LB：負載均衡) 后面所有的及其，Ribbon 會自動的幫助你基于某種規(guī)則 (如簡單輪詢，隨機連接等等) 去連接這些機器。我們也容易使用 Ribbon 實現(xiàn)自定義的負載均衡算法！

2、Ribbon能干什么

  • LB，即負載均衡 (LoadBalancer) ，在微服務或分布式集群中經(jīng)常用的一種應用。
  • 負載均衡簡單的說就是將用戶的請求平攤的分配到多個服務上，從而達到系統(tǒng)的HA (高用)。
  • 常見的負載均衡軟件有 Nginx、Lvs（中國人研發(fā)的） 等等。

其中l(wèi)vs是中國技術專家章文嵩發(fā)明的

  • Dubbo、SpringCloud 中均給我們提供了負載均衡，SpringCloud 的負載均衡算法可以自定義。

負載均衡簡單分類：

  • 集中式LB

即在服務的提供方和消費方之間使用獨立的LB設施，如Nginx(反向代理服務器)，由該設施負責把訪問請求通過某種策略轉發(fā)至服務的提供方！

  • 進程式 LB

將LB邏輯集成到消費方，消費方從服務注冊中心獲知有哪些地址可用，然后自己再從這些地址中選出一個合適的服務器。 Ribbon就屬于進程內LB，它只是一個類庫，集成于消費方進程，消費方通過它來獲取到服務提供方的地址！

二、使用Ribbon

1、客戶端導入依賴

     <!--引入Eureka的依賴-->
     <dependencies>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-eureka</artifactId>
            <version>1.4.6.RELEASE</version>
        </dependency>
        <!--引入ribbon-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-ribbon</artifactId>
            <version>1.4.6.RELEASE</version>
        </dependency>
    </dependencies>

2、application.yml配置

server:
  port: 801

eureka:
  client:
    register-with-eureka: false  #不向eureka注冊自己
    service-url:
      defaultZone: http://localhost:7001/eureka/ #去哪個地方獲取

3、Controller配置

和前面兩節(jié)不一樣的是，用Ribbon做負載均衡，地址不能寫死，也就是不能和前面的一樣寫成一個具體的值如：localhost:8001，而是這個微服務的名字，也就是這個名字，如下。

package com.you.controller;
import com.you.pojo.Dept;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.client.RestTemplate;
import java.util.List;
@RestController
@ResponseBody
public class DeptComsumerController {
    @Autowired
    RestTemplate restTemplate;
//    public static final String REST_URL_PREFIX = "http://localhost:8001";
    public static final String REST_URL_PREFIX = "http://SPRINGCLOUD-PROVIDER-DEPT";
    @GetMapping("/consumer/dept/getDept/{id}")
    public Dept getDeptOfId(@PathVariable("id") Long id)
    {
        System.out.println(REST_URL_PREFIX+"/dept"+"/aDept/"+id);
        return restTemplate.getForObject(REST_URL_PREFIX + "/dept" + "/aDept/"+id, Dept.class);
    }
}

4、Config的配置

在此文件里，增加了@LoadBalanced注解，該注解的作用是讓RestTemplate有了負載均衡的能力，而且默認的負載均衡算法是輪詢（也就是一個一個的嘗試），可以使用系統(tǒng)配備的負載均衡算法，也可以自己寫自己的負載均衡算法。

package com.you.config;
import com.netflix.loadbalancer.IRule;
import com.netflix.loadbalancer.RandomRule;
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 {
    @Bean
    @LoadBalanced  //ribbon
    /*配置負載均衡實現(xiàn)RestTemplate*/
    /*IRule*/
    /*RoundRobinRule 輪詢 */
    /*RandomRule 隨機*/
    /*AvailabilityFilteringRule 優(yōu)先過濾掉跳閘、訪問故障的服務，對剩下的進行輪詢 */
    public RestTemplate getRestTemplate() {
        return new RestTemplate();
    }
}

5、啟動類的配置

package com.you;
import com.tan.tanRule;
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 = "SPRINGCLOUD-PROVIDER-DEPT",configuration = tanRule.class)
public class DeptConsumer_80 {
    public static void main(String[] args) {
        SpringApplication.run(DeptConsumer_80.class,args);
    }
}

三、Ribbon實現(xiàn)負載均衡

為了實現(xiàn)負載均衡，擴充一下服務提供者，將原來的一個服務提供者，改為三個。

  • 新建三個module，springboot-provider-8002、springboot-provider-8003。
  • 參考springboot-provider-8001，修改application.xml（主要是端口號，數(shù)據(jù)庫名，instance-id），其中application-name要保持一致。和微服務的名字一樣。

  • 啟動Eureka_7001，啟動這個三個提供者，根據(jù)自己的情況，如果電腦性能比較差，可以少啟動一個。啟動consumer_80。

訪問consumer_80配置的Getmapping地址，然后不斷的刷新，會看到依次訪問三個數(shù)據(jù)庫，并且一直重復，這就是默認的負載均衡算法：輪詢

四、設計負載均衡算法

1、80啟動類的改動

@RibbonClient()注釋的應用，在psvm上面添加該注釋，其具體內容為@RibbonClient(name = “SPRINGCLOUD-PROVIDER-DEPT”,configuration = tanRule.class)，其中name的值即為微服務的名字，configuration的值對應的就是自己寫的路由類

2、自定義路由類

需要注意，自定義的路由類，不可以用啟動類放在同一目錄，一般要比啟動類高一級目錄，放在同一目錄下，需要配置CompentScan。

package com.tan;
import com.netflix.loadbalancer.IRule;
import com.netflix.loadbalancer.RandomRule;
import org.springframework.context.annotation.Bean;
public class tanRule {
    @Bean
    public IRule myRule()
    {
        return new tanRandomRule();
    }
}

3、負載均衡算法的實現(xiàn)

可以模仿系統(tǒng)中的負載均衡算法，撰寫自己的負載均衡算法，如下面的例子即為：每個端口的提供者訪問5次，然后切換下一個端口，全部訪問完成后則重新開始，代碼如下：

package com.tan;
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 tanRandomRule extends AbstractLoadBalancerRule {
   int total = 0;
   int currentIndex = 0;
   public tanRandomRule() {
   }
   @SuppressWarnings({"RCN_REDUNDANT_NULLCHECK_OF_NULL_VALUE"})
   public Server choose(ILoadBalancer lb, Object key) {
       if (lb == null) {
           return null;
       } else {
           Server server = null;
           while(server == null) {
               if (Thread.interrupted()) {
                   return null;
               }
               List<Server> upList = lb.getReachableServers();
               List<Server> allList = lb.getAllServers();
               if(total<5)
               {
                   server = (Server)upList.get(currentIndex);
                   total++;
               }else{
                   total = 0;
                   currentIndex++;
                   if(currentIndex>2)
                   {
                       currentIndex = 0;
                   }
                   server = (Server)upList.get(currentIndex);
               }
               System.out.println("CurrentIndex:"+currentIndex);
               System.out.println("Total:"+total);
               System.out.println("sever 的值是:"+server);
               if (server == null) {
                   Thread.yield();
               } else {
                   if (server.isAlive()) {
                       return server;
                   }
                   server = null;
                   Thread.yield();
               }
           }
           return server;
       }
   }
   protected int chooseRandomInt(int serverCount) {
       return ThreadLocalRandom.current().nextInt(serverCount);
   }
   public Server choose(Object key) {
       return this.choose(this.getLoadBalancer(), key);
   }
   public void initWithNiwsConfig(IClientConfig clientConfig) {
   }
}

到此這篇關于SpringCloud Netflix Ribbon超詳細講解的文章就介紹到這了,更多相關SpringCloud Netflix Ribbon內容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家！

相關文章

  • 線程池之newCachedThreadPool可緩存線程池的實例

    線程池之newCachedThreadPool可緩存線程池的實例

    這篇文章主要介紹了線程池之newCachedThreadPool可緩存線程池的實例，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教
    2021-06-06
  • Java利用Selenium操作瀏覽器的示例詳解

    Java利用Selenium操作瀏覽器的示例詳解

    本文主要介紹如何使用java代碼利用Selenium操作瀏覽器，某些網(wǎng)頁元素加載慢，如何操作元素就會把找不到元素的異常，此時需要設置元素等待，等待元素加載完，再操作，感興趣的可以了解一下
    2023-01-01
  • java LinkedList的實例詳解

    java LinkedList的實例詳解

    這篇文章主要介紹了java LinkedList的實例詳解的相關資料,通過本文希望大家能徹底了解掌握這部分內容，需要的朋友可以參考下
    2017-09-09
  • spring security認證異常后返回中文提示的問題

    spring security認證異常后返回中文提示的問題

    這篇文章主要介紹了spring security認證異常后返回中文提示的問題,本文給大家介紹的非常詳細，對大家的學習或工作具有一定的參考借鑒價值，需要的朋友可以參考下
    2021-02-02
  • Java實現(xiàn)的權重算法（按權重展現(xiàn)廣告）

    Java實現(xiàn)的權重算法（按權重展現(xiàn)廣告）

    這篇文章主要介紹了Java實現(xiàn)的權重算法（按權重展現(xiàn)廣告）,本文講解了算法實現(xiàn)原理和實現(xiàn)代碼,需要的朋友可以參考下
    2015-04-04
  • JAVA OutputStreamWriter流的實現(xiàn)

    JAVA OutputStreamWriter流的實現(xiàn)

    OutputStreamWriter是從字符流到字節(jié)流的橋接,它使用的字符集可以通過名稱指定，也可以明確指定，或者可以接受平臺的默認字符集，本文詳細的介紹了JAVA OutputStreamWriter流的使用，感興趣的可以了解一下
    2021-06-06
  • Spring實戰(zhàn)之協(xié)調作用域不同步的Bean操作示例

    Spring實戰(zhàn)之協(xié)調作用域不同步的Bean操作示例

    這篇文章主要介紹了Spring實戰(zhàn)之協(xié)調作用域不同步的Bean操作,結合實例形式分析了Spring協(xié)調作用域不同步的Bean相關配置及使用技巧,需要的朋友可以參考下
    2019-11-11
  • Java中操作超大數(shù)的方法

    Java中操作超大數(shù)的方法

    本篇文章是小編在網(wǎng)上整理的關于java操作超大數(shù)的方法以及解決思路，有興趣的朋友參考學習下。
    2018-06-06
  • JNI實現(xiàn)最簡單的JAVA調用C/C++代碼

    JNI實現(xiàn)最簡單的JAVA調用C/C++代碼

    這篇文章主要介紹了JNI實現(xiàn)最簡單的JAVA調用C/C++代碼，具有一定的參考價值，感興趣的小伙伴們可以參考一下
    2017-08-08
  • springboot+redis自定義注解實現(xiàn)發(fā)布訂閱的實現(xiàn)代碼

    springboot+redis自定義注解實現(xiàn)發(fā)布訂閱的實現(xiàn)代碼

    在Redis中客戶端可以通過訂閱特定的頻道來接收發(fā)送至該頻道的消息，本文主要介紹了springboot+redis自定義注解實現(xiàn)發(fā)布訂閱，具有一定的參考價值，感興趣的可以了解一下
    2023-08-08

最新評論