# SpringBootDemo-Dubbo

**Repository Path**: ForwardD/SpringBootDemo-Dubbo

## Basic Information

- **Project Name**: SpringBootDemo-Dubbo
- **Description**: No description available
- **Primary Language**: Unknown
- **License**: Not specified
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 0
- **Forks**: 0
- **Created**: 2021-05-28
- **Last Updated**: 2021-05-28

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

# SpringBoot Dubbo (从零开始搭建springboot-dubbo的例子)

Dubbo 是一个分布式服务框架，致力于提供高性能和透明化的 RPC 远程服务调用方案，以及 SOA 服务治理方案

## 一、 Dubbo的简单介绍

### 1. 网站架构的发展历程  

网站架构随着业务的发展，逻辑越来越复杂，数据量越来越大，交互越来越多.......

![网站架构的发展历程](https://note.youdao.com/yws/api/personal/file/D402EA4804184A839BEB8B65655CD31C?method=download&shareKey=e5ad47ccf37c97f3cab246000ce11494)

- 单一应用架构（OORM）

当网站流量很小时，将所有的功能部署到一起，以减少部署节点和成本。此时，只需要使用简化增删改查的工作量，采用数据访问框架(ORM)。

- 垂直应用架构 （MVC）

当访问量逐渐增大，单一应用带来的加速度越来越小。此时，将应用拆分成互不相干的几个应用，所以采用MVC框架。

- 分布式服务架构 （RPC）

当垂直应用越来越多，应用之交互不可避免，将核心业务抽取出来，作为独立的服务，逐渐形成稳定的服务中心，使前端应用能更快速地响应多变的市场需求。此时，用于提高业务复用及整合的服务框架(RPC)是关键。

- 流动计算框架 （SQA）

当服务越来越多，容量的评估，小服务资源的浪费等问题逐渐显现，此时需增加一个调度中心基于访问压力实时管理集群容量，提高集群利用率。此时，用于提高机器利用率的 资源调度和治理中心(SOA) 是关键。

### 2. dubbo核心工作原理

![dubbo核心工作原理](https://note.youdao.com/yws/api/personal/file/2C1D0FF81BAE4977A690D2073D997FCC?method=download&shareKey=07e664cb7040a5c1d45ed8b1ba180c28)

节点 | 角色说明
--|--
Provider|暴露服务的服务提供方
Registry|服务的注册与发现的注册中心，如zookeper(推荐)、multicast、redis、simple
Consumer|调用远程服务的服务消费方
Monitor|统计服务的调用次数和调用时间的监控中心
Container|服务运行容器

#### 调用流程

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

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

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

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

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

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

### 3. dubbo特点

1. Dubbo 支持 RPC 调用，服务之间的调用性能会很好，效率很高

2. 支持多种序列化协议，如 Hessian(默认)、HTTP、WebService

3. 对比springcloud

![dubbo和SpringCloud对比](https://note.youdao.com/yws/api/personal/file/8C1E02A8FBB344A0A4DD63DA245DBEF0?method=download&shareKey=39cc0e558b014e9c71b1e2c676b87353)

## 二、 springboot-Dubbo搭建

想要使用Dubbo的话，按照前面的原理图，我们主要使用它的服务远程调用功能，也就是两个项目之间相互通讯，即RPC

直接上图，先大致看看项目结构：

![dubbo示例项目结构](https://note.youdao.com/yws/api/personal/file/113EFBF4C33140BF9C90842753851434?method=download&shareKey=5ca0997d494f11eeac42fe3f33d9d5d2)

dubbo-provider是所谓的服务提供者，springboot项目 

dubbo-consumer是服务消费者，springboot项目

dubbo-api是服务提供者的接口API，最普通的maven项目

>这里可以会想起dubbo工作原理的图：

- 0 dubbo-provider先在容器里初始化启动
- 1 dubbo-provider去注册中心去注册服务，注册中心使用zookeeper
- 2 dubbo-consumer去注册中心发现需要的服务
- 3 注册中心返回dubbo-provider的服务
- 4 dubbo-consumer直接去调用dubbo-provider

### 1. 项目依赖

dubbo的jar包依赖(spring-boot)

```xml
<!-- dubbo依赖 -->
<dependency>
    <groupId>com.alibaba.spring.boot</groupId>
    <artifactId>dubbo-spring-boot-starter</artifactId>
    <version>2.0.0</version>
</dependency>
```

注册中心zookeeper的jar包依赖

```xml
<!-- 引入zookeeper的依赖 -->
<dependency>
    <groupId>com.101tec</groupId>
    <artifactId>zkclient</artifactId>
    <version>0.10</version>
</dependency>
```

### 2. 服务提供者

服务提供者dubbo-provider提供HelloService.sayHello()接口

```java
package com.dubbo.provider.service;

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

//@Service是dubbo里的注解，作用是暴露服务，不要选择spring的@Service
@Service
@Component
public class HelloServiceImpl implements HelloService {

    @Override
    public String sayHello(String name) {
        return "Hello" + name;
    }
}
```

>还要在springboot的启动类上加一个开启Dubbo的注解

```java
package com.dubbo.provider;

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

//开启dubbo的自动配置
@EnableDubboConfiguration
@SpringBootApplication
public class DubboProviderApplication {

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

}
```

### 3. 服务消费者

dubbo-consumer远程调用dubbo-consumer提供的服务HelloService.sayHello()接口

```java
package com.dubbo.consumer.controller;

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

@RestController
public class HelloController {

    @Reference//dubbo注解，可以仔细了解下这个注解
    private HelloService helloService;

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

}
```

同上，这个也需要让Dubbo开启自动配置

```java
package com.dubbo.consumer;

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

//就是这里，对，没错 ->_->
@EnableDubboConfiguration
@SpringBootApplication
public class DubboConsumerApplication {

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

}
```

### 4. 项目启动流程和结构

#### 1. 启动祖册中心：

项目启动需要去官网下载[zookeper注册中心](http://mirror.bit.edu.cn/apache/zookeeper/)，解压，配置一下zoo.cfg配置文件，然后启动zkServer.cmd（以下是我的简单配置）

```properties
tickTime=2000
initLimit=10
syncLimit=5
dataDir=F:\\zookeeper-3.4.14\\temp\\zookeeper
dataLogDir=F:\\zookeeper-3.4.14\\temp\\zookeeper-logs
clientPort=2181
```

#### 2. 启动服务提供方dubbo-provider

如下图，说明dubbo-provider启动，并且已经连上注册中心

![提供者启动](https://note.youdao.com/yws/api/personal/file/05ABF9BF1C1144F689B3711024D20FF5?method=download&shareKey=59c6212ae4b3d09568465774799dd654)

#### 3. 启动服务消费方dubbo-consumer

效果跟上面差不多

#### 4. 服务调用结果

自己去试试，皮一下，，哈哈 QWQ

## 三、项目地址

[springboot-dubbo-demo](https://github.com/Baijq/SpringBootDemo/tree/master/springboot-dubbo)

## 注意点和问题

**dubbo直连**，这个可以在测试的过程中使用

**dubbo的高校序列化协议**可以选的，默认是hessian

dubbo是基于TCP协议去做的，所以很快。

在启动zookeeper时，会有窗口一闪而过的情况，有可能时jdk环境变量有空格，还有可能是zk的dataDir路径不对

《完》