文章詳情頁

SpringBoot中dubbo+zookeeper實現分布式開發的應用詳解

瀏覽：67日期：2023-04-06 18:14:28

總體實現思路是啟動一個生產者項目注冊, 將所含服務注冊到zookeeper的注冊中心, 然后在啟動一個消費者項目,將所需服務向zookeeper注冊中心進行訂閱, 等待注冊中心的通知

注冊中心基于負載均衡算法給消費者匹配到合適的生產者主機,然后通知消費者可以使用

實現生產者

導入zookeeper依賴包

<dependency> <groupId>org.apache.dubbo</groupId> <artifactId>dubbo-spring-boot-starter</artifactId> <version>2.7.3</version> </dependency>   <dependency> <groupId>com.github.sgroschupf</groupId> <artifactId>zkclient</artifactId> <version>0.1</version> </dependency>   <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>  <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);}

實現一個消費者

導入依賴, 和生產者的依賴是相同的

配置服務名字,注冊中心地址

server.port=8082# 配置zookeeper# 配置服務名字dubbo.application.name=consumer.server# 配置注冊中心地址dubbo.registry.address=zookeeper://127.0.0.1:2181

本來正常步驟是需要將服務提供者的接口打包，然后用pom文件導入，我們這里使用簡單的方式，直接將服務的接口拿過來，路徑必須保證正確，即和服務提供者相同

SpringBoot中dubbo+zookeeper實現分布式開發的應用詳解實

現獲取翻譯服務

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進入到監控頁面中