超详细，新手都能看懂 ！使用SpringBoot+Dubbo 搭建一个简单的分布式服务

Github 地址：https://github.com/Snailclimb/springboot-integration-examples ，欢迎各位 Star。

目录：

使用 SpringBoot+Dubbo 搭建一个简单分布式服务

实战之前，先来看几个重要的概念

什么是分布式?

什么是 Duboo？

Dubbo 架构

什么是 RPC？

为什么要用 Dubbo？

开始实战 1 ：zookeeper 环境安装搭建

1. 下载

2. 解压

3. 进入zookeeper目录，创建data文件夹。

4. 进入/zookeeper/conf目录下，复制zoo_sample.cfg，命名为zoo.cfg

5. 修改配置文件

6. 启动测试

开始实战 2 ：实现服务接口 dubbo-interface

1. dubbo-interface 项目创建

2. 创建接口类

3. 将项目打成 jar 包供其他项目使用

开始实战 3 ：实现服务提供者 dubbo-provider

1. dubbo-provider 项目创建

2. pom 文件引入相关依赖

3. 在 application.properties 配置文件中配置 dubbo 相关信息

4. 实现接口

5. 服务提供者启动类编写

开始实战 4 ：实现服务消费者 dubbo-consumer

4. 编写一个简单 Controller 调用远程服务

5. 服务消费者启动类编写

6. 测试效果

开始实战之前，我们先来简单的了解一下这样几个概念：Dubbo、RPC、分布式、由于本文的目的是带大家使用SpringBoot+Dubbo 搭建一个简单的分布式服务，所以这些概念我只会简单给大家普及一下，不会做深入探究。

分布式或者说 SOA 分布式重要的就是面向服务，说简单的分布式就是我们把整个系统拆分成不同的服务然后将这些服务放在不同的服务器上减轻单体服务的压力提高并发量和性能。比如电商系统可以简单地拆分成订单系统、商品系统、登录系统等等。

我们可以使用 Dubbo作为分布式系统的桥梁，那么什么是 Dubbo 呢？

Apache Dubbo (incubating) |ˈdʌbəʊ| 是一款高性能、轻量级的开源Java RPC 框架，它提供了三大核心能力：面向接口的远程方法调用，智能容错和负载均衡，以及服务自动注册和发现。简单来说 Dubbo 是一个分布式服务框架，致力于提供高性能和透明化的RPC远程服务调用方案，以及SOA服务治理方案。

Dubbo 目前已经有接近 23k 的 Star ，Dubbo的Github 地址：https://github.com/apache/inc...。另外，在开源中国举行的2018年度最受欢迎中国开源软件这个活动的评选中，Dubbo 更是凭借其超高人气仅次于 vue.js 和 ECharts 获得第三名的好成绩。

Dubbo 是由阿里开源，后来加入了 Apache 。正式由于 Dubbo 的出现，才使得越来越多的公司开始使用以及接受分布式架构。

下面我们简单地来看一下 Dubbo 的架构，加深对 Dubbo 的理解。

下面我们再来看看 Dubbo 的架构，我们后面会使用 zookeeper 作为注册中心，这也是 Dubbo 官方推荐的一种方式。

上述节点简单说明：

Provider 暴露服务的服务提供方

Consumer 调用远程服务的服务消费方

Registry 服务注册与发现的注册中心

Monitor 统计服务的调用次数和调用时间的监控中心

Container 服务运行容器

调用关系说明：

服务容器负责启动，加载，运行服务提供者。

服务提供者在启动时，向注册中心注册自己提供的服务。

服务消费者在启动时，向注册中心订阅自己所需的服务。

注册中心返回服务提供者地址列表给消费者，如果有变更，注册中心将基于长连接推送变更数据给消费者。

服务消费者，从提供者地址列表中，基于软负载均衡算法，选一台提供者进行调用，如果调用失败，再选另一台调用。

服务消费者和提供者，在内存中累计调用次数和调用时间，定时每分钟发送一次统计数据到监控中心。

我们在讲 Dubbo 的时候提到了 Dubbo 实际上是一款 RPC 框架，那么RPC 究竟是什么呢？相信看了下面我对 RPC 的介绍你就明白了！

RPC（Remote Procedure Call）—远程过程调用，它是一种通过网络从远程计算机程序上请求服务，而不需要了解底层网络技术的协议。比如两个不同的服务A,B部署在两台不同的机器上，那么服务 A 如果想要调用服务 B 中的某个方法该怎么办呢？使用 HTTP请求 当然可以，但是可能会比较慢而且一些优化做的并不好。 RPC 的出现就是为了解决这个问题。

如果你要开发分布式程序，你也可以直接基于 HTTP 接口进行通信，但是为什么要用 Dubbo呢？

我觉得主要可以从 Dubbo 提供的下面四点特性来说为什么要用 Dubbo：

负载均衡——同一个服务部署在不同的机器时该调用那一台机器上的服务

服务调用链路生成——服务之间互相是如何调用的

服务访问压力以及时长统计——当前系统的压力主要在哪里，如何来扩容和优化

服务降级——某个服务挂掉之后调用备用服务

我使用的是 CentOS 7.4 阿里云服务器，注意：如果你也同样阿里云服务器必须配置一个安全组，不然你的应用程序会无法访问你的 zookeeper 服务器，这一点我在后面也提到了。

通过 http://mirror.bit.edu.cn/apache/zookeeper/ 这个链接下载，然后上传到Linux上。（可以说那个 Xhell 附带的文件传输功能）

或者直接在Linux中使用 wget https://archive.apache.org/dist/zookeeper/zookeeper-3.4.12/zookeeper-3.4.12.tar.gz 命令下载（版本号 3.4.12 是我写这篇文章的时候最新的稳定版本，各位可以根据实际情况修改）

tar -zxvf zookeeper-3.4.12-alpha.tar.gz

解压完毕之后修改一下解压之后所得的文件夹名

mv zookeeper-3.4.12 zookeeper

删除 zookeeper 安装包

rm -rf zookeeper-3.4.12.tar.gz

mkdir data

进入 data 文件夹 然后执行pwd命令，复制所得的当前目录位置(就是我用红色圈出来的文字)

cp zoo_sample.cfg zoo.cfg

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

vim 文件------>进入文件----->命令模式------>按i进入编辑模式----->编辑文件    ------->按Esc进入底行模式----->输入:wq/q! （输入wq代表写入内容并退出，即保存；输入q!代表强制退出不保存。）

修改配置文件中的 data 属性:

dataDir=/usr/local/zookeeper/data

进入 /zookeeper/bin 目录然后执行下面的命令

./zkServer.sh start

执行 ./zkServer.sh status 查看当前 zookeeper 状态。

或者运行 netstat -lntup 命令查看网络状态,可以看到 zookeeper 的端口号 2181 已经被占用

注意没有关闭防火墙可能出现的问题！！！

如果你使用的阿里云服务器注意配置相关安全组：

进入本实例安全组页面

选择配置规则

选择添加安全组规则，然后按照下图配置

在开始实战之前提个建议：尽量新建一个文件夹，然后后面将接口项目、服务提供者以及服务消费者都放在这个文件夹。

主要分为下面几步：

创建 Maven 项目;

创建接口类

将项目打成 jar 包供其他项目使用

项目结构：

dubbo-interface 后面被打成 jar 包，它的作用只是提供接口。

File->New->Module... ,然后选择 Maven类型的项目，其他的按照提示一步一步走就好。

package top.snailclimb.service;

public interface HelloService {

    public  String sayHello(String name);
}

点击右边的 Maven Projects 然后选择 install ，这样 jar 宝就打好了。

主要分为下面几步：

创建 springboot 项目;

加入 dubbo 、zookeeper以及接口的相关依赖 jar 包；

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

实现接口类;

服务提供者启动类编写

项目结构：

创建一个 SpringBoot 项目，注意勾选上 web 模块。不会创建的话，可以查看下面这篇文章：，可以说很详细了。

https://blog.csdn.net/qq_34337272/article/details/79563606

需要引入 dubbo 、zookeeper以及接口的相关依赖 jar 包。注意将本项目和 dubbo-interface 项目的 dependency 依赖的 groupId 和 artifactId 改成自己的。dubbo 整合spring boot 的 jar 包在这里找dubbo-spring-boot-starter。zookeeper 的 jar包在 Maven 仓库 搜索 zkclient 即可找到。

        
            top.snailclimb
            dubbo-interface
            1.0-SNAPSHOT
        
        
        
            com.alibaba.spring.boot
            dubbo-spring-boot-starter
            2.0.0
        
        
        
            com.101tec
            zkclient
            0.10
        

配置很简单，这主要得益于 springboot 整合 dubbo 专属的@EnableDubboConfiguration 注解提供的 Dubbo 自动配置。

# 配置端口
server.port=8333

spring.dubbo.application.name=dubbo-provider
spring.dubbo.application.registry=zookeeper://ip地址:2181

注意： @Service 注解使用的时 Dubbo 提供的而不是 Spring 提供的。另外，加了Dubbo 提供的 @Service 注解之后还需要加入

package top.snailclimb.service.impl;

import com.alibaba.dubbo.config.annotation.Service;
import org.springframework.stereotype.Component;
import top.snailclimb.service.HelloService;

@Component
@Service
public class HelloServiceImpl implements HelloService {
    @Override
    public String sayHello(String name) {
        return "Hello " + name;
    }
}

注意：不要忘记加上 @EnableDubboConfiguration 注解开启Dubbo 的自动配置。

package top.snailclimb;

import com.alibaba.dubbo.spring.boot.annotation.EnableDubboConfiguration;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
// 开启dubbo的自动配置
@EnableDubboConfiguration
public class DubboProviderApplication {
    public static void main(String[] args) {
        SpringApplication.run(DubboProviderApplication.class, args);
    }
}

主要分为下面几步：

创建 springboot 项目;

加入 dubbo 、zookeeper以及接口的相关依赖 jar 包；

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

编写测试类;

服务消费者启动类编写

测试效果

项目结构：

第1，2，3 步和服务提供者的一样，这里直接从第 4 步开始。

package top.snailclimb.dubboconsumer;

import com.alibaba.dubbo.config.annotation.Reference;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import top.snailclimb.service.HelloService;

@RestController
public class HelloController {
    @Reference
    private HelloService helloService;

    @RequestMapping("/hello")
    public String hello() {
        String hello = helloService.sayHello("world");
        System.out.println(helloService.sayHello("SnailClimb"));
        return hello;
    }
}

package top.snailclimb.dubboconsumer;

import com.alibaba.dubbo.spring.boot.annotation.EnableDubboConfiguration;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
@EnableDubboConfiguration
public class DubboConsumerApplication {

    public static void main(String[] args) {

        SpringApplication.run(DubboConsumerApplication.class, args);
    }
}

浏览器访问 http://localhost:8330/hello 页面返回 Hello world，控制台输出 Hello SnailClimb，和预期一直，使用SpringBoot+Dubbo 搭建第一个简单的分布式服务实验成功！

ThoughtWorks准入职Java工程师。专注Java知识分享！开源 Java 学习指南——JavaGuide（12k+ Star）的作者。公众号多篇文章被各大技术社区转载。公众号后台回复关键字“1”可以领取一份我精选的Java资源哦！