SpringCloud(一) - Dubbo + Zookeeper

Dubbo 和Zookeeper 不是SpringCloud的東西，放在這里只是為了方便復習；

1、下載安裝Zookeeper和Dubbo

1.1 下載安裝教程

下載安裝教程 windows環境下安裝zookeeper教程詳解（單機版）

1.2 啟動頁面

1.2.1 zkServer.xmd zookeeper 服務端

1.2.2 zkCli.cmd zookeeper 客戶端

1.3.3 運行 double-admin

java-jar dubbo-admin-0.0.1-SNAPSHOT.jar

訪問localhost:7001

2、SpringBoot 集成 dubbo + zookeeper

2.1 模塊專案建立

2.1.1 主專案

2.1.1.1 pom.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>1.5.9.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>
    <groupId>com.kgc.sbt</groupId>
    <artifactId>springboot-10-dubbo-96</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>springboot-10-dubbo-96</name>
    <!-- 主專案打包方式，pom方式 -->
    <packaging>pom</packaging>
    <description>Demo project for Spring Boot</description>

    <properties>
        <java.version>1.8</java.version>
        <!-- 版本統一管理 -->
        <dubbo.version>0.1.0</dubbo.version>
        <zkclient.version>0.10</zkclient.version>
    </properties>

    <!-- 父專案中的 dependencyManagement 中定義的只是依賴的宣告，并不實作引入，因此子專案需要顯式的宣告需要用的依賴 -->
    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>com.kgc.sbt</groupId>
                <artifactId>contactmall96-common</artifactId>
                <version>0.0.1-SNAPSHOT</version>
            </dependency>

            <dependency>
                <groupId>com.alibaba.boot</groupId>
                <artifactId>dubbo-spring-boot-starter</artifactId>
                <version>${dubbo.version}</version>
            </dependency>

            <dependency>
                <groupId>com.101tec</groupId>
                <artifactId>zkclient</artifactId>
                <version>${zkclient.version}</version>
            </dependency>
        </dependencies>
    </dependencyManagement>

	<!-- 模塊管理  -->
    <modules>
        <module>contactmall96-common</module>
        <module>contactmall96-server</module>
        <module>contactmall96-web</module>
    </modules>
    
    <!-- 不需要 build -->

</project>

2.1.2 公共模塊 common模塊

2.1.2.1 pom.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>com.kgc.sbt</groupId>
        <artifactId>springboot-10-dubbo-96</artifactId>
        <version>0.0.1-SNAPSHOT</version>
        <relativePath>../pom.xml </relativePath>
    </parent>
    <groupId>com.kgc.sbt</groupId>
    <artifactId>contactmall96-common</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>contactmall96-common</name>
    <!-- 普通jar包，不是可執行jar,用于提供公共jar,給其他模塊提供依賴 -->
    <packaging>jar</packaging>
    <description>Demo project for Spring Boot</description>
    <properties>
        <java.version>1.8</java.version>
    </properties>
    <dependencies>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
        </dependency>
    </dependencies>

    <!-- 不需要 build -->
    
</project>

2.1.2.2 公共Api介面

// 聯系人 公共介面(基于dubbo的rpc遠程介面服務呼叫)，
// 此介面是提供給消費端web呼叫獲取資料
// 服務端server實作此介面，提供資料
public interface ContactApi {

    //根據聯系人編號，查詢聯系人詳情公共方法
    ContactVO queryContactById(Integer id);

}

2.1.2.3 其他公共資源

注意：視圖層的物體一定要進行序列化，因為在網路上傳輸的物件需要序列化；(ContactVO implements Serializable)

2.1.3 服務提供者 server模塊

2.1.3.1 pom.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>com.kgc.sbt</groupId>
        <artifactId>springboot-10-dubbo-96</artifactId>
        <version>0.0.1-SNAPSHOT</version>
        <relativePath>../pom.xml </relativePath>
    </parent>
    <groupId>com.kgc.sbt</groupId>
    <artifactId>contactmall96-server</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <description>Demo project for Spring Boot</description>
    <properties>
        <java.version>1.8</java.version>
    </properties>
    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

        <!--   依賴了common 模塊，跨域直接使用模塊中的依賴和類     -->
        <dependency>
            <groupId>com.kgc.sbt</groupId>
            <artifactId>contactmall96-common</artifactId>
            <version>0.0.1-SNAPSHOT</version>
        </dependency>

        <!-- fastjson -->
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>fastjson</artifactId>
            <version>1.2.62</version>
        </dependency>

        <!-- mysql-connector-java -->
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <version>8.0.30</version>
        </dependency>

        <!-- commons-lang -->
        <dependency>
            <groupId>commons-lang</groupId>
            <artifactId>commons-lang</artifactId>
            <version>2.6</version>
        </dependency>

        <!-- mybatis-plus-boot-starter -->
        <dependency>
            <groupId>com.baomidou</groupId>
            <artifactId>mybatis-plus-boot-starter</artifactId>
            <version>3.4.3.4</version>
        </dependency>

        <!-- 父專案中管理了版本的不需要指定版本 -->
        <dependency>
            <groupId>com.alibaba.boot</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
        </dependency>
        <dependency>
            <groupId>com.101tec</groupId>
            <artifactId>zkclient</artifactId>
        </dependency>

    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>

</project>

2.1.3.2 dubbo配置

# 埠
server.port=8096

#資料源
spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
spring.datasource.url=jdbc:mysql://localhost:3306/kh96_springboot_contactdb?useUnicode=true&characterEncoding=utf-8&useSSL=false&serverTimezone=GMT
spring.datasource.username=root
spring.datasource.password=root

#mybatis-plus 配置
mybatis-plus.configuration.map-underscore-to-camel-case=true

# dubbo配置
dubbo.application.name=contact-provider
dubbo.registry.address=127.0.0.1:2181
dubbo.registry.protocol=zookeeper
#埠號-1，會自動從20880開始遞增，也可以指定（必須確保不沖突，一般不建議）(不要寫成 dubbo.registry.port=-1)注冊埠
#協議埠
dubbo.protocol.port=-1  
#掃描指定包下的服務
dubbo.scan.base-packages=com.kgc.sbt.provider

2.1.3.3 代碼分布情況

注意：主啟動類掃描包，@MapperScan("com.kgc.sbt.mapper")

2.1.3.4 公共Api介面的實作類(注冊服務)

package com.kgc.sbt.provider;

import com.alibaba.dubbo.config.annotation.Service;  //@Service作用：將當前服務注冊為服務提供者
import com.kgc.sbt.api.ContactApi;
import com.kgc.sbt.service.ContactService;
import com.kgc.sbt.vo.ContactVO;
import org.springframework.beans.factory.annotation.Autowired;

//聯系人功能 的提供者
@Service  //是alibaba包下的，不是spring的業務組件注解，作用：將當前服務注冊為服務提供者
public class ContactProvider implements ContactApi {

    @Autowired
    private ContactService contactService;

    @Override
    public ContactVO queryContactById(Integer id) {
        //呼叫業務介面，查詢聯系人的詳情
        return contactService.getContactById(id);
    }


}

2.1.4 消費模塊 web模塊

2.1.4.1 pom.xml

跟服務提供者差不多，這里列出所有pom主要是因為第一次這樣構建模塊專案，所以記錄一下細節，

<?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>com.kgc.sbt</groupId>
        <artifactId>springboot-10-dubbo-96</artifactId>
        <version>0.0.1-SNAPSHOT</version>
        <relativePath>../pom.xml </relativePath>
    </parent>
    <groupId>com.kgc.sbt</groupId>
    <artifactId>contactmall96-web</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>contactmall96-web</name>
    <description>Demo project for Spring Boot</description>
    <properties>
        <java.version>1.8</java.version>
    </properties>
    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

        <dependency>
            <groupId>com.kgc.sbt</groupId>
            <artifactId>contactmall96-common</artifactId>
            <version>0.0.1-SNAPSHOT</version>
        </dependency>

        <dependency>
            <groupId>com.alibaba.boot</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
        </dependency>
        <dependency>
            <groupId>com.101tec</groupId>
            <artifactId>zkclient</artifactId>
        </dependency>

    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>

</project>

2.1.4.2 dubbo配置

# 埠
server.port=8098

# dubbo 配置
dubbo.application.name=contact-consumer
dubbo.registry.address=127.0.0.1:2181
dubbo.registry.protocol=zookeeper

2.1.4.3 代碼分布情況

2.1.4.4 獲取公共Api的實作類(訂閱服務)

import com.alibaba.dubbo.config.annotation.Reference; //作用，到注冊中心訂閱當前介面物件提供的服務，成為該介面的消費者
import com.kgc.sbt.api.ContactApi;
import com.kgc.sbt.vo.ContactVO;
import org.springframework.stereotype.Service;

@Service  //spring容器的業務注解
public class ContactServiceImpl implements com.kgc.sbt.service.ContactService {

    @Reference //alibaba下的，作用，到注冊中心訂閱當前介面物件提供的服務，成為該介面的消費者
    private ContactApi contactApi;

    @Override
    public ContactVO getContactById(Integer contactId) {
        //基于RPC遠程介面呼叫，呼叫服務提供者提供的服務，就等價于呼叫此既可，只不過是遠程
        return contactApi.queryContactById(contactId);
    }
}

2.2 測驗

先啟動zookeeper和dubbo-admin;

在啟動服務提供模塊和服務消費模塊；

2.2.1 請求測驗

2.2.1.1 dubbo-admin頁面查看 提供者和消費者

提供者：

消費者：

2.2.1.2 請求測驗

2.2.2 多提供者，多消費者測驗

2.2.2.1 復制服務

2.2.2.2 dubbo 查看 提供者和消費者

提供者：

消費者：

2.2.2.3 兩個消費者請求測驗

2.2.3 一些重要的點

2.2.3.1提供者的 權重

2.2.3.2 消費者的禁止

2.2.3.2.1 設定 消費者禁止：

被禁止的客戶端將收到訪問禁止例外

2.2.3.2.1 測驗訪問：

2.2.3.3 消費者的屏蔽

2.2.3.3.1 設定 消費者屏蔽：

屏蔽后，將不發起遠程呼叫，直接在客戶端回傳空物件，

2.2.3.3.2 測驗訪問：

2.2.3.4 負載均衡

負載均衡有：隨機(默認)，輪詢，最少并發，

標籤：其他

上一篇：Java 8 函式式介面和Lambda運算式

下一篇：JUC中的AQS底層詳細超詳解