分布式系统RPC远程调用

互联⽹不可不知的RPC远程调⽤协议？

• RPC是什么？

  • RPC是指远程过程调用，也就是说两台服务器A，B，一个应用部署在A服务器上，想要调用B服务器上应用提供的函数/方法，由于不在一个内存空间，不能直接调用，需要通过网络来表达调用的语义和传达调用的数据

• RPC怎么做

  • 连接：通过在客户端和服务器之间建立TCP连接，远程过程调用的所有交换的数据都在这个连接里传输

  • 寻址：A服务器上的应用怎么告诉底层的RPC框架，如何连接到B服务器（如主机或IP地址）以及特定的端口

  • 编码：网络协议是基于二进制的，内存中的参数的值要序列化成二进制的形式，也就是序列化（Serialize）或编组（marshal），通过寻址和传输将序列化的二进制发送给B服务器

  • 解码：B服务器收到请求后，需要对参数进行反序列化（序列化的逆操作），恢复为内存中的表达方式，然后找到对应的方法（寻址的一部分）进行本地调用，然后得到返回值

  • 处理返回值：返回值还要发送回服务器A上的应用，也要经过序列化的方式发送，服务器A接到后，再反序列化，恢复为内存中的表达方式，交给A服务器上的应用

  • 

• RPC的协议有很多，比如最早的CORBA，Java RMI，Web Service的RPC风格，Hessian，Thrift，甚至Rest API

二、Dubbo是什么？为什么我们要用Dubbo

• Dubbo是什么？

  Apache Dubbo 是一个高性能，轻量级，基于Java的RPC框架。Dubbo提供三个关键功能，包括基于接口的远程调用，容错和负载平衡以及自动服务注册和发现。

• Dubbo功能分析

• 

• 调用功能指责

  • 服务容器负责启动，加载，运行服务提供者

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

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

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

  • 服务消费者，从提供者地址列表中，基于软负载均衡算法，选一台提供者进行调用，如果调用失败，再选另一台调用。

    • 软负载均衡区分于硬负载均衡（例如F5硬负均衡器），是一种基于软件实现的负载均衡(例如:nginx负载均衡)

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

    • map(调用id，times) map(调用id,int)，防止于集装箱进行汇总再上报到注册中心

三、ZooKeeper是什么？

• Zookeeper是什么？

  • ZooKeeper是一种集中式服务，用于维护配置信息，命名，提供分布式同步和提供组服务

• Zookeeper在Dubbo中的主要功能

  • 当提供者出现断电等异常停机时，注册中心能自动删除提供者信息。

  • 当注册中心重启时，能自动恢复注册数据，以及订阅请求。

  • 当会话过期时，能自动恢复注册数据，以及订阅请求。

  • 当设置<dubbo:registry check="false" />时，记录失败注册和订阅请求，后台定时重试。

• 

四、ZooKeeper的搭建

下载

配置在“conf”目录下，新建一个名为“zoo.cfg”的文件，其中内容如下：

tickTime=2000  
dataDir= /usr/local/zookeeper/data  (填写自己的data目录)  
dataLogDir=/usr/local/zookeeper/logs  
clientPort=2181

ZooKeeper启动

sudo ./bin/zkServer.sh start

检查启动端口

netstat -an|grep 2181

• 参数解析

  • tickTime：以毫秒为单位，这个时间作为 Zookeeper 服务器之间或客户端之间维持心跳的时间间隔

  • dataDir：存储内存中数据库快照的位置，顾名思义就是 Zookeeper 保存数据的目录，默认情况下，Zookeeper 将写数据的日志文件也保存到这个目录里

  • clientPort：这个端口就是客户端连接 Zookeeper 服务器的端口，Zookeeper 会监听这个端口，接受客户

  • 端的访问请求