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

搭建一個SpringBoot+Dubbo+zookeeper的demo

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

搭建 zookeeper 之前要確保當(dāng)前的服務(wù)器已經(jīng)有 JDK 環(huán)境。

我使用的是阿里云服務(wù)器

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

自行去網(wǎng)上下載zookeeper的安裝包后在服務(wù)器上解壓

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

進(jìn)入 data 文件夾 然后執(zhí)行pwd命令，復(fù)制所得的當(dāng)前目錄位置

cp zoo_sample.cfg zoo.cfg

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

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

dataDir=/usr/local/zookeeper/data

進(jìn)入 /zookeeper/bin 目錄然后執(zhí)行下面的命令啟動zookeeper

./zkServer.sh start

查看當(dāng)前 zookeeper 狀態(tài)

./zkServer.sh status

或者運(yùn)行 netstat -lntup 命令查看網(wǎng)絡(luò)狀態(tài),可以看到 zookeeper 的端口號 2181 已經(jīng)被占用

到這里zookeeper的環(huán)境就搭建完成了，開始搭建項(xiàng)目

項(xiàng)目我這里采用maven搭建，使用springboot+dubbo+zookeeper

項(xiàng)目分成三個模塊

三個模塊的功能：

dubbo-api 服務(wù)提供者的接口

dubbo-provider 服務(wù)提供者

dubbo-consumer 服務(wù)消費(fèi)者

關(guān)鍵依賴

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

抽象服務(wù)提供者的接口供服務(wù)消費(fèi)者調(diào)用

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

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

主要分為下面幾步：

創(chuàng)建 springboot 項(xiàng)目;

加入接口的相關(guān)依賴 jar 包；

在 application.properties 配置文件中配置 dubbo 相關(guān)信息；

實(shí)現(xiàn)接口類;

服務(wù)提供者啟動類編寫

項(xiàng)目結(jié)構(gòu)：

創(chuàng)建一個 SpringBoot 項(xiàng)目，注意勾選上 web 模塊。

需要引入接口的相關(guān)依賴 jar 包。注意將本項(xiàng)目和 dubbo-api 項(xiàng)目的 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

#指定當(dāng)前服務(wù)/應(yīng)用的名字（同樣的服務(wù)名字相同，不要和別的服務(wù)同名）
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

#統(tǒng)一設(shè)置服務(wù)提供方的規(guī)則
dubbo.provider.timeout = 1000

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

服務(wù)提供者，包含真正的服務(wù)實(shí)現(xiàn)代碼

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

主要分為下面幾步：

創(chuàng)建 springboot 項(xiàng)目;

加入接口的相關(guān)依賴 jar 包；

在 application.properties 配置文件中配置 dubbo 相關(guān)信息；

服務(wù)消費(fèi)者調(diào)用接口編寫

服務(wù)消費(fèi)者啟動類編寫

項(xiàng)目結(jié)構(gòu)：

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

與服務(wù)提供者基本一致

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

#指定當(dāng)前服務(wù)/應(yīng)用的名字（同樣的服務(wù)名字相同，不要和別的服務(wù)同名）
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

#統(tǒng)一設(shè)置服務(wù)提供方的規(guī)則
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);
    }

}

可以看到消費(fèi)者調(diào)用服務(wù)提供者正常

查看zookeeper下發(fā)現(xiàn)有我們注冊的服務(wù)節(jié)點(diǎn)

使用springboot+dubbo+zookeeper進(jìn)行搭建 dubbo 的項(xiàng)目應(yīng)該說是比較簡單的，官方也有集成Springboot的依賴，這里就不多說了，實(shí)踐出真知~

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