SpringCloud客戶端的負載均衡Ribbon的實現(xiàn)
更新時間：2018年06月20日 14:03:19 作者：lfalex
微服務(wù)架構(gòu)，不可避免的存在單個微服務(wù)有多個實例，這篇文章主要介紹了SpringCloud客戶端的負載均衡Ribbon的實現(xiàn)，小編覺得挺不錯的，現(xiàn)在分享給大家，也給大家做個參考。一起跟隨小編過來看看吧
前言：微服務(wù)架構(gòu)，不可避免的存在單個微服務(wù)有多個實例，那么客戶端如何將請求分攤到多個微服務(wù)的實例上呢？這里我們就需要使用負載均衡了
一、Ribbon簡介
Ribbon是Netflix發(fā)布的負載均衡器，它有助于控制HTTP和TCP客戶端的行為。為Ribbon配置服務(wù)提供者地址列表后，Ribbon就可基于某種負載均衡算法，自動地幫助服務(wù)消費者去請求。Ribbon默認為我們提供了很多的負載均衡算法，例如：輪詢，隨機等，也可自定義；
Ribbon的GitHub： https://github.com/Netflix/ribbon
而在SpringCloud中使用Ribbon和Eureka時，Ribbon會自動從EurekaServer中獲取服務(wù)提供者地址列表，并基于負載均衡算法。
二、Ribbon實戰(zhàn)
1、創(chuàng)建EurekaServer，EurekaClient1，EurekaClient2，之前已經(jīng)說過了Eureka的使用，這里直接上代碼：
EurekaServer：
ServerApplication.java
@SpringBootApplication
@EnableEurekaServer
public class ServerApplication {
public static void main(String[] args) {
SpringApplication.run(ServerApplication.class,args);
}
}
pom.xml
<?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">
<modelVersion>4.0.0</modelVersion>
<groupId>com.cn</groupId>
<artifactId>eureka-ribbon-server</artifactId>
<version>1.0-SNAPSHOT</version>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<java.version>1.8</java.version>
</properties>
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>1.5.13.RELEASE</version>
</parent>
<dependencies>
<dependency>
<groupId>org.springframework.</groupId>
<artifactId></artifactId>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-eureka-server</artifactId>
</dependency>
</dependencies>
<dependencyManagement>
<dependencies>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-dependencies</artifactId>
<version>Edgware.SR3</version>
<type>pom</type>
<scope>import</scope>
</dependency>
</dependencies>
</dependencyManagement>
<!-- 添加spring-boot的maven插件 -->
<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
</build>
</project>
application.properties
server.port=8761 #注意：這兩個配置eureka默認為true，要改成false，否則會報錯，connot connect server #表示是否將自己注冊在EurekaServer上 eureka.client.register-with-eureka=false #表示是否從EurekaServer獲取注冊信息 eureka.client.fetch-registry=false eureka.client.service-url.defaultZone=http://localhost:8761/eureka/
EurekaClient1:
pom.xml
<?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">
<modelVersion>4.0.0</modelVersion>
<groupId>com.cn</groupId>
<artifactId>eureka-ribbon-client</artifactId>
<version>1.0-SNAPSHOT</version>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<java.version>1.8</java.version>
</properties>
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>1.5.13.RELEASE</version>
</parent>
<dependencies>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-ribbon</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-eureka</artifactId>
</dependency>
</dependencies>
<dependencyManagement>
<dependencies>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-dependencies</artifactId>
<version>Edgware.SR3</version>
<type>pom</type>
<scope>import</scope>
</dependency>
</dependencies>
</dependencyManagement>
<!-- 添加spring-boot的maven插件 -->
<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
</build>
</project>
server.port=8762 spring.application.name=client-8762 eureka.client.service-url.defaultZone=http://localhost:8761/eureka/
而在啟動類中加入RestTemplate遠程調(diào)用實例到容器中，并且 添加LoadBalanced注解，使RestTemplate具備負載均衡的能力 ：
@SpringBootApplication
@EnableDiscoveryClient
public class ClientApplication {
public static void main(String[] args) {
SpringApplication.run(ClientApplication.class, args);
}
/**
* @Description: 加入@LoadBalanced注解，就可以為RestTemplate加入負載均衡的能力
* @Param:
* @return:
* @Author:
* @Date: 2018/6/15
*/
@Bean
@LoadBalanced
public RestTemplate getRestTemplate() {
return new RestTemplate();
}
}
創(chuàng)建Controller，注入RestTemplate、LoadBalancerClient實例：
package com.cn.controller;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cloud.client.ServiceInstance;
import org.springframework.cloud.client.loadbalancer.LoadBalancerClient;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.client.RestTemplate;
/**
* @program: springcloud-example
* @description:
* @author:
* @create: 2018-06-15 15:55
**/
@Controller
public class RibbonController {
@Autowired
private LoadBalancerClient loadBalancerClient;
@Autowired
private RestTemplate restTemplate;
@GetMapping("/loadInstance")
@ResponseBody
public String loadInstance() {
ServiceInstance choose = this.loadBalancerClient.choose("client-87");
System.out.println(choose.getServiceId()+":"+choose.getHost()+":"+choose.getPort());
return choose.getServiceId() + ":" + choose.getHost() + ":" + choose.getPort();
}
}
package com.cn;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
/**
* @program: springcloud-example
* @description:
* @author: 535504
* @create: 2018-06-15 16:05
**/
@SpringBootApplication
@EnableDiscoveryClient
public class ClientApplication {
public static void main(String[] args) {
SpringApplication.run(ClientApplication.class, args);
}
}
EurekaClient2：
pom.xml與EurekaClient1中一致
application.xml:
server.port=8763 spring.application.name=client-87 eureka.client.service-url.defaultZone=http://localhost:8761/eureka
ClientController.java:
package com.cn.contorller;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.ResponseBody;
/**
* @program: springcloud-example
* @description:
* @author:
* @create: 2018-06-15 16:12
**/
@Controller
public class ClientController {
@GetMapping("/getUser")
@ResponseBody
public String getUser() {
System.out.println("獲取用戶成功");
return "獲取用戶成功";
}
}
2、啟動順序：
①、依次啟動EurekaServer =》 EurekaClient1 =》 EurekaClient2 ；
②、然后將EurekaClient2中的application.properties的server.port=8763改為server.port=8764，再次啟動該項目;
③、打開EurekaServer的配置頁面（http://localhost:8761/），如下：
④、我們在地址欄輸入http://localhost:8762/loadInstance，多刷新幾次，會發(fā)現(xiàn)每次調(diào)用的端口實例都不同，如下圖：
⑤、我們在看控制臺，如圖：
至此，Ribbon已經(jīng)入門，是不是很簡單，但是這只是最簡單的應(yīng)用，九牛一毛爾...學(xué)無止境乎！
相關(guān)文章
mybatis中數(shù)據(jù)加密與解密的實現(xiàn)
數(shù)據(jù)加解密的實現(xiàn)方式多種多樣，在mybatis環(huán)境中數(shù)據(jù)加解密變得非常簡單易用，本文主要介紹了mybatis中數(shù)據(jù)加密與解密的實現(xiàn)，文中通過示例代碼介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們可以參考一下2022-03-03
這篇文章主要介紹了使用SpringAOP獲取用戶操作日志入庫，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2021-11-11
Intelli IDEA安裝Scala插件并安裝Scala軟件和配置環(huán)境變量的詳細教程
這篇文章主要介紹了Intelli IDEA安裝Scala插件并安裝Scala軟件和配置環(huán)境變量的詳細教程,需要的朋友可以參考下2020-10-10
Java?EasyExcel利用填充模版動態(tài)生成多個sheet頁
這篇文章主要為大家詳細介紹了Java?EasyExcel如何利用填充模版動態(tài)生成多個sheet頁,文中的示例代碼講解詳細,感興趣的小伙伴可以跟隨小編一起學(xué)習(xí)一下2023-12-12
這篇文章主要為大家介紹了SpringMVC?RESTFul實現(xiàn)列表功能詳解，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進步，早日升職加薪2022-05-05
在學(xué)習(xí)了一個學(xué)期的java以后，搞了一個多線程的聊天室，熟悉了一下服務(wù)器和客戶機的操作。感興趣的小伙伴們可以參考一下2021-06-06
今天小編就為大家分享一篇關(guān)于Java分布式鎖的概念與實現(xiàn)方式詳解，小編覺得內(nèi)容挺不錯的，現(xiàn)在分享給大家，具有很好的參考價值，需要的朋友一起跟隨小編來看看吧2019-01-01
這篇文章主要介紹了Spring-boot-starter常用依賴模塊及spring boot的兩大優(yōu)點,需要的朋友可以參考下2018-01-01
java_時間戳與Date_相互轉(zhuǎn)化的實現(xiàn)代碼
本篇文章是對java_時間戳與Date_相互轉(zhuǎn)化的實現(xiàn)代碼進行了詳細的分析介紹,需要的朋友參考下如下。2016-11-11
所謂代碼塊是指用"{}"括起來的一段代碼，根據(jù)其位置和聲明的不同，可以分為普通代碼塊、構(gòu)造塊、靜態(tài)塊、和同步代碼塊。如果在代碼塊前加上?synchronized關(guān)鍵字，則此代碼塊就成為同步代碼塊2022-05-05