總體實(shí)現(xiàn)思路是啟動(dòng)一個(gè)生產(chǎn)者項(xiàng)目注冊, 將所含服務(wù)注冊到zookeeper的注冊中心, 然后在啟動(dòng)一個(gè)消費(fèi)者項(xiàng)目,將所需服務(wù)向zookeeper注冊中心進(jìn)行訂閱, 等待注冊中心的通知

注冊中心基于負(fù)載均衡算法給消費(fèi)者匹配到合適的生產(chǎn)者主機(jī),然后通知消費(fèi)者可以使用

實(shí)現(xiàn)生產(chǎn)者

導(dǎo)入zookeeper依賴包

<!-- Dubbo Spring Boot Starter --> <dependency> <groupId>org.apache.dubbo</groupId> <artifactId>dubbo-spring-boot-starter</artifactId> <version>2.7.3</version> </dependency> <!--zookeeper的包--> <!-- https://mvnrepository.com/artifact/com.github.sgroschupf/zkclient --> <dependency> <groupId>com.github.sgroschupf</groupId> <artifactId>zkclient</artifactId> <version>0.1</version> </dependency> <!-- 引入zookeeper --> <!--【新版的坑】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>

配置服務(wù)名字, 注冊中心地址, 掃描被注冊的包

server.port=8081#當(dāng)前應(yīng)用名字dubbo.application.name=provider-server#注冊中心地址dubbo.registry.address=zookeeper://127.0.0.1:2181#掃描指定包下服務(wù)dubbo.scan.base-packages=com.demo.service

實(shí)現(xiàn)一個(gè)接口,在接口中完成需求

public interface Translate { String translate(String str);}

public interface Translate { String translate(String str);}

實(shí)現(xiàn)一個(gè)消費(fèi)者

導(dǎo)入依賴, 和生產(chǎn)者的依賴是相同的

配置服務(wù)名字,注冊中心地址

server.port=8082# 配置zookeeper# 配置服務(wù)名字dubbo.application.name=consumer.server# 配置注冊中心地址dubbo.registry.address=zookeeper://127.0.0.1:2181

本來正常步驟是需要將服務(wù)提供者的接口打包，然后用pom文件導(dǎo)入，我們這里使用簡單的方式，直接將服務(wù)的接口拿過來，路徑必須保證正確，即和服務(wù)提供者相同

實(shí)

現(xiàn)獲取翻譯服務(wù)

package com.demo.service;import org.apache.dubbo.config.annotation.Reference;import org.springframework.stereotype.Service;@Service //使用Spring的Service添加組件public class Translation { @Reference //遠(yuǎn)程引用指定的服務(wù)，他會按照全類名進(jìn)行匹配，看誰給注冊中心注冊了這個(gè)全類名 private Translate translate; public String getTranslation(String str) { return translate.translate(str); }}

實(shí)現(xiàn)controller

@RestControllerpublic class TranslateController { @Autowired Translation translation; @RequestMapping('/tran/{str}') public String tran(@PathVariable('str')String str) { return translation.getTranslation(str); }}

測試

首先啟動(dòng)zookeeper服務(wù)器和dubbo進(jìn)入到監(jiān)控頁面中

切記不要關(guān)閉服務(wù)器和dubbo開啟生產(chǎn)者這個(gè)springboot項(xiàng)目

上圖顯示就是生產(chǎn)者注冊成功, 我們可以點(diǎn)擊ip查看詳情

啟動(dòng)消費(fèi)者這個(gè)springboot項(xiàng)目

訪問地址, 但是要注意我們消費(fèi)者的tomcat啟動(dòng)端口已經(jīng)換成8082

翻譯成功

到此這篇關(guān)于SpringBoot中dubbo+zookeeper實(shí)現(xiàn)分布式開發(fā)的應(yīng)用詳解的文章就介紹到這了,更多相關(guān)SpringBoot dubbo zookeeper分布式內(nèi)容請搜索好吧啦網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持好吧啦網(wǎng)！