怎么通過Zookeeper的API注冊(cè)微服務(wù)到Zookeeper ，針對(duì)這個(gè)問題，這篇文章詳細(xì)介紹了相對(duì)應(yīng)的分析和解答，希望可以幫助更多想解決這個(gè)問題的小伙伴找到更簡(jiǎn)單易行的方法。
公司主營(yíng)業(yè)務(wù)：成都做網(wǎng)站、網(wǎng)站建設(shè)、外貿(mào)營(yíng)銷網(wǎng)站建設(shè)、移動(dòng)網(wǎng)站開發(fā)等業(yè)務(wù)。幫助企業(yè)客戶真正實(shí)現(xiàn)互聯(lián)網(wǎng)宣傳，提高企業(yè)的競(jìng)爭(zhēng)能力。成都創(chuàng)新互聯(lián)是一支青春激揚(yáng)、勤奮敬業(yè)、活力青春激揚(yáng)、勤奮敬業(yè)、活力澎湃、和諧高效的團(tuán)隊(duì)。公司秉承以“開放、自由、嚴(yán)謹(jǐn)、自律”為核心的企業(yè)文化，感謝他們對(duì)我們的高要求，感謝他們從不同領(lǐng)域給我們帶來的挑戰(zhàn)，讓我們激情的團(tuán)隊(duì)有機(jī)會(huì)用頭腦與智慧不斷的給客戶帶來驚喜。成都創(chuàng)新互聯(lián)推出虞城免費(fèi)做網(wǎng)站回饋大家。
????springboot工程通過引入zk的依賴，通過注解注冊(cè)到zk，這個(gè)網(wǎng)上資料很多，就不多啰嗦了，這里主要給出，通過api注冊(cè)到zk，什么場(chǎng)景會(huì)用到呢？比如環(huán)境中有一些springboot工程，也有非springboot工程，那么對(duì)于springboot工程直接通過注解注冊(cè)，通過Feign調(diào)用其他微服務(wù)，非springboot工程通過api注解，其他服務(wù)通過服務(wù)名稱調(diào)用即可；
注解：@EnableDiscoveryClient org.springframework.cloud spring-cloud-starter-zookeeper-discovery 1.1.3.RELEASE
pom依賴org.apache.zookeeper zookeeper 3.4.11 pom com.101tec zkclient 0.10
????這里我先注冊(cè)兩個(gè)服務(wù)到ZK，一個(gè)zkClient，一個(gè)provider，這倆個(gè)都是標(biāo)準(zhǔn)的springboot工程，集成第二步中的組件注冊(cè)，zkClient會(huì)在接口中調(diào)用provider和后面要通過api注冊(cè)的微服務(wù)zkServices，并且有個(gè)接口會(huì)返回所有的實(shí)例，簡(jiǎn)單代碼如下：
重慶分公司
重慶分公司
//使用Feign調(diào)用微服務(wù)
@RequestMapping("/")
public String test() {
//調(diào)用provider服務(wù)
String str1 = providerClientI.callProviderTwo();
//調(diào)用zkServices服務(wù)
String str2 = zkClientI.callProviderOne();
return str1 + "-------" + str;
}
//獲取所有zk的微服務(wù)實(shí)例
@GetMapping("/allServices")
public List> allServiceUrl() {
List list = discoveryClient.getServices();
List> serviceInstance = new ArrayList<>();
if (list != null && list.size() > 0) {
for (String serviceId : list) {
serviceInstance.add(discoveryClient.getInstances(serviceId));
}
}
return serviceInstance;
} ????進(jìn)入到zk的目錄下，使用命令./zkCli.sh -server 192.168.xx.xx:2181接入zookeeper，然后使用ls / 查看所有的節(jié)點(diǎn)，然后使用ls /services查看services下的節(jié)點(diǎn)，注冊(cè)的服務(wù)默認(rèn)在services節(jié)點(diǎn)下，此時(shí)可以看到provider,和zkClient，查看provider和zkClient下面發(fā)現(xiàn)下面有一個(gè)節(jié)點(diǎn)，貌似是以UUID命名的，然后使用get命令查看下面的節(jié)點(diǎn)內(nèi)的數(shù)據(jù)內(nèi)容，如下：
然后我們大概明白了，原來一個(gè)微服務(wù)實(shí)例注冊(cè)到zk，就是在節(jié)點(diǎn)里面放了這些數(shù)據(jù)，下面開始我們通過API注冊(cè)的工作
????我先來一段很簡(jiǎn)單的代碼，全部是寫死的，后面測(cè)試我們的方法可行之后，我們?cè)賹?duì)代碼進(jìn)行優(yōu)雅的改造，該封裝的封裝，該寫成配置的就配置化，先驗(yàn)證后完善，這里的regeister方法是核心方法，里面通過Zookeeper類的create方法向服務(wù)器創(chuàng)建節(jié)點(diǎn)并把數(shù)據(jù)寫入節(jié)點(diǎn)，實(shí)際上寫入的就是服務(wù)的注冊(cè)信息，寫入之后，其他的節(jié)點(diǎn)才能發(fā)現(xiàn)本節(jié)點(diǎn)，繼而才能調(diào)用它；
@Override
public void register(String serviceName, String serviceAddress) {
String registryPath = REGISTRY_PATH;
try {
zk.create("/services/zkServices", null, ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
String uuid = "95b4f91c-96b9-4aa6-ab61-935a7f8be599";
String data = "{\"name\":\"zkService\",\"id\":\"95b4f91c-96b9-4aa6-ab61-935a7f8be599\",\"address\":\"192.168.6.164\",\"port\":9505,\"sslPort\":null,\"payload\":{\"@class\":\"org.springframework.cloud.zookeeper.discovery.ZookeeperInstance\",\"id\":\"zkService:9505\",\"name\":\"zkService\",\"metadata\":{\"instance_status\":\"UP\"}},\"registrationTimeUTC\":1534763883884,\"serviceType\":\"DYNAMIC\",\"uriSpec\":{\"parts\":[{\"value\":\"scheme\",\"variable\":true},{\"value\":\"://\",\"variable\":false},{\"value\":\"address\",\"variable\":true},{\"value\":\":\",\"variable\":false},{\"value\":\"port\",\"variable\":true}]}}";
zk.create("/services/zkServices/">
這段代碼簡(jiǎn)單粗暴，就是直接create創(chuàng)建/services/zkServices節(jié)點(diǎn)，然后再create往里面放入數(shù)據(jù)，數(shù)據(jù)就是從provider服務(wù)里面拷貝過來的，就是個(gè)json，我把相關(guān)的地址，服務(wù)名稱啥的改了下，然后啟動(dòng)工程，之后檢查zk，果然創(chuàng)建了節(jié)點(diǎn)，get命令查看數(shù)據(jù)也和創(chuàng)建的一致，然后在訪問zkClient服務(wù)的上面的兩個(gè)接口，都成功了，一個(gè)正確的返回了zkServices和provider的響應(yīng)字符串，另一個(gè)接口正確顯示出了三個(gè)服務(wù)的信息，包括zkClient，provider，zkServices，這說明通過api注冊(cè)一個(gè)服務(wù)成功了；
關(guān)于怎么通過Zookeeper的API注冊(cè)微服務(wù)到Zookeeper 問題的解答就分享到這里了，希望以上內(nèi)容可以對(duì)大家有一定的幫助，如果你還有很多疑惑沒有解開，可以關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道了解更多相關(guān)知識(shí)。
