本篇文章給大家分享的是有關SpringBoot中如何實現集成dubbo和Zookeeper，小編覺得挺實用的，因此分享給大家學習，希望大家閱讀完這篇文章后可以有所收獲，話不多說，跟著小編一起來看看吧。
dubbo是阿里巴巴公司開源的一個高性能優秀的服務框架，一款高性能、輕量級的開源Java RPC框架，它提供了三大核心能力：面向接口的遠程方法調用，智能容錯和負載均衡，以及服務自動注冊和發現。
zookeeper
zooKeeper是一個分布式的，開放源碼的分布式應用程序協調服務，它是一個為分布式應用提供一致性服務的軟件，提供的功能包括：配置維護、域名服務、分布式同步、組服務等。
SpringBoot整合dubbo和Zookeeper
1、了解Dubbo基本概念
服務提供者（Provider）：暴露服務的服務提供方，服務提供者在啟動時，向注冊中心注冊自己提供的服務。
服務消費者（Consumer）：調用遠程服務的服務消費方，服務消費者在啟動時，向注冊中心訂閱自己所需的服務，服務消費者，從提供者地址列表中，基于軟負載均衡算法，選一臺提供者進行調用，如果調用失敗，再選另一臺調用。
注冊中心（Registry）（中臺）：注冊中心返回服務提供者地址列表給消費者，如果有變更，注冊中心將基于長連接推送變更數據給消費者
監控中心（Monitor）：服務消費者和提供者，在內存中累計調用次數和調用時間，定時每分鐘發送一次統計數據到監控中心
他們的關系如下：
1、服務容器啟動后，運行加載服務提供者provider；
2、服務提供者成功啟動，往注冊中心提供自己能提供的服務；
3、服務消費者consumer成功啟動，往注冊中心訂閱自己要消費的服務；
4、注冊中心Registry返回服務提供者地址列表給消費者，如果有變更，注冊中心將基于長連接推送變更數據給消費者。
5、服務消費者，從提供者地址列表中，基于軟負載均衡算法，選一臺提供者進行調用，如果調用失敗，再選另一臺調用。
6、服務消費者和提供者，在內存中累計調用次數和調用時間，定時每分鐘發送一次統計數據到監控中心。
2、在docker中安裝zookeeper
安裝：
（自動獲取到最新的zookeeper版本） docker pull zookeeper
啟動：
docker run --name zk01 -p 2181:2181 --restart always -d 6ad6cb039dfa 6ad6cb039dfa（鏡像id）
阿里云安全組規則和Linux系統防火墻都記得開放2181端口。
3、新建工程（1）新建工程，工程里新建兩個模塊，provider模塊
（2）consumer模塊
4、給兩個模塊導入相同的pom.xml文件
  zkclient使用起來還是有點坑，注意清除一些包中依賴，也是看狂神視頻學到的，這里在使用2.7.7版本時候用了新的注解出了點問題，還是改回來使用2.7.3，使用新版本還有點點區別，在代碼中我也給出一些警示了。
<dependencies>
<!-- dubbo 7.3倒是可以,7.7的就出錯連接不上了-->
<dependency>
<groupId>org.apache.dubbo</groupId>
<artifactId>dubbo-spring-boot-starter</artifactId>
<version>2.7.3</version>
</dependency>
<!-- zookeeper client zkclient-->
<!-- https://mvnrepository.com/artifact/com.github.sgroschupf/zkclient -->
<dependency>
<groupId>com.github.sgroschupf</groupId>
<artifactId>zkclient</artifactId>
<version>0.1</version>
</dependency>
<!-- 引入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>5、添加service層售票接口、接口實現類  （1）ITicketService
public interface ITicketService {
String saleTicket(String name);
}  （2）TicketServiceImpl
注意使用的包名稱一定要一致，不是spring帶的Service
package top.weidaboy.provider.service.Impl;
import org.apache.dubbo.config.annotation.Service;
import org.springframework.stereotype.Component;
import top.weidaboy.provider.service.ITicketService;
//zookeeper:服務注冊與發現
@Service //使用后被注入,項目已啟動就自動注冊到注冊中心
@Component //放到spring容器中去
//新版:import org.apache.dubbo.config.annotation.DubboService;
//@DubboService //將服務發布出去
public class TicketServiceImpl implements ITicketService {
@Override
public String saleTicket(String name) {
return "確認買票： "+name;
}
}6、application.proterties文件配置dubbo詳細信息
server.port=8081 #當前應用起名 dubbo.application.name=provider-server #找到zookeeper注冊中心地址 dubbo.registry.address=zookeeper://你的IP:2181 #掃描提供指定包下的服務 dubbo.scan.base-packages=top.weidaboy.provider.service
7、啟動服務提供者代碼
  啟動成功后，該程序會往對應的注冊中心地址注冊新的服務，供給需要消費的消費者使用
8、編寫服務消費者代碼
  既然有了服務提供者，那么就在consumer模塊中創建消費者來使用服務，分以下三步：
（1）創建消費者服務，以及實現接口
  UserService：
public interface IUserService {
//買票
String buyTicket(String name);
}   UserServiceImpl：
@Service//注入到容器中, 這個import org.springframework.stereotype.Service;
public class UserServiceImpl implements IUserService {
@Reference
//遠程引用指定的服務,
//該注解會按照全類名來進行匹配,看是哪個給注冊中心注冊了這個全類名
ITicketService ticketService; //相同的接口名
@Override
public String buyTicket(String name) {
return ticketService.saleTicket(name);
}
}（2）在consumer模塊中添加服務提供者的接口代碼
  要求：在consumer模塊提供方的代碼路徑必須與provider模塊的路徑一樣,只需導入接口類
ITicketService：
public interface ITicketService {
String saleTicket(String name);
} 代碼結構如圖：丑了點嘿嘿，湊合看吧
（3）修改application.proterties文件
  注意：這是在consumer模塊下的文件，因為消費者只是需要消費服務，無須注冊，就可以不用掃描對應的服務包名了
server.port=8082 #需要不同端口 #給當前應用起名: dubbo.application.name=consumer-server #注冊中心 dubbo.registry.address=zookeeper://你的IP:2181
9、編寫測試類
@SpringBootTest
class WeidaboyApplicationTests {
@Autowired
IUserService userService;
@Test
void contextLoads() {
System.out.println(userService.buyTicket("唐人街探案三"));
}
}10、測試調用不同端口的服務
  運行測試類，要求我們剛剛啟動的服務提供者的程序不要關閉，并且兩個端口不能相互占用，注冊中心地址一樣。
以上就是SpringBoot中如何實現集成dubbo和Zookeeper，小編相信有部分知識點可能是我們日常工作會見到或用到的。希望你能通過這篇文章學到更多知識。更多詳情敬請關注億速云行業資訊頻道。
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
