一、分布式简要说明

Dubbo是用于分布式系统的框架所以我们要先了解什么是分布式

分布式系统是若干独立计算机的集合，这些计算机对于用户来说就像单个相关系统。

老式系统(单一应用架构)就是把一个系统，统一放到一个服务器当中然后每一个服务器上放一个系统，如果说要更新代码的话，每一个服务器上的系统都要重新去部署十分的麻烦。

而分布式系统就是将一个完整的系统拆分成多个不同的服务，然后在将每一个服务单独的放到一个服务器当中。(三个臭皮匠赛过诸葛亮)

1.1、应用架构及发展演变

1.2、Dubbo和SpringCloud对比

1.3、发展演变

1.3.1、ORM

单一应用架构：一个项目装到一个服务器当中，也可以运行多个服务器每一个服务器当中都装一个项目。
缺点：1.如果要添加某一个功能的话就要把一个项目重新打包，在分别部署到每一个服务器当中去。2.如果后期项目越来越大的话单台服务器跑一个项目压力会很大的。会不利于维护，开发和程序的性能。

1.3.2、mvc

垂直应用架构：将应用切割成几个互不相干的小应用，在将每个小应用独立放到一个服务器上，如果哪一个应用的访问数量多就多加几台服务器。

1.3.3、分布式服务架构

1.3.4、RPC简介

分布式应用架构(远程过程调用)：当垂直应用越来越多，应用之间交互不可避免，将核心业务抽取出来，作为独立的服务，逐渐形成稳定的服务中心，使前端应用能更快速的响应多变的市场需求。

什么是RPC

RPC [ Remote Procedure Call]是指远程过程调用，是一种进程问通信方式，他是一种技术的思想，而不是规范。它允许程序调用另一个地址空间(通常是共享网络的另一台机器上)的过程或函数，而不用程序员显式编码这个远程调用的细节。即程序员无论是调用本地的还是远程的函数，本质上编写的调用代码基本相同。
RPC（Remote Procedure Call）—远程过程调用，它是一种通过网络从远程计算机程序上请求服务，而不需要了解底层网络技术的协议。也就是说两台服务器A，B，一个应用部署在A服务器上，想要调用B服务器上应用提供的方法，由于不在一个内存空间，不能直接调用，需要通过网络来表达调用的语义和传达调用的数据。

RPC工作原理

过程

a.Client像调用本地服务似的调用远程服务；
b.Client stub接收到调用后，将方法、参数序列化
c.客户端通过sockets将消息发送到服务端
d.Server stub 收到消息后进行解码（将消息对象反序列化）
e.Server stub 根据解码结果调用本地的服务
f.本地服务执行(对于服务端来说是本地执行)并将结果返回给Server stub
g.Server stub将返回结果打包成消息（将结果消息对象序列化）
h.服务端通过sockets将消息发送到客户端
i.Client stub接收到结果消息，并进行解码（将结果消息发序列化）
j.客户端得到最终结果

RPC 调用分以下两种：

同步调用：客户方等待调用执行完成并返回结果。
异步调用：客户方调用后不用等待执行结果返回，但依然可以通过回调通知等方式获取返回结果。若客户方不关心调用返回结果，则变成单向异步调用，单向调用不用返回结果。

RPC步骤解析

SOA

流动计算架构：在分布式应用架构的基础上增加了一个调度、治理中心基于访问压力实时管理集群容量、提高集群的利用率，用于提高机器利用率的资源调度和治理中心(SOA) 是关键 (不浪费计算机资源)

二、Dubbo基础

2.1、Dubbo核心概念

Dubbo官网: http://dubbo.apache.org/en-us/index.html
Dubbo 是一款高性能、轻量级的开源Java RPC框架，它提供了三大核心能力：面向接口的远程方法调用，智能容错和负载均衡，服务自动注册和发现。分布式系统是将一个系统拆分为多个不同的服务

2.2、Dubbo特性一览

2.3、dubbo设计架构

服务提供者（Provider）：暴露服务的服务提供方，服务提供者在启动时，向注册中心注册自己提供的服务。
服务消费者（Consumer）: 调用远程服务的服务消费方，服务消费者在启动时，向注册中心订阅自己所需的服务，服务消费者，从提供者地址列表中，基于软负载均衡算法，选一台提供者进行调用，如果调用失败，再选另一台调用。
注册中心（Registry）：注册中心返回服务提供者地址列表给消费者，如果有变更，注册中心将基于长连接推送变更数据给消费者。
监控中心（Monitor）：服务消费者和提供者，在内存中累计调用次数和调用时间，定时每分钟发送一次统计数据到监控中心。

2.4、Dubbo的特性

2.4.1、服务注册中心

相比Hessian类RPC框架，Dubbo有自己的服务中心，写好的服务可以注册到服务中心，客户端从服务中心寻找服务，然后再到相应的服务提供者机器获取服务。通过服务中心可以实现集群、负载均衡、高可用(容错) 等重要功能。
服务中心一般使用zookeeper实现，也有redis和其他一些方式。以使用zookeeper作为服务中心为例，服务提供者启动后会在zookeeper的/dubbo节点下创建提供的服务节点，包含服务提供者ip、port等信息。服务提供者关闭时会从zookeeper中移除对应的服务。
服务使用者会从注册中心zookeeper中寻找服务，同一个服务可能会有多个提供者，Dubbo会帮我们找到合适的服务提供者，也就是针对服务提供者的负载均衡。

2.4.2、负载均衡

当同一个服务有多个提供者在提供服务时，客户端如何正确的选择提供者实现负载均衡呢？dubbo也给我们提供了几种方案：

random 随机选提供者，并可以给提供者设置权重
roundrobin 轮询选择提供者
leastactive 最少活跃调用数，相同活跃数的随机，活跃数：指调用前后计数差。使慢的提供者收到更少请求，因为越慢的提供者的调用前后计数差会越大。
consistenthash 一致性hash，相同参数的请求发到同一台机器上。

2.4.3、简化测试，允许直连提供者

在开发阶段为了方便测试，通常系统客户端能指定调用某个服务提供者，那么可以在引用服务时加一个url参数去指定服务提供者。配置如下：

<dubbo:reference id="xxxService"interface="com.alibaba.xxx.XxxService"url="dubbo://localhost:20890"/>

2.4.4、服务版本，服务分组

在Dubbo配置文件中可以通过制定版本实现连接制定提供者，也就是通过服务版本可以控制服务的不兼容升级；当同一个服务有多种实现时，可以使用服务分组进行区分。

三、Dubbo环境搭建

3.1、搭建zookeeper注册中心环境

Dubbo官方文档: http://dubbo.apache.org/en-us/docs/user/quick-start.html

在zookeeper官网下载zookeeperhttp://mirror.bit.edu.cn/apache/zookeeper/zookeeper-3.4.14/

zookeeper 可访问如下文档：

点击链接查看：https://www.yuque.com/yang.guo.top1/java-start/yu9k75

此时，我们zookeeper的注册中心及环境以及搭建完毕。

3.2、搭建zookeeper监控中心的配置、启动dubbo-admin监控页面

下载dubbo-admin

dubbo-admin下载地址：https://github.com/apache/dubbo-admin/tree/master

解压后进入目录修改指定zookeeper地址

进入如下地址：dubbo-admin-master\dubbo-admin\src\main\resources\application.properties"
将zookeeper的监控中心的地址配置为本地端口

#注册中心的地址
dubbo.registry.address=zookeeper://127.0.0.1:2181

配置完毕后，我们在dubo-zookeeper\dubbo-admin-master\dubbo-admin文件夹下cmd打包测试下。
mvn clean package
java -jar dubbo-admin-0.0.1-SNAPSHOT.jar运行打包好的jar包
启动成功后，可以看到一个8080的端口
此时我们的zookeeper的服务都为启动状态，在浏览器中访问 localhost:8080，访问到注册中心，输入账号密码root。
此时，我们zookeeper监控中心的配置完成。注意，要访问到监控中心，一定要启动zookeeper注册中心的启动类

四、Dubbo-hello world

4.1、Dubbo环境搭建，创建提供者、消费者项目

4.1.1、服务提供者搭建（user-service-provider）

pojo.UserAddress

/**
* @Description:
* @Author: Guo.Yang
* @Date: 2022/09/22/15:45
*/
@Data
    @AllArgsConstructor
    @NoArgsConstructor
    public class UserAddress {
        private Integer id;
        private String userAddress; //用户地址
        private String userId; //用户id
        private String consignee; //收货人
        private String phoneNum; //电话号码
        private String isDefault; //是否为默认地址    Y-是     N-否
    }

service.UserService

/**
 * @Description:
 * @Author: Guo.Yang
 * @Date: 2022/09/22/15:47
 */
@Service
public interface UserService {
       /**
        * 按照用户id返回所有的收货地址
        * @param userId
        * @return
        */
        public List<UserAddress> getUserAddressList(String userId);
}

service.impl.UserServiceImpl

/**
 * @Description:
 * @Author: Guo.Yang
 * @Date: 2022/09/22/15:48
 */
@Service("UserServiceImpl")
public class UserServiceImpl implements UserService {
    @Override
    public List<UserAddress> getUserAddressList(String userId) {
        UserAddress address1 = new UserAddress(1, "河南省郑州巩义市宋陵大厦2F", "1", "安然", "150360313x", "Y");
        UserAddress address2 = new UserAddress(2, "北京市昌平区沙河镇沙阳路", "1", "情话", "1766666395x", "N");
        return Arrays.asList(address1,address2);
    }
}

4.1.2、服务消费者搭建（order-service-consumer）订单服务

service.OrderService

/**
 * @Description:
 * @Author: Guo.Yang
 * @Date: 2022/09/22/15:56
 */
@Service
public interface OrderService {
    /**
     * 初始化订单
     * @param userID
     */
    public void initOrder(String userID);
}

service.impl.OrderServiceImpl

/**
 * @Description:
 * @Author: Guo.Yang
 * @Date: 2022/09/22/15:56
 */
@Service("OrderServiceImpl")
public class OrderServiceImpl implements OrderService {
    //查询用户的收货地址
    UserService userService;
    @Override
    public void initOrder(String userID) {
        //查询用户的收货地址
        List<UserAddress> userAddressList = userService.getUserAddressList(userID);
        System.out.println(userAddressList);
    }
}

注意

因服务消费者要拿到提供者的方法
将服务提供者中的实体类及 UserService 复制到当前消费者同级文件中。
此时我们调用userservice肯定是要报错的。这种面向接口的方式，我们这里只是调到了接口，而接口实际是在另外一个项目中，如果我们两个项目工程都创建共同的实体类，太过于麻烦了，我们可以将服务接口，服务模型等单独放在一个项目中，更为方便调用。（将公共业务部分提到一个业务模块下，需要的模块服务，引入公共业务依赖jar包即可）

4.1.3、搭建共同的服务接口（gmail-interface）

pojo.UserAddress

@Data
@AllArgsConstructor
@NoArgsConstructor
public class UserAddress {
    private Integer id;
    private String userAddress; //用户地址
    private String userId; //用户id
    private String consignee; //收货人
    private String phoneNum; //电话号码
    private String isDefault; //是否为默认地址    Y-是     N-否
}

service.OrderService

public interface OrderService {
    /**
     * 初始化订单
     * @param userID
     */
    public void initOrder(String userID);
}

servce.UserService

public interface UserService {
    /**
     * 按照用户id返回所有的收货地址
     * @param userId
     * @return
     */
    public List<UserAddress> getUserAddressList(String userId);
}

将提供者和消费者项目中的所有实体类复制到当前相关的文件包下，删除原有的实体类包及service包，也就是将实体类及service放在了当前公共的项目中。
把服务提供者和消费者项目中引入以下依赖，引入后项目不在报错.

<!--        使用自定义的共通服务模块-->
<dependency>
  <groupId>com.yang</groupId>
  <artifactId>gmail-interface1</artifactId>
  <version>0.0.1-SNAPSHOT</version>
</dependency>

4.2、服务提供者配置&测试

4.2.1、将服务提供者注册到注册中心中

在user-service-provider 导入dubbo依赖、操作zk的客户端

   <!--dubbo-->
    <dependency>
        <groupId>com.alibaba</groupId>
        <artifactId>dubbo</artifactId>
        <version>2.6.2</version>
    </dependency>
    <!--注册中心是 zookeeper，引入zookeeper客户端-->
    <dependency>
        <groupId>org.apache.curator</groupId>
        <artifactId>curator-framework</artifactId>
        <version>2.12.0</version>
    </dependency>

在resource文件中创建provider.xml

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
    http://dubbo.apache.org/schema/dubbo http://dubbo.apache.org/schema/dubbo/dubbo.xsd
    http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
    <!--1、指定当前服务/应用的名字(同样的服务名字相同，不要和别的服务同名)-->
    <dubbo:application name="user-service-provider"></dubbo:application>
    <!--2、指定注册中心的位置-->
    <!--<dubbo:registry address="zookeeper://127.0.0.1:2181"></dubbo:registry>-->
    <dubbo:registry protocol="zookeeper" address="39.105.228.254:2181"></dubbo:registry>
    <!--3、指定通信规则（通信协议? 服务端口）-->
    <dubbo:protocol name="dubbo" port="10011"></dubbo:protocol>
    <!--4、暴露服务 让别人调用 ref指向服务的真正实现对象-->
    <dubbo:service interface="com.yang.gmail_interface.service.UserService" ref="userServiceImpl"></dubbo:service>
    <!--服务的实现-->
    <bean id="userServiceImpl" class="com.yang.user_service_provider.service.impl.UserServiceImpl"></bean>
</beans>

编写一个ProviderApplication启动类程序，运行测试配置

public class MailApplication {
    public static void main(String[] args) throws IOException {
        ClassPathXmlApplicationContext applicationContext= new ClassPathXmlApplicationContext("provider.xml");
        applicationContext.start();
        System.in.read();
    }
}

启动主启动类
启动dubbo-admin服务
访问http://localhost:8080/
在里边会看到我们刚刚注册进去的服务提供者

服务提供者配置测试成功

Dubbo

一、分布式简要说明

1.1、应用架构及发展演变

1.2、Dubbo和SpringCloud对比

1.3、发展演变

1.3.1、ORM

1.3.2、mvc

1.3.3、分布式服务架构

1.3.4、RPC简介

二、Dubbo基础

2.1、Dubbo核心概念

2.2、Dubbo特性一览

2.3、dubbo设计架构

2.4、Dubbo的特性

2.4.1、服务注册中心

2.4.2、负载均衡

2.4.3、简化测试，允许直连提供者

2.4.4、服务版本，服务分组

三、Dubbo环境搭建

3.1、搭建zookeeper注册中心环境

3.2、搭建zookeeper监控中心的配置、启动dubbo-admin监控页面

四、Dubbo-hello world

4.1、Dubbo环境搭建，创建提供者、消费者项目

4.1.1、服务提供者搭建（user-service-provider）

4.1.2、服务消费者搭建（order-service-consumer）订单服务

4.1.3、搭建共同的服务接口（gmail-interface）

4.2、服务提供者配置&测试

4.2.1、将服务提供者注册到注册中心中

4.2.2、让服务消费者去注册中心订阅服务提供者的服务地址

热门文章

最新文章

相关课程

相关电子书

相关实验场景

热门

活动广场

任务中心

开发者评测

高校计划

乘风者计划

训练营

阿里云MVP

话题

直播

下载

镜像站

技术资料

插件

Dubbo

一、分布式简要说明

1.1、应用架构及发展演变

1.2、Dubbo和SpringCloud对比

1.3、发展演变

1.3.1、ORM

1.3.2、mvc

1.3.3、分布式服务架构

1.3.4、RPC简介

二、Dubbo基础

2.1、Dubbo核心概念

2.2、Dubbo特性一览

2.3、dubbo设计架构

2.4、Dubbo的特性

2.4.1、服务注册中心

2.4.2、负载均衡

2.4.3、简化测试，允许直连提供者

2.4.4、服务版本，服务分组

三、Dubbo环境搭建

3.1、搭建zookeeper注册中心环境

3.2、搭建zookeeper监控中心的配置、启动dubbo-admin监控页面

四、Dubbo-hello world

4.1、Dubbo环境搭建，创建提供者、消费者项目

4.1.1、服务提供者搭建（user-service-provider）

4.1.2、服务消费者搭建（order-service-consumer）订单服务

4.1.3、搭建共同的服务接口（gmail-interface）

4.2、服务提供者配置&测试

4.2.1、将服务提供者注册到注册中心中

4.2.2、让服务消费者去注册中心订阅服务提供者的服务地址

热门文章

最新文章

相关课程

相关电子书

相关实验场景