SpringCloud與Consul集成實(shí)現(xiàn)負(fù)載均衡功能
負(fù)載均衡(Load Balance,簡稱LB)是一種服務(wù)器或網(wǎng)絡(luò)設(shè)備的集群技術(shù)。負(fù)載均衡將特定的業(yè)務(wù)(網(wǎng)絡(luò)服務(wù)、網(wǎng)絡(luò)流量等)分擔(dān)給多個(gè)服務(wù)器或網(wǎng)絡(luò)設(shè)備,從而提高了業(yè)務(wù)處理能力,保證了業(yè)務(wù)的高可用性。負(fù)載均衡基本概念有:實(shí)服務(wù)、實(shí)服務(wù)組、虛服務(wù)、調(diào)度算法、持續(xù)性等,其常用應(yīng)用場景主要是服務(wù)器負(fù)載均衡,鏈路負(fù)載均衡。
一、背景
SpringCloud微服務(wù)目前比較流行,其中大都在使用的服務(wù)注冊與發(fā)現(xiàn)是Eureka,最近研究了Consul的集群搭建,現(xiàn)使用Consul實(shí)現(xiàn)服務(wù)的負(fù)載均衡。其主要拓?fù)浣Y(jié)構(gòu)如下:

二、Consul集群環(huán)境搭建
本次搭建采用了三臺虛擬機(jī),Linux系統(tǒng),從Consul官網(wǎng)下載安裝包,解壓即可使用。在每臺機(jī)器下建一個(gè)目錄/data/consul/data,這個(gè)目錄主要存放器群啟動(dòng)后生成的一些數(shù)據(jù)。需要開啟的端口,8300, 8301, 8500, 8600。
分別在以下三個(gè)機(jī)器上執(zhí)行一下啟動(dòng)命令。
機(jī)器1:10.0.0.45
./consul agent -server -bootstrap-expect 2 -data-dir=/data/consul/data -node=consul-server-1 -bind=10.0.0.45 -client=0.0.0.0 &
機(jī)器2:10.0.0.100
./consul agent -server -bootstrap-expect 2 -data-dir=/data/consul/data -node=consul-server-2 -bind=10.0.0.100 -client=0.0.0.0 &
機(jī)器3:10.0.0.191
./consul agent -server -bootstrap-expect 2 -data-dir=/data/consul/data -node=consul-server-3 -bind=10.0.0.191 -client=0.0.0.0 -ui &
參數(shù)說明:
• server: 以server身份啟動(dòng)。默認(rèn)是client
• bootstrap-expect:集群要求的最少server數(shù)量,當(dāng)?shù)陀谶@個(gè)數(shù)量,集群即失效。
• data-dir:data存放的目錄,更多信息請參閱consul數(shù)據(jù)同步機(jī)制
• node:節(jié)點(diǎn)id,在同一集群不能重復(fù)。
• bind:監(jiān)聽的ip地址。默認(rèn)綁定0.0.0.0,可以不指定
• client: 客戶端的ip地址,0.0.0.0是指誰都可以訪問
• ui: 可以訪問UI界面
三臺機(jī)器上的服務(wù)啟動(dòng)完成后,將兩臺機(jī)器添加到其中一臺機(jī)器上,組建成集群。
分別在機(jī)器2和機(jī)器3上執(zhí)行:./consul join 10.0.0.45,構(gòu)成集群,同樣也可以再增加別的節(jié)點(diǎn)。
啟動(dòng)成功后訪問任意一臺機(jī)器 http://10.0.0.45:8500,會看到如下界面,有3個(gè)健康的節(jié)點(diǎn):

三、SpringCloud服務(wù)注冊
注冊中心已經(jīng)搭建完畢,接下來就是準(zhǔn)備兩個(gè)服務(wù),一個(gè)是生產(chǎn)者consul-producer,一個(gè)是消費(fèi)者consul-consumer。
3.1 生產(chǎn)者代碼,代碼很簡單,就是RestAPI請求并返回一個(gè)字符串
@RestController
public class ProducerController {
@GetMapping("/producer")
public String producer(){
System.out.println("I'm producer");
return "Hello, I'm producer";
}
}
以下是生產(chǎn)者consul-producer的啟動(dòng)配置文件application.yml:
spring:
application:
name: consul-producer #程序名稱
cloud:
consul:
host: 10.0.0.100 #consul節(jié)點(diǎn)IP
port: 8500 #consul節(jié)點(diǎn)端口
discovery:
instance-id: ${spring.application.name}:${spring.cloud.client.ip-address}:${server.port} #實(shí)例ID
health-check-path: /actuator/health #健康檢查
health-check-interval: 10s
server:
port: 9091 #消費(fèi)者服務(wù)端口
3.2 消費(fèi)者代碼,代碼也很簡單,使用大家熟悉分Feign,Controller接受請求,用過service調(diào)用消費(fèi)者提供的服務(wù)
/**
* 消費(fèi)者
*/
@RestController
public class ConsumerController {
@Autowired
private ConsumerService consumerService;
@GetMapping("/consumer")
public String getProducer(){
return consumerService.consumer();
}
}
以下是feign調(diào)用的接口聲明:
/**
* 調(diào)用生產(chǎn)者服務(wù)
*/
@FeignClient("consul-producer")
public interface ProducerRemote {
@GetMapping("/producer")
String producer();
}
以下是生產(chǎn)者consul-consumer的啟動(dòng)配置文件application.yml:
spring:
application:
name: consul-consumer #消費(fèi)者名稱
cloud:
consul:
host: 10.0.0.45 #consul注冊節(jié)點(diǎn)IP
port: 8500 #consul注冊節(jié)點(diǎn)端口
discovery:
instance-id: ${spring.application.name}:${spring.cloud.client.ip-address}:${server.port} #實(shí)例ID
health-check-path: /actuator/health #健康檢查
health-check-interval: 10s
server:
port: 9092 #消費(fèi)者服務(wù)端口
兩部分的源碼可在Github上查看https://github.com/liuzwei/consul-demo.git
生產(chǎn)者和消費(fèi)者存在了,就啟動(dòng)可以了,接下來是啟動(dòng)兩個(gè)生產(chǎn)者,一個(gè)消費(fèi)者,為了直觀的區(qū)分兩個(gè)生產(chǎn)者,在調(diào)用生產(chǎn)者返回的string稍微做了區(qū)分,一個(gè)是返回“Hello, I'm producer”,而另一個(gè)則返回“Hello, I'm producer2”,為了實(shí)現(xiàn)負(fù)載均衡便于測試。
其中在本機(jī)上10.0.0.93分別啟動(dòng)了程序consul-consumer和consul-producer,在另一臺機(jī)器10.0.0.191上啟動(dòng)另一個(gè)生產(chǎn)者實(shí)例consul-producer
啟動(dòng)之后在consul的界面上看到如下樣子:


四、測試負(fù)載功能
通過瀏覽器,Get請求消費(fèi)者的controller,會看到“Hello, I'm producer”和“Hello, I'm producer2”在交替顯示,這也是fegin調(diào)用的特性,輪詢機(jī)制實(shí)現(xiàn)負(fù)載均衡。


五、總結(jié)
目前微服務(wù)框架比較流行,最近項(xiàng)目也是上線了一些Spring Cloud微服務(wù)架構(gòu)的產(chǎn)品,同時(shí)也在探索其他可替代組件,因此對consul進(jìn)行了相關(guān)學(xué)習(xí),便整理成該文章,在consul的使用過程中也是存在一些不明白的地方,其中Eureka的注冊時(shí)可以配置多地址的,沒有發(fā)現(xiàn)consul怎么向多個(gè)節(jié)點(diǎn)進(jìn)行注冊,希望有用過的大佬給指點(diǎn)一二,還在學(xué)習(xí)中,共勉。
以上所述是小編給大家介紹的SpringCloud與Consul集成實(shí)現(xiàn)負(fù)載均衡功能,希望對大家有所幫助,如果大家有任何疑問請給我留言,小編會及時(shí)回復(fù)大家的。在此也非常感謝大家對腳本之家網(wǎng)站的支持!
相關(guān)文章
Java/Android 獲取網(wǎng)絡(luò)重定向文件的真實(shí)URL的示例代碼
本篇文章主要介紹了Java/Android 獲取網(wǎng)絡(luò)重定向文件的真實(shí)URL的示例代碼,具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下2017-11-11
mybatis-plus雪花算法自動(dòng)生成機(jī)器id原理及源碼
Mybatis-Plus是一個(gè)Mybatis的增強(qiáng)工具,它在Mybatis的基礎(chǔ)上做了增強(qiáng),卻不做改變,Mybatis-Plus是為簡化開發(fā)、提高開發(fā)效率而生,但它也提供了一些很有意思的插件,比如SQL性能監(jiān)控、樂觀鎖、執(zhí)行分析等,下面一起看看mybatis-plus雪花算法自動(dòng)生成機(jī)器id原理解析2021-06-06
MyBatis 動(dòng)態(tài)SQL和緩存機(jī)制實(shí)例詳解
這篇文章主要介紹了MyBatis 動(dòng)態(tài)SQL和緩存機(jī)制實(shí)例詳解,非常不錯(cuò),具有參考借鑒價(jià)值,需要的朋友可以參考下2017-09-09
Java工程編碼格式由GBK轉(zhuǎn)化成utf-8的具體實(shí)現(xiàn)
在寫項(xiàng)目的過程中我發(fā)現(xiàn)有的地方編碼格式被設(shè)置成了 gbk 如果用eclipse等工具直接改回utf-8編碼格式則會出現(xiàn)亂碼,所以本文給大家介紹了Java工程編碼格式由GBK轉(zhuǎn)化成utf-8的具體實(shí)現(xiàn),感興趣的朋友可以參考下2024-05-05
maven加載依賴報(bào)錯(cuò)的原因分析及解決方法
通常我們在項(xiàng)目中引入第三方依賴包時(shí),為了避免其版本迭代問題,經(jīng)常會使用本地的包,這篇文章主要給大家介紹了關(guān)于maven加載依賴報(bào)錯(cuò)的原因分析及解決方法的相關(guān)資料,需要的朋友可以參考下2023-10-10
Java實(shí)現(xiàn)word/pdf轉(zhuǎn)html并在線預(yù)覽
這篇文章主要為大家詳細(xì)介紹了如何利用Java語言實(shí)現(xiàn)word、pdf文件轉(zhuǎn)html并在線預(yù)覽的功能,文中的示例代碼講解詳細(xì),需要的可以參考一下2023-05-05
Java經(jīng)典設(shè)計(jì)模式之適配器模式原理與用法詳解
這篇文章主要介紹了Java經(jīng)典設(shè)計(jì)模式之適配器模式,簡單說明了適配器模式的概念、原理,并結(jié)合實(shí)例形式分析了java適配器模式的用法與相關(guān)注意事項(xiàng),需要的朋友可以參考下2017-08-08

