今日學(xué)習(xí)新的內(nèi)容：dubbo

  dubbo是阿里巴巴公司開源的一個(gè)高性能優(yōu)秀的服務(wù)框架，一款高性能、輕量級(jí)的開源Java RPC框架，它提供了三大核心能力：面向接口的遠(yuǎn)程方法調(diào)用，智能容錯(cuò)和負(fù)載均衡，以及服務(wù)自動(dòng)注冊(cè)和發(fā)現(xiàn)。

zookeeper

  zooKeeper是一個(gè)分布式的，開放源碼的分布式應(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 6ad6cb039dfa6ad6cb039dfa（鏡像id）

阿里云安全組規(guī)則和Linux系統(tǒng)防火墻都記得開放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 避開連接的坑 --> <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)買票： '+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、編寫服務(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 { //買票 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、編寫測(cè)試類

@SpringBootTestclass 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)分布式開發(fā)的應(yīng)用，將提供服務(wù)和消費(fèi)服務(wù)進(jìn)行拆分，讓不同系統(tǒng)去管理，整體是為了更方便，更有目的的開發(fā)項(xiàng)目，長(zhǎng)路漫漫，繼續(xù)前進(jìn)吧！

到此這篇關(guān)于SpringBoot系列教程之dubbo和Zookeeper集成方法的文章就介紹到這了,更多相關(guān)SpringBoot dubbo和Zookeeper集成內(nèi)容請(qǐng)搜索好吧啦網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持好吧啦網(wǎng)！