QUESTIONl:SpringBoot整合Dubbo+Zookeeper進行分布式搭建系統？

?

ANSWER：

一：創建項目模塊

?

1.1.創建一個Empty Project

?

名稱:Dubbo

1.2.創建一個Provider模塊

這里采用SpringBoot快速搭建。

?

1.3.創建Consumer模塊

創建完成后代碼架構:

二：provider代碼部分

2.1導入provider.xml依賴

?

<?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>2.2.1.RELEASE</version><relativePath/> <!-- lookup parent from repository --></parent><groupId>com.xy</groupId><artifactId>provider</artifactId><version>0.0.1-SNAPSHOT</version><name>provider</name><description>Demo project for Spring Boot</description><properties><java.version>1.8</java.version></properties><dependencies><!-- https://mvnrepository.com/artifact/org.apache.dubbo/dubbo-spring-boot-starter --><dependency><groupId>org.apache.dubbo</groupId><artifactId>dubbo-spring-boot-starter</artifactId><version>2.7.3</version></dependency><!-- https://mvnrepository.com/artifact/com.github.sgroschupf/zkclient --><dependency><groupId>com.github.sgroschupf</groupId><artifactId>zkclient</artifactId><version>0.1</version><exclusions><exclusion><artifactId>slf4j-log4j12</artifactId><groupId>org.slf4j</groupId></exclusion></exclusions></dependency><!-- https://mvnrepository.com/artifact/org.apache.curator/curator-framework --><dependency><groupId>org.apache.curator</groupId><artifactId>curator-framework</artifactId><version>2.13.0</version></dependency><dependency><groupId>org.apache.curator</groupId><artifactId>curator-recipes</artifactId><version>2.13.0</version></dependency><!-- https://mvnrepository.com/artifact/org.apache.zookeeper/zookeeper --><dependency><groupId>org.apache.zookeeper</groupId><artifactId>zookeeper</artifactId><version>3.4.13</version><exclusions><exclusion><artifactId>slf4j-log4j12</artifactId><groupId>org.slf4j</groupId></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><exclusions><exclusion><groupId>org.junit.vintage</groupId><artifactId>junit-vintage-engine</artifactId></exclusion></exclusions></dependency></dependencies><build><plugins><plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId></plugin></plugins></build></project>

?

2.2創建POJO類

創建一個User實體類，只做簡單的測試:

package com.xy.provider.pojo;import java.io.Serializable;public class User implements Serializable {private static final long serialVersionUID = -7341603933521593227L;private Long id;private String username;private String password;private Integer age;public static long getSerialVersionUID() {return serialVersionUID;}public Long getId() {return id;}public void setId(Long id) {this.id = id;}public String getUsername() {return username;}public void setUsername(String username) {this.username = username;}public String getPassword() {return password;}public void setPassword(String password) {this.password = password;}public Integer getAge() {return age;}public void setAge(Integer age) {this.age = age;}@Overridepublic String toString() {return "User{" +"id=" + id +", username='" + username + '\'' +", password='" + password + '\'' +", age=" + age +'}';} }

?

2.3創建接口及實現類

創建userService接口:

package com.xy.provider.service;import com.xy.provider.pojo.User;import java.util.List;public interface UserService {public List<User> findAll();public void test(); }

UserServiceImpl實現類:

package com.xy.provider.service.impl;import com.xy.provider.pojo.User; import com.xy.provider.service.UserService; import org.apache.dubbo.config.annotation.Service; import org.springframework.stereotype.Component;import java.util.ArrayList; import java.util.List;@Service //這里要用dubbo的service，在項目一啟動就注冊到注冊中心 @Component //使用了Dubbo盡量不要用@Service public class UserServiceImpl implements UserService {@Overridepublic List<User> findAll() {System.out.println("查詢所有");List<User> list = new ArrayList<User>();for (int i = 0; i < 10; i++) {User user = new User();user.setAge(10 + i);user.setId(Long.valueOf(i + 1));user.setPassword("123456");user.setUsername("username_" + i);list.add(user);}return list;}@Overridepublic void test() {System.out.println("dubbo");} }

?

2.4構造application.properties

#提供者名稱 dubbo.application.name=provider #注冊中心地址 dubbo.registry.address=zookeeper://www.youngxy.top:2181 #哪些服務要注冊 dubbo.scan.base-packages=com.xy.provider.service

?

三：consumer代碼部分

3.1導入consumer.xml依賴

<?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>2.2.4.RELEASE</version><relativePath/> <!-- lookup parent from repository --></parent><groupId>com.xy</groupId><artifactId>consumer</artifactId><version>0.0.1-SNAPSHOT</version><name>consumer</name><description>Demo project for Spring Boot</description><properties><java.version>1.8</java.version></properties><dependencies><!-- https://mvnrepository.com/artifact/org.apache.dubbo/dubbo-spring-boot-starter --><dependency><groupId>org.apache.dubbo</groupId><artifactId>dubbo-spring-boot-starter</artifactId><version>2.7.3</version></dependency><!-- https://mvnrepository.com/artifact/com.github.sgroschupf/zkclient --><dependency><groupId>com.github.sgroschupf</groupId><artifactId>zkclient</artifactId><version>0.1</version><exclusions><exclusion><artifactId>slf4j-log4j12</artifactId><groupId>org.slf4j</groupId></exclusion></exclusions></dependency><!-- https://mvnrepository.com/artifact/org.apache.curator/curator-framework --><dependency><groupId>org.apache.curator</groupId><artifactId>curator-framework</artifactId><version>2.13.0</version></dependency><dependency><groupId>org.apache.curator</groupId><artifactId>curator-recipes</artifactId><version>2.13.0</version></dependency><!-- https://mvnrepository.com/artifact/org.apache.zookeeper/zookeeper --><dependency><groupId>org.apache.zookeeper</groupId><artifactId>zookeeper</artifactId><version>3.4.13</version><exclusions><exclusion><artifactId>slf4j-log4j12</artifactId><groupId>org.slf4j</groupId></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><exclusions><exclusion><groupId>org.junit.vintage</groupId><artifactId>junit-vintage-engine</artifactId></exclusion></exclusions></dependency><dependency><groupId>com.xy</groupId><artifactId>provider</artifactId><version>0.0.1-SNAPSHOT</version></dependency></dependencies><build><plugins><plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId></plugin></plugins></build></project>

?

3.2創建實現類

消費者要獲取提供者的服務，定義消費者實現類:

package com.xy.consumer.service;import com.xy.provider.pojo.User; import com.xy.provider.service.UserService; import com.xy.provider.service.impl.UserServiceImpl; import org.apache.dubbo.config.annotation.Reference; import org.springframework.stereotype.Service;import java.util.List;@Service //這里是Spring的服務，表示放到容器中 public class ConsumerService {/** 想要拿到UserService，要到注冊中心去拿* */@Referenceprivate UserService userService; //引用，pom導入相關依賴public void consume(){System.out.println("test");List<User> users = userService.findAll();for (User user:users) {System.out.println(user);}userService.test();} }

?

3.3構造application.properties

#SpringBoot端口 server.port=8081 #消費者去注冊中心獲取服務需要暴露自己的名稱 dubbo.application.name=consumer #注冊中心的地址 dubbo.registry.address=zookeeper://www.youngxy.top:2181

3.4創建測試類

package com.xy.consumer;import com.xy.consumer.service.ConsumerService; import com.xy.provider.pojo.User; import com.xy.provider.service.UserService; import org.apache.dubbo.config.annotation.Reference; import org.junit.jupiter.api.Test; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.boot.test.context.SpringBootTest;import java.util.List;@SpringBootTest class ConsumerApplicationTests {@Autowiredprivate ConsumerService consumerService;@Testpublic void testConsume(){consumerService.consume();System.out.println("成功");}}

?

四：打開dubbo-admin平臺

首先在本地或者云服務器上面安裝好dubbo軟件，詳情請參照:搭建分布式環境:Dubbo+Zookeeper

在瀏覽器輸入:ip:8080/dubbo-admin-2.5.4-SNAPSHOT輸入密碼進入。

?

五：SpringBoot和Dubbo、Zookeeper版本不兼容問題的解決

5.1官方匹配的版本

請參考：SrpingBoot整合Zookeeper和Dubbo的版本匹配問題

?

5.2依賴沖突

請參考：依賴包沖突

?

?

總結

以上是生活随笔為你收集整理的SpringBoot整合Dubbo+Zookeeper进行分布式搭建系统的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。