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服務已經(jīng)開啟
1.首先提供者提供服務
- 導入依賴
- 配置注冊中心的地址,以及服務發(fā)現(xiàn)名,和要掃描的包
- 在想要被注冊的服務上面增加一個注解@Service
2.消費者如何消費
- 導入依賴
- 配置注冊中心的地址,配置自己的服務名
- 從遠程注入服務 @Reference

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

