SpringBoot系列教程之dubbo和Zookeeper集成方法
今日學(xué)習(xí)新的內(nèi)容:dubbo
dubbo是阿里巴巴公司開(kāi)源的一個(gè)高性能優(yōu)秀的服務(wù)框架,一款高性能、輕量級(jí)的開(kāi)源Java RPC框架,它提供了三大核心能力:面向接口的遠(yuǎn)程方法調(diào)用,智能容錯(cuò)和負(fù)載均衡,以及服務(wù)自動(dòng)注冊(cè)和發(fā)現(xiàn)。
zookeeper
zooKeeper是一個(gè)分布式的,開(kāi)放源碼的分布式應(yīng)用程序協(xié)調(diào)服務(wù),它是一個(gè)為分布式應(yīng)用提供一致性服務(wù)的軟件,提供的功能包括:配置維護(hù)、域名服務(wù)、分布式同步、組服務(wù)等。
SpringBoot整合dubbo和Zookeeper
1、了解Dubbo基本概念
服務(wù)提供者(Provider):暴露服務(wù)的服務(wù)提供方,服務(wù)提供者在啟動(dòng)時(shí),向注冊(cè)中心注冊(cè)自己提供的服務(wù)。
服務(wù)消費(fèi)者(Consumer):調(diào)用遠(yuǎn)程服務(wù)的服務(wù)消費(fèi)方,服務(wù)消費(fèi)者在啟動(dòng)時(shí),向注冊(cè)中心訂閱自己所需的服務(wù),服務(wù)消費(fèi)者,從提供者地址列表中,基于軟負(fù)載均衡算法,選一臺(tái)提供者進(jìn)行調(diào)用,如果調(diào)用失敗,再選另一臺(tái)調(diào)用。
注冊(cè)中心(Registry)(中臺(tái)):注冊(cè)中心返回服務(wù)提供者地址列表給消費(fèi)者,如果有變更,注冊(cè)中心將基于長(zhǎng)連接推送變更數(shù)據(jù)給消費(fèi)者
監(jiān)控中心(Monitor):服務(wù)消費(fèi)者和提供者,在內(nèi)存中累計(jì)調(diào)用次數(shù)和調(diào)用時(shí)間,定時(shí)每分鐘發(fā)送一次統(tǒng)計(jì)數(shù)據(jù)到監(jiān)控中心
他們的關(guān)系如下:
1、服務(wù)容器啟動(dòng)后,運(yùn)行加載服務(wù)提供者provider;
2、服務(wù)提供者成功啟動(dòng),往注冊(cè)中心提供自己能提供的服務(wù);
3、服務(wù)消費(fèi)者consumer成功啟動(dòng),往注冊(cè)中心訂閱自己要消費(fèi)的服務(wù);
4、注冊(cè)中心Registry返回服務(wù)提供者地址列表給消費(fèi)者,如果有變更,注冊(cè)中心將基于長(zhǎng)連接推送變更數(shù)據(jù)給消費(fèi)者。
5、服務(wù)消費(fèi)者,從提供者地址列表中,基于軟負(fù)載均衡算法,選一臺(tái)提供者進(jìn)行調(diào)用,如果調(diào)用失敗,再選另一臺(tái)調(diào)用。
6、服務(wù)消費(fèi)者和提供者,在內(nèi)存中累計(jì)調(diào)用次數(shù)和調(diào)用時(shí)間,定時(shí)每分鐘發(fā)送一次統(tǒng)計(jì)數(shù)據(jù)到監(jiān)控中心。
2、在docker中安裝zookeeper
安裝:
(自動(dòng)獲取到最新的zookeeper版本) docker pull zookeeper
啟動(dòng):
docker run --name zk01 -p 2181:2181 --restart always -d 6ad6cb039dfa 6ad6cb039dfa(鏡像id)
阿里云安全組規(guī)則和Linux系統(tǒng)防火墻都記得開(kāi)放2181端口。
3、新建工程(1)新建工程,工程里新建兩個(gè)模塊,provider模塊
(2)consumer模塊
4、給兩個(gè)模塊導(dǎo)入相同的pom.xml文件
zkclient使用起來(lái)還是有點(diǎn)坑,注意清除一些包中依賴,也是看狂神視頻學(xué)到的,這里在使用2.7.7版本時(shí)候用了新的注解出了點(diǎn)問(wèn)題,還是改回來(lái)使用2.7.3,使用新版本還有點(diǎn)點(diǎn)區(qū)別,在代碼中我也給出一些警示了。
<dependencies> <!-- dubbo 7.3倒是可以,7.7的就出錯(cuò)連接不上了--> <dependency> <groupId>org.apache.dubbo</groupId> <artifactId>dubbo-spring-boot-starter</artifactId> <version>2.7.3</version> </dependency> <!-- zookeeper client zkclient--> <!-- https://mvnrepository.com/artifact/com.github.sgroschupf/zkclient --> <dependency> <groupId>com.github.sgroschupf</groupId> <artifactId>zkclient</artifactId> <version>0.1</version> </dependency> <!-- 引入zookeeper 避開(kāi)連接的坑 --> <dependency> <groupId>org.apache.curator</groupId> <artifactId>curator-framework</artifactId> <version>2.12.0</version> </dependency> <dependency> <groupId>org.apache.curator</groupId> <artifactId>curator-recipes</artifactId> <version>2.12.0</version> </dependency> <dependency> <groupId>org.apache.zookeeper</groupId> <artifactId>zookeeper</artifactId> <version>3.4.14</version> <!--排除這個(gè)slf4j-log4j12--> <exclusions> <exclusion> <groupId>org.slf4j</groupId> <artifactId>slf4j-log4j12</artifactId> </exclusion> </exclusions> </dependency>
5、添加service層售票接口、接口實(shí)現(xiàn)類 (1)ITicketService
public interface ITicketService { String saleTicket(String name); }
(2)TicketServiceImpl
注意使用的包名稱一定要一致,不是spring帶的Service
package top.weidaboy.provider.service.Impl; import org.apache.dubbo.config.annotation.Service; import org.springframework.stereotype.Component; import top.weidaboy.provider.service.ITicketService; //zookeeper:服務(wù)注冊(cè)與發(fā)現(xiàn) @Service //使用后被注入,項(xiàng)目已啟動(dòng)就自動(dòng)注冊(cè)到注冊(cè)中心 @Component //放到spring容器中去 //新版:import org.apache.dubbo.config.annotation.DubboService; //@DubboService //將服務(wù)發(fā)布出去 public class TicketServiceImpl implements ITicketService { @Override public String saleTicket(String name) { return "確認(rèn)買(mǎi)票: "+name; } }
6、application.proterties文件配置dubbo詳細(xì)信息
server.port=8081 #當(dāng)前應(yīng)用起名 dubbo.application.name=provider-server #找到zookeeper注冊(cè)中心地址 dubbo.registry.address=zookeeper://你的IP:2181 #掃描提供指定包下的服務(wù) dubbo.scan.base-packages=top.weidaboy.provider.service
7、啟動(dòng)服務(wù)提供者代碼
啟動(dòng)成功后,該程序會(huì)往對(duì)應(yīng)的注冊(cè)中心地址注冊(cè)新的服務(wù),供給需要消費(fèi)的消費(fèi)者使用
8、編寫(xiě)服務(wù)消費(fèi)者代碼
既然有了服務(wù)提供者,那么就在consumer模塊中創(chuàng)建消費(fèi)者來(lái)使用服務(wù),分以下三步:
(1)創(chuàng)建消費(fèi)者服務(wù),以及實(shí)現(xiàn)接口
UserService:
public interface IUserService { //買(mǎi)票 String buyTicket(String name); }
UserServiceImpl:
@Service//注入到容器中, 這個(gè)import org.springframework.stereotype.Service; public class UserServiceImpl implements IUserService { @Reference //遠(yuǎn)程引用指定的服務(wù), //該注解會(huì)按照全類名來(lái)進(jìn)行匹配,看是哪個(gè)給注冊(cè)中心注冊(cè)了這個(gè)全類名 ITicketService ticketService; //相同的接口名 @Override public String buyTicket(String name) { return ticketService.saleTicket(name); } }
(2)在consumer模塊中添加服務(wù)提供者的接口代碼
要求:在consumer模塊提供方的代碼路徑必須與provider模塊的路徑一樣,只需導(dǎo)入接口類
ITicketService:
public interface ITicketService { String saleTicket(String name); }
代碼結(jié)構(gòu)如圖:丑了點(diǎn)嘿嘿,湊合看吧
(3)修改application.proterties文件
注意:這是在consumer模塊下的文件,因?yàn)橄M(fèi)者只是需要消費(fèi)服務(wù),無(wú)須注冊(cè),就可以不用掃描對(duì)應(yīng)的服務(wù)包名了
server.port=8082 #需要不同端口 #給當(dāng)前應(yīng)用起名: dubbo.application.name=consumer-server #注冊(cè)中心 dubbo.registry.address=zookeeper://你的IP:2181
9、編寫(xiě)測(cè)試類
@SpringBootTest class WeidaboyApplicationTests { @Autowired IUserService userService; @Test void contextLoads() { System.out.println(userService.buyTicket("唐人街探案三")); } }
10、測(cè)試調(diào)用不同端口的服務(wù)
運(yùn)行測(cè)試類,要求我們剛剛啟動(dòng)的服務(wù)提供者的程序不要關(guān)閉,并且兩個(gè)端口不能相互占用,注冊(cè)中心地址一樣。
測(cè)試成功!
小結(jié)
本次學(xué)習(xí)內(nèi)容實(shí)現(xiàn):SpingBoot整合了dubbo和zookeeper實(shí)現(xiàn)分布式開(kāi)發(fā)的應(yīng)用,將提供服務(wù)和消費(fèi)服務(wù)進(jìn)行拆分,讓不同系統(tǒng)去管理,整體是為了更方便,更有目的的開(kāi)發(fā)項(xiàng)目,長(zhǎng)路漫漫,繼續(xù)前進(jìn)吧!
到此這篇關(guān)于SpringBoot系列教程之dubbo和Zookeeper集成方法的文章就介紹到這了,更多相關(guān)SpringBoot dubbo和Zookeeper集成內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
- 淺談Java(SpringBoot)基于zookeeper的分布式鎖實(shí)現(xiàn)
- 使用dubbo+zookeeper+spring boot構(gòu)建服務(wù)的方法詳解
- SpringBoot中dubbo+zookeeper實(shí)現(xiàn)分布式開(kāi)發(fā)的應(yīng)用詳解
- SpringBoot集成Curator實(shí)現(xiàn)Zookeeper基本操作的代碼示例
- SpringBoot整合Dubbo+Zookeeper實(shí)現(xiàn)RPC調(diào)用
- springboot應(yīng)用訪問(wèn)zookeeper的流程
- SpringBoot整合Zookeeper詳細(xì)教程
- Java Spring Boot 集成Zookeeper
- SpringBoot讀取ZooKeeper(ZK)屬性的方法實(shí)現(xiàn)
相關(guān)文章
Java 如何繞過(guò)迭代器遍歷時(shí)的數(shù)據(jù)修改異常
這篇文章主要介紹了Java 繞過(guò)迭代器遍歷時(shí)的數(shù)據(jù)修改異常的方法,幫助大家更好的理解和學(xué)習(xí)使用Java,感興趣的朋友可以了解下2021-02-02java實(shí)現(xiàn)簡(jiǎn)易的計(jì)算器界面
這篇文章主要為大家詳細(xì)介紹了java實(shí)現(xiàn)簡(jiǎn)易的計(jì)算器界面,文中示例代碼介紹的非常詳細(xì),具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下2022-04-04idea啟動(dòng)命令過(guò)長(zhǎng)的問(wèn)題及解決
當(dāng)IDEA啟動(dòng)命令過(guò)長(zhǎng)時(shí),可以通過(guò)修改workspace.xml文件或調(diào)整啟動(dòng)類配置來(lái)解決,方案一是在.idea文件或項(xiàng)目目錄中修改workspace.xml;方案二是通過(guò)運(yùn)行配置(run->edit)來(lái)保存啟動(dòng)設(shè)置,這兩種方法都可以有效縮短命令長(zhǎng)度,解決啟動(dòng)錯(cuò)誤2024-09-09Java實(shí)現(xiàn)輕松處理日期和時(shí)間的API小結(jié)
這篇文章主要為大家詳細(xì)介紹了Java中的日期和時(shí)間API,可以輕松處理日期和時(shí)間,文中的示例代碼講解詳細(xì),感興趣的小伙伴可以跟隨小編一起學(xué)習(xí)一下2024-03-03java實(shí)現(xiàn)馬踏棋盤(pán)算法(騎士周游問(wèn)題)
這篇文章主要為大家詳細(xì)介紹了java實(shí)現(xiàn)馬踏棋盤(pán)算法,解決騎士周游問(wèn)題,文中示例代碼介紹的非常詳細(xì),具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下2022-02-02Java實(shí)現(xiàn)大文件的分片上傳與下載(springboot+vue3)
這篇文章主要為大家詳細(xì)介紹了java基于springboot+vue3如何大文件的分片上傳與下載,文中示例代碼介紹的非常詳細(xì),具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下2023-06-06