springboot-zookeeper-dubbo
- 建議maven項目,pom.xml加上相應依賴
<parent> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-parent</artifactId> <version>2.3.3.RELEASE</version> <relativePath/> <!-- lookup parent from repository --> </parent> <properties> <java.version>1.8</java.version> </properties> <dependencies> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> <scope>compile</scope> </dependency> <!-- dubbo 相關依賴 --> <dependency> <groupId>org.apache.dubbo</groupId> <artifactId>dubbo-spring-boot-starter</artifactId> <version>2.7.8</version> </dependency> <dependency> <groupId>org.apache.curator</groupId> <artifactId>curator-recipes</artifactId> <version>2.13.0</version> </dependency> <dependency> <groupId>org.apache.zookeeper</groupId> <artifactId>zookeeper</artifactId> <version>3.4.13</version> <type>pom</type> </dependency> </dependencies>
- 建立一個Module 專門存放Consumer和provider 公用元素,可取名xxx-base模闆,存放共同的接口和工具類等
- 建立Consumer對應的Module和Provider對應的Module,兩者都引用base Module
<dependencies> <dependency> <groupId>com.baoyong</groupId> <artifactId>dubbo-base</artifactId> <version>${project.parent.version}</version> </dependency> </dependencies>
- 安裝zookeeper,下載下傳個壓縮包本地解壓修改一下conf/zoo.cfg即可,啟動zk;
- 消費者 application配置:
#Dubbo configuration dubbo.application.name=dubbo_consumer dubbo.registry.protocol=zookeeper dubbo.registry.address=zookeeper://127.0.0.1:2181 # 注解中引用此版本,之後消費者可通過配置該參數實作動态切換引用的生産者 dubbo.provider.version=2.0
- 生産者application配置:
## dubbo 配置 dubbo.application.name=dubbo_provider dubbo.registry.protocol=zookeeper dubbo.registry.address=zookeeper://127.0.0.1:2181 dubbo.protocol.name=dubbo dubbo.protocol.port=20880 # 掃描注解包通過該設定将服務注冊到zookeeper dubbo.scan.base-packages=com.baoyong.provider.service.impl
- 消費者 application配置:
- 接口實作及調用:
- 在base的項目中定義接口 如 TestService。
- 在provider項目中實作base定義的接口,TestServiceImpl,注意引用注解:
此處的實作類在bean容器中的id為 testServiceImpl@DubboService(interfaceClass = TestService.class, interfaceName = "testServiceImplProvider", version = "${dubbo.provider.version}") public class TestServiceImpl implements TestService { ... }
- 在consumer項目中引用provider的服務:
@DubboReference(version = "${dubbo.provider.version}") private com.baoyong.base.service.TestService testService;
- 可配置不同version的provider,然後修改consumer調用provider的version即可切換不同版本調用。