- [使用 SpringBoot+Dubbo 搭建一个简单分布式服务](#使用-springbootdubbo-搭建一个简单分布式服务) - [实战之前，先来看几个重要的概念](#实战之前先来看几个重要的概念) - [什么是分布式?](#什么是分布式) - [什么是 Duboo？](#什么是-duboo) - [Dubbo 架构](#dubbo-架构) - [什么是 RPC？](#什么是-rpc) - [为什么要用 Dubbo？](#为什么要用-dubbo) - [开始实战 1 ：zookeeper 环境安装搭建](#开始实战-1-zookeeper-环境安装搭建) - [1. 下载](#1-下载) - [2. 解压](#2-解压) - [3. 进入zookeeper目录，创建data文件夹。](#3-进入zookeeper目录创建data文件夹) - [4. 进入/zookeeper/conf目录下，复制zoo_sample.cfg，命名为zoo.cfg](#4-进入zookeeperconf目录下复制zoo_samplecfg命名为zoocfg) - [5. 修改配置文件](#5-修改配置文件) - [6. 启动测试](#6-启动测试) - [开始实战 2 ：实现服务接口 dubbo-interface](#开始实战-2-实现服务接口-dubbo-interface) - [1. dubbo-interface 项目创建](#1-dubbo-interface-项目创建) - [2. 创建接口类](#2-创建接口类) - [3. 将项目打成 jar 包供其他项目使用](#3-将项目打成-jar-包供其他项目使用) - [开始实战 3 ：实现服务提供者 dubbo-provider](#开始实战-3-实现服务提供者-dubbo-provider) - [1. dubbo-provider 项目创建](#1-dubbo-provider-项目创建) - [2. pom 文件引入相关依赖](#2-pom-文件引入相关依赖) - [3. 在 application.properties 配置文件中配置 dubbo 相关信息](#3-在-applicationproperties-配置文件中配置-dubbo-相关信息) - [4. 实现接口](#4-实现接口) - [5. 服务提供者启动类编写](#5-服务提供者启动类编写) - [开始实战 4 ：实现服务消费者 dubbo-consumer](#开始实战-4-实现服务消费者-dubbo-consumer) - [4. 编写一个简单 Controller 调用远程服务](#4-编写一个简单-controller-调用远程服务) - [5. 服务消费者启动类编写](#5-服务消费者启动类编写) - [6. 测试效果](#6-测试效果) # 使用 SpringBoot+Dubbo 搭建一个简单分布式服务 ## 实战之前，先来看几个重要的概念 开始实战之前，我们先来简单的了解一下这样几个概念：Dubbo、RPC、分布式、由于本文的目的是带大家使用SpringBoot+Dubbo 搭建一个简单的分布式服务，所以这些概念我只会简单给大家普及一下，不会做深入探究。 ### 什么是分布式? 分布式或者说 SOA 分布式重要的就是面向服务，说简单的分布式就是我们把整个系统拆分成不同的服务然后将这些服务放在不同的服务器上减轻单体服务的压力提高并发量和性能。比如电商系统可以简单地拆分成订单系统、商品系统、登录系统等等。 **我们可以使用 Dubbo作为分布式系统的桥梁，那么什么是 Dubbo 呢？** ### 什么是 Duboo？ Apache Dubbo (incubating) |ˈdʌbəʊ| 是一款高性能、轻量级的开源Java RPC 框架，它提供了三大核心能力：面向接口的远程方法调用，智能容错和负载均衡，以及服务自动注册和发现。简单来说 Dubbo 是一个分布式服务框架，致力于提供高性能和透明化的RPC远程服务调用方案，以及SOA服务治理方案。 Dubbo 目前已经有接近 23k 的 Star ，Dubbo的Github 地址：[https://github.com/apache/incubator-dubbo](https://github.com/apache/incubator-dubbo) 。 另外，在开源中国举行的2018年度最受欢迎中国开源软件这个活动的评选中，Dubbo 更是凭借其超高人气仅次于 vue.js 和 ECharts 获得第三名的好成绩。 Dubbo 是由阿里开源，后来加入了 Apache 。正是由于 Dubbo 的出现，才使得越来越多的公司开始使用以及接受分布式架构。 **下面我们简单地来看一下 Dubbo 的架构，加深对 Dubbo 的理解。** ### Dubbo 架构 下面我们再来看看 Dubbo 的架构，我们后面会使用 zookeeper 作为注册中心，这也是 Dubbo 官方推荐的一种方式。  **上述节点简单说明：** - **Provider** 暴露服务的服务提供方 - **Consumer** 调用远程服务的服务消费方 - **Registry** 服务注册与发现的注册中心 - **Monitor** 统计服务的调用次数和调用时间的监控中心 - **Container** 服务运行容器 **调用关系说明：** 1. 服务容器负责启动，加载，运行服务提供者。 2. 服务提供者在启动时，向注册中心注册自己提供的服务。 3. 服务消费者在启动时，向注册中心订阅自己所需的服务。 4. 注册中心返回服务提供者地址列表给消费者，如果有变更，注册中心将基于长连接推送变更数据给消费者。 5. 服务消费者，从提供者地址列表中，基于软负载均衡算法，选一台提供者进行调用，如果调用失败，再选另一台调用。 6. 服务消费者和提供者，在内存中累计调用次数和调用时间，定时每分钟发送一次统计数据到监控中心。 **我们在讲 Dubbo 的时候提到了 Dubbo 实际上是一款 RPC 框架，那么RPC 究竟是什么呢？相信看了下面我对 RPC 的介绍你就明白了！** ### 什么是 RPC？ RPC（Remote Procedure Call）—远程过程调用，它是一种通过网络从远程计算机程序上请求服务，而不需要了解底层网络技术的协议。比如两个不同的服务A,B部署在两台不同的机器上，那么服务 A 如果想要调用服务 B 中的某个方法该怎么办呢？使用 HTTP请求 当然可以，但是可能会比较慢而且一些优化做的并不好。 RPC 的出现就是为了解决这个问题。 ### 为什么要用 Dubbo？ 如果你要开发分布式程序，你也可以直接基于 HTTP 接口进行通信，但是为什么要用 Dubbo呢？ 我觉得主要可以从 Dubbo 提供的下面四点特性来说为什么要用 Dubbo： 1. **负载均衡**——同一个服务部署在不同的机器时该调用那一台机器上的服务 2. **服务调用链路生成**——服务之间互相是如何调用的 3. **服务访问压力以及时长统计**——当前系统的压力主要在哪里，如何来扩容和优化 4. **服务降级**——某个服务挂掉之后调用备用服务 ## 开始实战 1 ：zookeeper 环境安装搭建 搭建 zookeeper 之前要确保当前的机器已经有 JDK 环境。 我使用的是 CentOS 7.4 阿里云服务器，注意：如果你也同样阿里云服务器必须配置一个安全组，不然你的应用程序会无法访问你的 zookeeper 服务器，这一点我在后面也提到了。 ### 1. 下载 通过 [http://mirror.bit.edu.cn/apache/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 是我写这篇文章的时候最新的稳定版本，各位可以根据实际情况修改） ### 2. 解压 ```shell tar -zxvf zookeeper-3.4.12-alpha.tar.gz ```  解压完毕之后修改一下解压之后所得的文件夹名 ```shell mv zookeeper-3.4.12 zookeeper ``` 删除 zookeeper 安装包 ```shell rm -rf zookeeper-3.4.12.tar.gz ``` ### 3. 进入zookeeper目录，创建data文件夹。 ```shell mkdir data ``` 进入 data 文件夹 然后执行`pwd`命令，复制所得的当前目录位置(就是我用红色圈出来的文字)  ### 4. 进入/zookeeper/conf目录下，复制zoo_sample.cfg，命名为zoo.cfg ```shell cp zoo_sample.cfg zoo.cfg ``` ### 5. 修改配置文件 使用 `vim zoo.cfg` 命令修改配置文件 > vim 文件------>进入文件----->命令模式------>按i进入编辑模式----->编辑文件 ------->按Esc进入底行模式----->输入:wq/q! （输入wq代表写入内容并退出，即保存；输入q!代表强制退出不保存。） 修改配置文件中的 data 属性: ```conf dataDir=/usr/local/zookeeper/data ``` ### 6. 启动测试 进入 /zookeeper/bin 目录然后执行下面的命令 ```shell ./zkServer.sh start ``` 执行 `./zkServer.sh status` 查看当前 zookeeper 状态。 或者运行 `netstat -lntup` 命令查看网络状态,可以看到 zookeeper 的端口号 2181 已经被占用  ---- 注意没有关闭防火墙可能出现的问题！！！ 如果你使用的阿里云服务器注意配置相关安全组： 1. 进入本实例安全组页面  2. 选择配置规则  3. 选择添加安全组规则，然后按照下图配置  在开始实战之前提个建议：尽量新建一个文件夹，然后后面将接口项目、服务提供者以及服务消费者都放在这个文件夹。  ## 开始实战 2 ：实现服务接口 dubbo-interface 主要分为下面几步： 1. 创建 Maven 项目; 2. 创建接口类 3. 将项目打成 jar 包供其他项目使用 项目结构：  dubbo-interface 后面被打成 jar 包，它的作用只是提供接口。 ### 1. dubbo-interface 项目创建 **File->New->Module...** ,然后选择 Maven类型的项目，其他的按照提示一步一步走就好。   ### 2. 创建接口类 ```java package top.snailclimb.service; public interface HelloService { public String sayHello(String name); } ``` ### 3. 将项目打成 jar 包供其他项目使用 点击右边的 Maven Projects 然后选择 install ，这样 jar 包就打好了。  ## 开始实战 3 ：实现服务提供者 dubbo-provider 主要分为下面几步： 1. 创建 springboot 项目; 2. 加入 dubbo 、zookeeper以及接口的相关依赖 jar 包； 3. 在 application.properties 配置文件中配置 dubbo 相关信息； 4. 实现接口类; 5. 服务提供者启动类编写 项目结构：  ### 1. dubbo-provider 项目创建 创建一个 SpringBoot 项目，注意勾选上 web 模块。不会创建的话，可以查看下面这篇文章：，可以说很详细了。 [https://blog.csdn.net/qq_34337272/article/details/79563606](https://blog.csdn.net/qq_34337272/article/details/79563606)  ### 2. pom 文件引入相关依赖 需要引入 dubbo 、zookeeper以及接口的相关依赖 jar 包。注意将本项目和 dubbo-interface 项目的 dependency 依赖的 groupId 和 artifactId 改成自己的。dubbo 整合spring boot 的 jar 包在这里找[dubbo-spring-boot-starter](https://github.com/alibaba/dubbo-spring-boot-starter/blob/master/README_zh.md)。zookeeper 的 jar包在 [Maven 仓库](https://mvnrepository.com/artifact/com.101tec/zkclient) 搜索 zkclient 即可找到。 ```xml top.snailclimb dubbo-interface 1.0-SNAPSHOT com.alibaba.spring.boot dubbo-spring-boot-starter 2.0.0 com.101tec zkclient 0.10 ``` ### 3. 在 application.properties 配置文件中配置 dubbo 相关信息 配置很简单，这主要得益于 springboot 整合 dubbo 专属的`@EnableDubboConfiguration` 注解提供的 Dubbo 自动配置。 ```properties # 配置端口 server.port=8333 spring.dubbo.application.name=dubbo-provider spring.dubbo.application.registry=zookeeper://ip地址:2181 ``` ### 4. 实现接口 注意： `@Service` 注解使用的时 Dubbo 提供的而不是 Spring 提供的。另外，加了Dubbo 提供的 `@Service` 注解之后还需要加入 ```java 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; } } ``` ### 5. 服务提供者启动类编写 注意：不要忘记加上 `@EnableDubboConfiguration` 注解开启Dubbo 的自动配置。 ```java 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); } } ``` ## 开始实战 4 ：实现服务消费者 dubbo-consumer 主要分为下面几步： 1. 创建 springboot 项目; 2. 加入 dubbo 、zookeeper以及接口的相关依赖 jar 包； 3. 在 application.properties 配置文件中配置 dubbo 相关信息； 4. 编写测试类; 5. 服务消费者启动类编写 6. 测试效果 项目结构：  第1，2，3 步和服务提供者的一样，这里直接从第 4 步开始。 ### 4. 编写一个简单 Controller 调用远程服务 ```java 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; } } ``` ### 5. 服务消费者启动类编写 ```java 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); } } ``` ### 6. 测试效果 浏览器访问 [http://localhost:8330/hello](http://localhost:8330/hello) 页面返回 Hello world，控制台输出 Hello SnailClimb，和预期一致，使用SpringBoot+Dubbo 搭建第一个简单的分布式服务实验成功！ 代码地址：https://github.com/Snailclimb/springboot-guide/tree/master/source-code/advanced/springboot-dubbo