總體實現思路是啟動一個生產者項目注冊, 將所含服務注冊到zookeeper的注冊中心, 然后在啟動一個消費者項目,將所需服務向zookeeper注冊中心進行訂閱, 等待注冊中心的通知

注冊中心基于負載均衡算法給消費者匹配到合適的生產者主機,然后通知消費者可以使用

實現生產者

導入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> <!--排除這個slf4j-log4j12--> <exclusions><exclusion> <groupId>org.slf4j</groupId> <artifactId>slf4j-log4j12</artifactId></exclusion> </exclusions> </dependency>

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

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

實現一個接口,在接口中完成需求

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

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

實現一個消費者

導入依賴, 和生產者的依賴是相同的

配置服務名字,注冊中心地址

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

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

實

現獲取翻譯服務

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

實現controller

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

測試

首先啟動zookeeper服務器和dubbo進入到監控頁面中

切記不要關閉服務器和dubbo開啟生產者這個springboot項目

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

啟動消費者這個springboot項目

訪問地址, 但是要注意我們消費者的tomcat啟動端口已經換成8082

翻譯成功

到此這篇關于SpringBoot中dubbo+zookeeper實現分布式開發的應用詳解的文章就介紹到這了,更多相關SpringBoot dubbo zookeeper分布式內容請搜索好吧啦網以前的文章或繼續瀏覽下面的相關文章希望大家以后多多支持好吧啦網！