springBoot+dubbo+zookeeper實現(xiàn)分布式開發(fā)應(yīng)用的項目實踐
環(huán)境搭建
項目結(jié)構(gòu)圖:

1.我們首先做好服務(wù)端
pom.xml
<dependencies>
<!--導(dǎo)入依賴: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 # 服務(wù)應(yīng)用名字 dubbo.application.name=provider-server # 注冊中心地址 dubbo.registry.address=zookeeper://127.0.0.1:2181 # 哪些服務(wù)要被注冊 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:服務(wù)注冊與發(fā)現(xiàn)
@Service //可以被掃描到,在項目一啟動就自動注冊到注冊中心
@Component //使用了Dubbo后盡量不要用Service注解
public class TicketServiceImpl implements TicketService {
@Override
public String getTicket() {
return "咸魚_翻身";
}
}
2.啟動服務(wù)端
打開服務(wù)端,開啟之后不要點掉,讓他在后臺運行:

執(zhí)行服務(wù)端的jar包,待會我們要監(jiān)控服務(wù)端:

運行上面的服務(wù)端代碼,然后去游覽器中查看
http://localhost:7001/

3.我們再來做客戶端
pom.xml
<dependencies>
<!--導(dǎo)入相關(guān)的依賴-->
<!--導(dǎo)入依賴: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 # 消費者去哪里拿服務(wù),需要暴露自己的名字 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提供的票,要去注冊中心拿到服務(wù)
@Reference //引用, pom坐標(biāo),可以定義路徑相同的接口名
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結(jié)果:拿到服務(wù)端的”咸魚_翻身“

4.總結(jié)
前提:zookeeper服務(wù)已經(jīng)開啟
1.首先提供者提供服務(wù)
- 導(dǎo)入依賴
- 配置注冊中心的地址,以及服務(wù)發(fā)現(xiàn)名,和要掃描的包
- 在想要被注冊的服務(wù)上面增加一個注解@Service
2.消費者如何消費
- 導(dǎo)入依賴
- 配置注冊中心的地址,配置自己的服務(wù)名
- 從遠程注入服務(wù) @Reference

到此這篇關(guān)于springBoot+dubbo+zookeeper實現(xiàn)分布式開發(fā)應(yīng)用的項目實踐的文章就介紹到這了,更多相關(guān)springBoot dubbo zookeeper分布式 內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
- Springboot 整合 Dubbo/ZooKeeper 實現(xiàn) SOA 案例解析
- SpringBoot整合Dubbo+Zookeeper實現(xiàn)RPC調(diào)用
- springboot+dubbo+zookeeper的簡單實例詳解
- IDEA整合Dubbo+Zookeeper+SpringBoot實現(xiàn)
- SpringBoot+Dubbo+Zookeeper實現(xiàn)簡單分布式開發(fā)的應(yīng)用詳解
- SpringBoot中dubbo+zookeeper實現(xiàn)分布式開發(fā)的應(yīng)用詳解
- SpringBoot+Dubbo+Zookeeper知識整合過程詳解
相關(guān)文章
mybatis?實現(xiàn)多層級collection嵌套
這篇文章主要介紹了mybatis?實現(xiàn)多層級collection嵌套,具有很好的參考價值,希望對大家有所幫助。如有錯誤或未考慮完全的地方,望不吝賜教2022-03-03
Intellj?idea新建的java源文件夾不是藍色的圖文解決辦法
idea打開java項目后新建的模塊中,java文件夾需要變成藍色,這篇文章主要給大家介紹了關(guān)于Intellj?idea新建的java源文件夾不是藍色的相關(guān)資料,文中通過圖文介紹的非常詳細,需要的朋友可以參考下2024-02-02
生產(chǎn)環(huán)境NoHttpResponseException異常排查解決記錄分析
這篇文章主要為大家介紹了生產(chǎn)環(huán)境NoHttpResponseException異常排查解決記錄分析,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪2023-10-10
ServletContext讀取web資源_動力節(jié)點Java學(xué)院整理
這篇文章主要介紹了ServletContext讀取web資源,小編覺得挺不錯的,現(xiàn)在分享給大家,也給大家做個參考。一起跟隨小編過來看看吧2017-07-07
Java中利用Alibaba開源技術(shù)EasyExcel來操作Excel表的示例代碼
這篇文章主要介紹了Java中利用Alibaba開源技術(shù)EasyExcel來操作Excel表的示例代碼,本文給大家介紹的非常詳細,對大家的學(xué)習(xí)或工作具有一定的參考借鑒價值,需要的朋友可以參考下2021-03-03

