Dubbo和Zookeeper

分布式系统

分布式系统是由一组通过网络进行通信、为了完成共同的任务而协调工作的计算机节点组成的系统。分布式系统的出现是为了用廉价的、普通的机器完成单个计算机无法完成的计算、存储任务。其目的是利用更多的机器，处理更多的数据。分布式系统（distributed system）是建立在网络之上的软件系统。

分布式系统也带来了一些好处：

• 提升性能和并发，操作被分发到不同的分片，相互独立
• 提升系统的可用性，即使部分分片不能用，其他分片不会受到影响

几种架构的区别

在Dubbo官网有这样的一张图,分别列举出了几种不同的架构方式:

• 单一的应用架构

当应用程序很小时,我们需要把所有功能都部署到一起,这样可以减少成本和部署节点的麻烦;适用于小型网站和小型应用程序;

• 垂直应用架构

当程序变得很大,用户访问量也很大时,可以将应用分拆成几个不相干的部分;即使用WEB开发框架(MVC)的思想;

• 分布式架构

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

RPC

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

例子: 两台服务器A & B , 在服务器A上部署应用, 然后在服务器B上调用应用 ;由于不在一个内存空间，不能直接调用，需要通过网络来表达调用的语义和传达调用的数据。

分布式系统的环境搭建

• Dubbo的安装

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

Dubbo的基本概念:

Dubbo中各名词的详解:

服务提供者（Provider）：暴露服务的服务提供方，服务提供者在启动时，向注册中心注册自己提供的服务。

服务消费者（Consumer）：调用远程服务的服务消费方，服务消费者在启动时，向注册中心订阅自己所需的服务，服务消费者，从提供者地址列表中，基于软负载均衡算法，选一台提供者进行调用，如果调用失败，再选另一台调用。

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

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

执行路线:

服务器负责启动服务 -----> 提供者在注册中心中注册自己提供的服务 -----> 消费者从注册中心获取自己所需要的服务

• 开始搭建服务:

1、首先要先下载zookeeper:

下载地址: https://downloads.apache.org/zookeeper/

下载完解压,在cmd控制台页面输入:

tar -zxvf xxxxtar.gz

注意:如果运行/bin/zkServer.cmd出现问题,则需要在conf文件夹下面的zoo_sample.cfg复制一份改名为zoo.cfg即可;

也可编辑zkServer.cmd文件末尾添加pause ,会提示出错误信息;

接下来,就可以启动成功了;

2、下载dubbo-admin：

下载地址：https://github.com/stackXu/dubbo-admin

解压完成后，在项目目录下打包dubbo-daimn：

mvn clean package -Dmaven.test.skip=true

等待打包成功，会生成一个jar包，执行jar包： dubbo-admin\target 下的dubbo-admin-0.0.1-SNAPSHOT.jar

java -jar dubbo-admin-0.0.1-SNAPSHOT.jar

然后就可以在网页输入链接： http://localhost:7001/，可以访问dubbo的可视化界面了。

注意：访问页面时，zookeeper的服务必须同时开启，不然无法访问。

springboot中集成dubbo+zookeeper

• 创建一个空项目；
• 里面建立两个模块；分别问provide和consumer

• 添加依赖

Dubbo：

<!-- Dubbo Spring Boot Starter -->
<dependency>
   <groupId>org.apache.dubbo</groupId>
   <artifactId>dubbo-spring-boot-starter</artifactId>
   <version>2.7.3</version>
</dependency>    

zookeeper:

<!-- https://mvnrepository.com/artifact/com.github.sgroschupf/zkclient -->
<dependency>
   <groupId>com.github.sgroschupf</groupId>
   <artifactId>zkclient</artifactId>
   <version>0.1</version>
</dependency>

日志冲突，还需要剔除日志依赖:

<!-- 引入zookeeper -->
<dependency>
   <groupId>org.apache.curator</groupId>
   <artifactId>curator-framework</artifactId>
   <version>2.12.0</version>
</dependency>
<dependency>
   <groupId>org.apache.curator</groupId>
   <artifactId>curator-recipes</artifactId>
   <version>2.12.0</version>
</dependency>
<dependency>
   <groupId>org.apache.zookeeper</groupId>
   <artifactId>zookeeper</artifactId>
   <version>3.4.14</version>
   <!--排除这个slf4j-log4j12-->
   <exclusions>
       <exclusion>
           <groupId>org.slf4j</groupId>
           <artifactId>slf4j-log4j12</artifactId>
       </exclusion>
   </exclusions>
</dependency>

注意：两个模块都要导入依赖；

• provide的编写：

application.properties

server.port=8080
#当前应用的名字
dubbo.application.name=provider-server
#注册中心的地址
dubbo.registry.address=zookeeper://127.0.0.1:2181
#需要被扫描的包
dubbo.scan.base-packages=com.vxzx.server

server层：

public interface Provider {
    public String getTicket();
}

@DubboService       //添加注解,将服务发布出去
@Service            //将该类放到spring容器中
public class ProviderImp implements Provider {
    @Override
    public String getTicket() {
        return "获取得到Provider的票";
    }
}

• consumer编写：

application.properties

server.port=8081

#当前应用名字
dubbo.application.name=consumer-server
#注册中心地址
dubbo.registry.address=zookeeper://127.0.0.1:2181

server层：

@Service
public class Userserver {
    @DubboReference     //远程引用指定的服务，他会按照全类名进行匹配，看谁给注册中心注册了这个全类名
    Provider provider;

    //可以从数据中心拿出数据:
    public String consumerGet(){
        String ticket = provider.getTicket();
        return "从注册中心得到的值:" + ticket;
    }
}

简单的测试，正常步骤是需要将服务提供者的接口打包，然后用pom文件导入，我们这里使用简单的方式，直接将服务的接口拿过来，路径必须保证正确，即和服务提供者相同；

public interface Provider {
    public String getTicket();
}

最后，开启zookeeper服务，开启两个模块的(必须保证两个模块的端口号不同)，运行测试：

@SpringBootTest
class ConsumerServerApplicationTests {
    @Autowired
    Userserver userserver;

    @Test
    void contextLoads() {
        System.out.println(userserver.consumerGet());
    }
}

测试成功！

进入http://localhost:7001/，可以看到我们使用的注册中心和使用的服务：