1、分布式理论

1.1）什么是分布式系统

“分布式是若干独立计算机的集合，这些计算机对于用户来说就像单个相关系统”
分布式系统是建立在网络之上的软件系统

1.2）发展演变

单一应用架构—-》垂直应用架构—-》分布式业务架构—》流动计算架构

1.界面+业务逻辑的实现分离
2.应用不可能完全独立，大量的应用之间需要交互。

1.3）RPC

什么是RPC
RPC [ Remote Procedure Call]是指远程过程调用，是一种进程间通信方式，他是一种技术的思想，而不是规范。它允许程序调用另一个地址空间(通常是共享网络的另-台机器上)的过程或函数，而不用程序员显式编码这个远程调用的细节。即程序员无论是调用本地的还是远程的函数，本质上编写的调用代码基本相同。
RPC原理图

例子：

影响一个RPC框架的性能的两点核心模块（通信[xml，json，二进制流 ]和序列化）：
能否在各个调用之间快速的建立连接（看框架的序列化机制和反序列化机制快不快）

市面上的RPC框架：dubbo，gRPC，Thrift，HSF（High Speed Service Framework）

2、dubbo核心概念

2.1）简介

Apache Dubbo是一款高性能、轻量级的开源Java RPC框架，它提供了三大核心能力:面向接口的远程方法调用，智能容错和负载均衡，以及服务自动注册和发现。
官网：https://dubbo.apache.org/zh/index.html
特性：

为动态感知每一个服务的健康状态引入注册中心。

灰度发布：由旧服务慢慢的变为新服务，先将部分旧服务替换为新服务，当一段时间后没有问题再将一部分替换为新服务从而将所有的服务都替换为新服务。

2.2）dubbo设计架构

https://blog.csdn.net/niyuelin1990/article/details/103974106

3、启动服务注册中心

启动报错：缺少配置文件

修改配置文件数据存放位置：dataDir=../data
再次启动：启动OK。

4、安装监控中心

监控中心可不安装。不影响使用

下载地址
Dubbo Admin下载，mvn clean package进行打包。2.8以前是war包，2.8以后是jar包。
启动监控中心：java -jar xxxx.jar
默认端口：7001，用户名和密码都是root

5、dubbo-helloworld

5.1）需求如下

某个电商系统，订单服务需要调用用户服务获取某个用户的所有地址
我们现在，需要创建两个服务模块进行测试。

订单服务web模块：创建订单等
用户服务service模块：查询用户地址

测试预期结果：订单服务web模块在A服务器，用户服务模块在B服务器，A可以远程调用B的功能。

5.2）创建SpringBoot工程 dubbo-demo

5.3）创建服务提供者 user-service-provider

public class UserAdress implements Serializable {
    private Integer id;
    private String userAdress; // 用户地址
    private String userId; // 用户id
    private String consignee; // 收货人
    private String phoneNume; // 电话号码
    private String isDefault; // 是否为默认地址
}

public interface UserService {
    /**
     * 获取用户所有地址
     * @param userId
     * @return
     */
    List<UserAdress> getUserAddressList(String userId);
}

public class UserServiceImpl implements UserService {
    @Override
    public List<UserAdress> getUserAddressList(String userId) {
        UserAdress userAdress1 = new UserAdress(1, "长沙", "1", "李老师", "199", "是");
        UserAdress userAdress2 = new UserAdress(2, "长沙", "2", "谭老师", "198", "是");
        return Arrays.asList(userAdress1, userAdress2);
    }
}

5.4）创建订单服务 order-service-consumer

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

public class OrderServiceImpl implements OrderService {
    @Override
    public void initOrder(String userId) {
        // 1. 查询用户的地址
        List<UserAdress> userAddressList = userService.getUserAddressList(userId);
        System.out.println(userAddressList);
    }
}

5.5）创建公共服务 gmail-interface

将实体类和接口放入到公共服务模块中，并引入公共模块依赖。

最后的项目结构如下：

6、dubbo改造helloworld

provider.xml：https://dubbo.apache.org/zh/docsv2.7/user/quick-start/
zookeeper注册中心：https://dubbo.apache.org/zh/docsv2.7/user/references/registry/zookeeper/
步骤：

6.1）配置服务提供者

在user-service-provider工程中添加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://dubbo.apache.org/schema/dubbo"
       xsi:schemaLocation="http://www.springframework.org/schema/beans        http://www.springframework.org/schema/beans/spring-beans-4.3.xsd        http://dubbo.apache.org/schema/dubbo        http://dubbo.apache.org/schema/dubbo/dubbo.xsd">
    <!-- 1、提供方应用信息，用于计算依赖关系 -->
    <dubbo:application name="user-service-provider"  />
    <!-- 2、指定注册中心，使用zookeeper广播注册中心暴露服务地址 -->
    <!--    集群配置-->
<!--    <dubbo:registry address="zookeeper://10.20.153.10:2181?backup=10.20.153.11:2181,10.20.153.12:2181" />-->
    <!--    单机配置  <dubbo:registry address="zookeeper://10.20.153.10:2181" /> -->
    <dubbo:registry protocol="zookeeper" address="127.0.0.1:2181" />
    <!-- 3、指定通信规则，用dubbo协议在20880端口暴露服务 -->
    <dubbo:protocol name="dubbo" port="20880" />
    <!-- 4、声明需要暴露的服务接口, userService指向服务真正的实现对象 -->
    <dubbo:service interface="com.lzy.service.UserService" ref="userServiceImpl" />
    <!-- 5、和本地bean一样实现服务 -->
    <bean id="userServiceImpl" class="com.lzy.service.impl.UserServiceImpl" />
</beans>

在user-service-provider工程中添加MainApplication入口类进行测试

public class MainApplication {
    public static void main(String[] args) throws IOException {
        ClassPathXmlApplicationContext ioc = new ClassPathXmlApplicationContext("provider.xml");
        ioc.start();  // start是ClassPathXmlApplicationContext中的方法
        System.in.read();
    }
}

启动后：

6.2）配置服务消费者

<?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://dubbo.apache.org/schema/dubbo"
       xmlns:context="http://www.springframework.org/schema/context"
       xsi:schemaLocation="http://www.springframework.org/schema/beans
       http://www.springframework.org/schema/beans/spring-beans-4.3.xsd
       http://dubbo.apache.org/schema/dubbo
       http://dubbo.apache.org/schema/dubbo/dubbo.xsd http://www.springframework.org/schema/context https://www.springframework.org/schema/context/spring-context.xsd">
    <!-- 让注解生效，使用包扫描-->
    <context:component-scan base-package="com.lzy.service.impl"></context:component-scan>
    <!-- 消费方应用名，用于计算依赖关系，不是匹配条件，不要与提供方一样 -->
    <dubbo:application name="order-service-consumer"  />
    <!-- 使用zookeeper广播注册中心暴露发现服务地址 -->
    <dubbo:registry address="zookeeper://127.0.0.1:2181" />
    <!-- 生成远程服务代理，可以和本地bean一样使用demoService -->
    <dubbo:reference id="userService" interface="com.lzy.gmail.service.UserService" />
</beans>

import com.lzy.gmail.service.OrderService;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import java.io.IOException;
public class MainApplication {
    public static void main(String[] args) throws IOException {
        ClassPathXmlApplicationContext ioc = new ClassPathXmlApplicationContext("consumer.xml");
        OrderService orderService = ioc.getBean(OrderService.class);
        orderService.initOrder("1");
        System.out.println("调用完成~");
        System.in.read();
    }
}

启动测试：

6.3）监控中心：dubbo-monitor-simple

打包：mvn clean package

打包后不要直接启动，将压缩包解压后，修改下dubbo.properties配置文件后，进入bin目录进行启动。

添加监控中心地址：

      <!-- 添加监控中心 protocol="registry" 去注册中心发现-->
    <dubbo:monitor address="127.0.0.1:7070"></dubbo:monitor>
<!--    <dubbo:monitor protocol="registry"></dubbo:monitor>-->

重新启动服务

7、与SpringBoot整合

导入依赖

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>com.alibaba.boot</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
            <version>0.2.0</version>
        </dependency>

创建订单controller

@RestController
public class OrderController {
    @Autowired
    private UserService userService;
    @RequestMapping("/initOrder")
    public List<UserAdress> initOrder(@RequestParam("uid")String userId) {
        return userService.getUserAddressList(userId);
    }
}

使用application.properties整合dubbo

dubbo.application.name=user-service-provider
dubbo.registry.address=127.0.0.1:2181
dubbo.registry.protocol=zookeeper
# 协议
dubbo.protocol.name=dubbo
dubbo.protocol.port=20880
# 使用注册中心发现
dubbo.monitor.protocol=registry

暴露服务使用注解@Service [import com.alibaba.dubbo.config.annotation.Service;]
主程序开启dubbo。@EnableDubbo # 开启注解的Dubbo功能。

import com.alibaba.dubbo.config.spring.context.annotation.EnableDubbo;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
@EnableDubbo  // 开始Dubbo注解
@SpringBootApplication
public class MainApplication {
    public static void main(String[] args) {
        SpringApplication.run(MainApplication.class);
    }
}

启动测试访问地址： http://localhost:8902/initOrder?uid=1

dubbo学习

1、基础知识