springBoot+dubbo+zookeeper實現(xiàn)分布式開發(fā)應用的項目實踐
環(huán)境搭建
項目結構圖:
1.我們首先做好服務端
pom.xml
<dependencies> <!--導入依賴:Dubbo + zookeeper--> <dependency> <groupId>org.apache.dubbo</groupId> <artifactId>dubbo-spring-boot-starter</artifactId> <version>2.7.3</version> </dependency> <!--引入zkclient--> <dependency> <groupId>com.github.sgroschupf</groupId> <artifactId>zkclient</artifactId> <version>0.1</version> </dependency> <!--引入zkclient,可能會日志沖突,還需要剔除日志依賴--> <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> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-test</artifactId> <scope>test</scope> </dependency> </dependencies>
application.properties
server.port=8001 # 服務應用名字 dubbo.application.name=provider-server # 注冊中心地址 dubbo.registry.address=zookeeper://127.0.0.1:2181 # 哪些服務要被注冊 dubbo.scan.base-packages=com.wlm.service
TicketService
package com.wlm.service; public interface TicketService { public String getTicket(); }
TicketServiceImpl.java
package com.wlm.service; import org.apache.dubbo.config.annotation.Service; import org.springframework.stereotype.Component; //zookeeper:服務注冊與發(fā)現(xiàn) @Service //可以被掃描到,在項目一啟動就自動注冊到注冊中心 @Component //使用了Dubbo后盡量不要用Service注解 public class TicketServiceImpl implements TicketService { @Override public String getTicket() { return "咸魚_翻身"; } }
2.啟動服務端
打開服務端,開啟之后不要點掉,讓他在后臺運行:
執(zhí)行服務端的jar包,待會我們要監(jiān)控服務端:
運行上面的服務端代碼,然后去游覽器中查看
http://localhost:7001/
3.我們再來做客戶端
pom.xml
<dependencies> <!--導入相關的依賴--> <!--導入依賴:Dubbo + zookeeper--> <dependency> <groupId>org.apache.dubbo</groupId> <artifactId>dubbo-spring-boot-starter</artifactId> <version>2.7.3</version> </dependency> <!--引入zkclient--> <dependency> <groupId>com.github.sgroschupf</groupId> <artifactId>zkclient</artifactId> <version>0.1</version> </dependency> <!--引入zkclient,可能會日志沖突,還需要剔除日志依賴--> <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> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-test</artifactId> <scope>test</scope> </dependency> </dependencies>
application.properties
server.port=8002 # 消費者去哪里拿服務,需要暴露自己的名字 dubbo.application.name=consumer-server # 注冊中心的地址,可以在任何電腦上! dubbo.registry.address=zookeeper://127.0.0.1:2181
TicketService
package com.wlm.service; public interface TicketService { public String getTicket(); }
UserService.java
package com.wlm.service; import org.apache.dubbo.config.annotation.Reference; import org.springframework.stereotype.Service; @Service //放到容器中,注意區(qū)分 public class UserService { //想拿到provider-server提供的票,要去注冊中心拿到服務 @Reference //引用, pom坐標,可以定義路徑相同的接口名 TicketService ticketService; public void buyTicket(){ String ticket = ticketService.getTicket(); System.out.println("在注冊中心拿到=>"+ticket); } }
ConsumerServerApplicationTests.java
package com.wlm; import com.wlm.service.UserService; import org.junit.jupiter.api.Test; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.boot.test.context.SpringBootTest; @SpringBootTest class ConsumerServerApplicationTests { @Autowired UserService userService; @Test void contextLoads() { userService.buyTicket(); } }
運行ConsumerServerApplicationTests.java結果:拿到服務端的”咸魚_翻身“
4.總結
前提:zookeeper服務已經開啟
1.首先提供者提供服務
- 導入依賴
- 配置注冊中心的地址,以及服務發(fā)現(xiàn)名,和要掃描的包
- 在想要被注冊的服務上面增加一個注解@Service
2.消費者如何消費
- 導入依賴
- 配置注冊中心的地址,配置自己的服務名
- 從遠程注入服務 @Reference
到此這篇關于springBoot+dubbo+zookeeper實現(xiàn)分布式開發(fā)應用的項目實踐的文章就介紹到這了,更多相關springBoot dubbo zookeeper分布式 內容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家!
相關文章
springboot maven 項目打包jar 最后名稱自定義的教程
這篇文章主要介紹了springboot maven 項目打包jar 最后名稱自定義的教程,具有很好的參考價值,希望對大家有所幫助。一起跟隨小編過來看看吧2020-10-10基于SpringBoot集成測試遠程連接Redis服務的教程詳解
這篇文章主要介紹了基于SpringBoot集成測試遠程連接的Redis服務的相關知識,本文通過實例代碼給大家介紹的非常詳細,對大家的學習或工作具有一定的參考借鑒價值,需要的朋友可以參考下2020-03-03JavaWeb中struts2實現(xiàn)文件上傳下載功能實例解析
這篇文章主要介紹了JavaWeb中struts2文件上傳下載功能的實現(xiàn),在Web應用系統(tǒng)開發(fā)中,文件上傳和下載功能是非常常用的功能,需要的朋友可以參考下2016-05-05Java重寫(Override)與重載(Overload)區(qū)別原理解析
這篇文章主要介紹了Java重寫(Override)與重載(Overload)區(qū)別原理解析,文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下2020-02-02Spring Boot教程之利用ActiveMQ實現(xiàn)延遲消息
這篇文章主要給大家介紹了關于Spring Boot教程之利用ActiveMQ實現(xiàn)延遲消息的相關資料,文中通過示例代碼介紹的非常詳細,對大家學習或者使用Spring Boot具有一定的參考學習價值,需要的朋友們下面來一起學習學習吧2019-11-11JavaWeb 使用Session實現(xiàn)一次性驗證碼功能
這篇文章主要介紹了JavaWeb 使用Session實現(xiàn)一次性驗證碼功能,本文通過實例代碼給大家介紹的非常詳細,具有一定的參考借鑒價值,需要的朋友可以參考下2019-08-08SpringBoot項目請求不中斷動態(tài)更新代碼的實現(xiàn)
在開發(fā)中,有時候不停機動態(tài)更新代碼熱部署是一項至關重要的功能,它可以在請求不中斷的情況下下更新代碼,這種方式不僅提高了開發(fā)效率,還能加速測試和調試過程,本文將詳細介紹如何在 Spring Boot 項目在Linux系統(tǒng)中實現(xiàn)熱部署,特別關注優(yōu)雅關閉功能的實現(xiàn)2024-09-09