摘要：文件引入相關依賴需要引入接口的相關依賴包。服務提供者，包含真正的服務實現代碼服務提供者啟動類編寫注意不要忘記加上注解開啟的自動配置。

搭建一個SpringBoot+Dubbo+zookeeper的demo

完整代碼見：github.com/Caizhenhao/…

搭建 zookeeper 之前要確保當前的服務器已經有 JDK 環境。

我使用的是阿里云服務器

注意：如果你也使用的是云服務器必須配置一個安全組，開放你的zookeeper端口。

自行去網上下載zookeeper的安裝包后在服務器上解壓

tar -zxvf zookeeper-3.4.11.tar.gz

解壓完畢之后修改一下解壓之后所得的文件夾名

mv zookeeper-3.4.11 zookeeper

刪除 zookeeper 安裝包

rm -rf zookeeper-3.4.11.tar.gz

mkdir data

進入 data 文件夾 然后執行pwd命令，復制所得的當前目錄位置

cp zoo_sample.cfg zoo.cfg

使用 vim zoo.cfg 命令修改配置文件

修改配置文件中的 dataDir 屬性:

dataDir=/usr/local/zookeeper/data

進入 /zookeeper/bin 目錄然后執行下面的命令啟動zookeeper

./zkServer.sh start

查看當前 zookeeper 狀態

./zkServer.sh status

或者運行 netstat -lntup 命令查看網絡狀態,可以看到 zookeeper 的端口號 2181 已經被占用

到這里zookeeper的環境就搭建完成了，開始搭建項目

項目我這里采用maven搭建，使用springboot+dubbo+zookeeper

項目分成三個模塊

三個模塊的功能：

dubbo-api 服務提供者的接口

dubbo-provider 服務提供者

dubbo-consumer 服務消費者

關鍵依賴

<dependency>
    <groupId>com.alibaba.spring.bootgroupId>
    <artifactId>dubbo-spring-boot-starterartifactId>
    <version>2.0.0version>
dependency>

抽象服務提供者的接口供服務消費者調用

package com.czh.provider.dubboprovider.serviceImpl.service;

public interface HelloService {
    String sayHello(String name);
}

主要分為下面幾步：

創建 springboot 項目;

加入接口的相關依賴 jar 包；

在 application.properties 配置文件中配置 dubbo 相關信息；

實現接口類;

服務提供者啟動類編寫

項目結構：

創建一個 SpringBoot 項目，注意勾選上 web 模塊。

需要引入接口的相關依賴 jar 包。注意將本項目和 dubbo-api 項目的 dependency 依賴的 groupId 和 artifactId 改成自己的。

    
        com.czh.api
        dubbo-api
        0.0.1-SNAPSHOT
    

配置很簡單，這主要得益于 dubbo 的@EnableDubbo注解。詳情可以參考dubbo官方說明dubbo.apache.org/zh-cn/blog/…

# 配置端口
spring.application.name = dubbo-provider
server.port = 9090

#指定當前服務/應用的名字（同樣的服務名字相同，不要和別的服務同名）
dubbo.application.name = dubbo-provider

demo.service.version = 1.0.0

dubbo.protocol.name = dubbo
dubbo.protocol.port = 20880

#指定注冊中心的位置
dubbo.registry.address = zookeeper://ip:2181

#統一設置服務提供方的規則
dubbo.provider.timeout = 1000

注意： @Service 注解使用的時 Dubbo 提供的而不是 Spring 提供的。

服務提供者，包含真正的服務實現代碼

package com.czh.provider.dubboprovider.serviceImpl;

import com.alibaba.dubbo.config.annotation.Service;
import com.czh.provider.dubboprovider.serviceImpl.service.HelloService;

@Service(version = "${demo.service.version}")
public class HelloServiceImpl implements HelloService {

    @Override
    public String sayHello(String name) {
        return "Hello " + name + ",This is springboot-dubbo test";
    }
}

注意：不要忘記加上 @EnableDubbo 注解開啟Dubbo 的自動配置。

package com.czh.provider;

import com.alibaba.dubbo.config.spring.context.annotation.EnableDubbo;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
@EnableDubbo
public class DubboProviderApplication {

    public static void main(String[] args) {
        SpringApplication.run(DubboProviderApplication.class, args);
    }

}

5. dubbo-consumer

主要分為下面幾步：

創建 springboot 項目;

加入接口的相關依賴 jar 包；

在 application.properties 配置文件中配置 dubbo 相關信息；

服務消費者調用接口編寫

服務消費者啟動類編寫

項目結構：

前兩步與之前的服務提供者一樣，這里我直接從第三步開始說起

與服務提供者基本一致

spring.application.name = dubbo-consumer
server.port = 9091

#指定當前服務/應用的名字（同樣的服務名字相同，不要和別的服務同名）
dubbo.application.name = dubbo-consumer

demo.service.version = 1.0.0

dubbo.protocol.name = dubbo
dubbo.protocol.port = 20880

#指定注冊中心的位置
dubbo.registry.address = zookeeper://ip:2181

#統一設置服務提供方的規則
dubbo.consumer.timeout = 5000

package com.czh.consumer.controller;

import com.alibaba.dubbo.config.annotation.Reference;
import com.czh.api.service.HelloService;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class HelloConsumerController {
    @Reference(version = "${demo.service.version}")
    private HelloService helloService;

    @RequestMapping("/sayHello/{name}")
    public String sayHello(@PathVariable("name") String name) {
        return helloService.sayHello(name);
    }

}

package com.czh.consumer;

import com.alibaba.dubbo.config.spring.context.annotation.EnableDubbo;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
@EnableDubbo
public class DubboConsumerApplication {

    public static void main(String[] args) {
        SpringApplication.run(DubboConsumerApplication.class, args);
    }

}

可以看到消費者調用服務提供者正常

查看zookeeper下發現有我們注冊的服務節點

使用springboot+dubbo+zookeeper進行搭建 dubbo 的項目應該說是比較簡單的，官方也有集成Springboot的依賴，這里就不多說了，實踐出真知~

完整代碼見：github.com/Caizhenhao/…