Spring Boot----SpringBoot整合 Dubbo 和 Zookeeper

下載安裝Zookeeper

linux

　　使用docker部署

windows:參考（https://blog.csdn.net/ring300/article/details/80446918），下載的zookeeper目錄中需要包含lib（內置jar包，否則需要自己導入）

　　1、將conf目錄下的zoo_sample.cfg文件，復制粘貼一份，重命名為zoo.cfg

　　2、創建data目錄和log目錄

　　3、修改zoo.cfg 文件中的

dataDir=D:\Zookeeper\data
datalogDir=D:\Zookeeper\log

　　4、啟動 雙擊 zkServer.cmd

對zoo.cfg文件配置說明

　　tickTime：這個時間是作為 Zookeeper 服務器之間或客戶端與服務器之間維持心跳的時間間隔，也就是每個 tickTime 時間就會發送一個心跳。

　　initLimit：這個配置項是用來配置 Zookeeper 接受客戶端（這里所說的客戶端不是用戶連接 Zookeeper 服務器的客戶端，而是 Zookeeper 服務器集群中連接到 Leader 的 Follower 服務器）初始化連接

時最長能忍受多少個心跳時間間隔數。當已經超過 10 個心跳的時間（也就是 tickTime）長度后 Zookeeper 服務器還沒有收到客戶端的返回信息，那么表明這個客戶端連接失敗。總的時間長度就是

10*2000=20 秒

　　syncLimit：這個配置項標識 Leader 與 Follower 之間發送消息，請求和應答時間長度，最長不能超過多少個 tickTime 的時間長度，總的時間長度就是 5*2000=10 秒

　　dataDir：顧名思義就是 Zookeeper 保存數據的目錄，默認情況下，Zookeeper 將寫數據的日志文件也保存在這個目錄里。

　　clientPort：這個端口就是客戶端連接 Zookeeper 服務器的端口，Zookeeper 會監聽這個端口，接受客戶端的訪問請求。

 

SpringBoot整合Dubbo（RPC）

整合dubbo添加依賴

方法文檔：https://github.com/apache/dubbo-spring-boot-project

1、provider 發布服務

1.1 在provider中的pom添加dubbo依賴和zookeeper相關依賴

        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
            <version>2.7.3</version>
        </dependency>

        <dependency>
            <groupId>org.apache.curator</groupId>
            <artifactId>curator-framework</artifactId>
            <version>4.2.0</version>
        </dependency>
        <dependency>
            <groupId>org.apache.curator</groupId>
            <artifactId>curator-recipes</artifactId>
            <version>4.2.0</version>
        </dependency>
        <dependency><!--zookeeper應該不需要在依賴了-->
            <groupId>org.apache.zookeeper</groupId>
            <artifactId>zookeeper</artifactId>
            <version>3.5.5</version>
            <exclusions>
                <exclusion>
                    <groupId>org.slf4j</groupId>
                    <artifactId>slf4j-log4j12</artifactId>
                </exclusion>
                <exclusion>
                    <groupId>log4j</groupId>
                    <artifactId>log4j</artifactId>
                </exclusion>
            </exclusions>
        </dependency>

1.2 application.properties

#當前服務的名字可以任意
dubbo.application.name=provider
#zookeeper的默認端口2181
dubbo.registry.address=zookeeper://localhost:2181
#將service包下的服務發布出去
dubbo.scan.base-packages=com.zy.provider.service

1.3 Service（非常重要，需要有一份一樣的service接口到consumer中，全限定類型(包名和類名都要一樣)）

package com.zy.provider.service;

public interface TestService {
    public String test();
}

1.4 serviceimpl

@Component
@Service  //注解到實現類上【org.apache.dubbo.config.annotation.Service;】
public class TestServiceImpl implements TestService {  //必須有一個接口
    @Override
    public String test() {
        return "ok";
    }
}

1.5 啟動：表示注冊成功(否則，測試consumer的時候會報錯)

 

2、consumer 引用服務

2.1 引入依賴

        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
            <version>2.7.3</version>
        </dependency>
        <dependency>
            <groupId>org.apache.curator</groupId>
            <artifactId>curator-framework</artifactId>
            <version>4.2.0</version>
        </dependency>
        <dependency>
            <groupId>org.apache.curator</groupId>
            <artifactId>curator-recipes</artifactId>
            <version>4.2.0</version>
        </dependency>
        <!--排除zookeeper內部的日志jia包,防止和自生項目引入日志jar包產生沖突--><!--zookeeper應該是不需要在依賴了-->
        <dependency>
            <groupId>org.apache.zookeeper</groupId>
            <artifactId>zookeeper</artifactId>
            <version>3.5.5</version>
            <exclusions>
                <exclusion>
                    <groupId>org.slf4j</groupId>
                    <artifactId>slf4j-log4j12</artifactId>
                </exclusion>
                <exclusion>
                    <groupId>log4j</groupId>
                    <artifactId>log4j</artifactId>
                </exclusion>
            </exclusions>
        </dependency>

2.2 application.properties

dubbo.application.name=consumer
dubbo.registry.address=zookeeper://192.168.1.101:2181
server.port=8082

2.3 創建service接口（這個service和provider中的 service需要一樣，全限定類名一樣(包名+接口名字)）

package com.zy.provider.service;  //注意包名

public interface TestService {
    public String test();
}

2.4 創建自己項目中的service

package com.zy.consumer.service;
import com.zy.provider.service.TestService;
import org.apache.dubbo.config.annotation.Reference;
import org.springframework.stereotype.Service;

@Service
public class ConsumerService {
    @Reference //注意包是dubbo下的org.apache.dubbo.config.annotation.Reference;
    TestService testService;

    public void test(){
        System.out.println(testService.test());
    }
}

2.5 測試，控制台打印ok

@RunWith(SpringRunner.class)
@SpringBootTest
public class ConsumerApplicationTests {
    @Autowired
    private ConsumerService consumerService;
    @Test
    public void contextLoads() {
        consumerService.test();
    }
}

　　

2.6 補充目錄結構