總體實現思路是啟動一個生產者項目注冊, 將所含服務注冊到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進入到監(jiān)控頁面中

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

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

啟動消費者這個springboot項目

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

翻譯成功

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