dubbo的初探

时间：2018-11-06 22:27:15 阅读：240 评论：0 收藏：0 [点我收藏+]

1.RPC 基本概念
1.1 RPC 协议(Remote Procedure Call Protocol)
远程过程调用协议，它是一种通过网络从远程计算机程序上请求服务，而不需要了解底层网络技术的协议。RPC 协议假定某些传输协议的存在，如 TCP 或 UDP，为通信程序之间携
带信息数据。在 OSI 网络通信模型中，RPC 跨越了传输层和应用层。RPC 使得开发包括网络分布式程序在内的应用程序更加容易。
RPC 采用客户机/服务器模式。请求程序就是一个客户机，而服务提供程序就是一个务器。首先，客户机调用进程发送一个有进程参数的调用信息到服务进程，然后等待应答信息。在服务器端，进程保持睡眠状态直到调用信息到达为止。当一个调用信息到达，服务器获得进程参数，计算结果，发送答复信息，然后等待下一个调用信息，最后，客户端调用进
程接收答复信息，获得进程结果，然后调用执行继续进行。

1.2 RPC 框架
在单机时代一台电脑运行多个进程，进程之间无法通讯，显然这会浪费很多资源，因此后来出现 IPC(Inter-process communication：单机中运行的进程之间的相互通信 )，这样就
能允许进程之间进行通讯，比如在一台计算机中的 A 进程写了一个吃饭的方法，那在以前如果在 B 进程中也要有一个吃饭的方法，必须要在 B 进程中进行创建，但有了 RPC 后 B 只需
要调用 A 进程的程序即可完成，再到后来网络时代的出现，大家电脑都连起来，这时可不可以调用其他电脑上的进程呢，当然可以，这样 RPC 框架就出现了。严格意义上来讲：Uni的生态系统中 RPC 可以在同一台电脑上不同进程进行，也可以在不同电脑上进行；而在windows 里面同一台电脑上不同进程间的通讯还可以采用 LPC(本地访问)。综上：RPC 或 LPC
是上层建筑，IPC 是底层基础。RPC 框架有很多：比如 Thrift、dubbo、grpc 等。

1.3 RPC 与与 HTTP 、TCP 、UDP 、Socket 的区别
TCP/UDP: 都是传输协议，主要区别是 tcp 协议连接需要 3 次握手，断开需要四次挥手，是通过流来传输的，就是确定连接后，一直发送信息，传完后断开。udp 不需要进行连接，
直接把信息封装成多个报文，直接发送。所以 udp 的速度更快写，但是不保证数据的完整性。
Http：超文本传输协议是一种应用层协议，建立在 TCP 协议之上Socket：是在应用程序层面上对 TCP/IP 协议的封装和应用。其实是一个调用接口，方便程序员使用 TCP/IP 协议栈而已。程序员通过 socket 来使用 tcp/ip 协议。但是 socket 并不是一定要使用 tcp/ip 协议，Socket 编程接口在设计的时候，就希望也能适应其他的网络协议。
小结：我们把网络传输类比于一条公路，那 TCP/UDP 就是货车，HTTP 就是货物，而 socket就是发动机。
RPC 是一种通过网络从远程计算机程序上请求服务，而不需要了解底层网络技术的协议。所以 RPC 的实现可以通过不同的协议去实现比如可以使 http、RMI 等。

1.4 RPC 的运行流程
首先，要解决通讯的问题，主要是通过在客户端和服务器之间建立 TCP 连接，远程过程调用的所有交换的数据都在这个连接里传输。连接可以是按需连接，调用结束后就断掉，也
可以是长连接，多个远程过程调用共享同一个连接。

第二，要解决寻址的问题，也就是说，A 服务器上的应用怎么告诉底层的 RPC 框架，如何连接到 B 服务器（如主机或 IP 地址）以及特定的端口，方法的名称名称是什么，这样才能完成调用。比如基于Web服务协议栈的RPC，就要提供一个endpoint URI，或者是从UDDI(一种目录服务，通过该目录服务进行服务注册与搜索)服务上查找。如果是 RMI 调用的话，还需要一个 RMI Registry 来注册服务的地址。
第三，当 A 服务器上的应用发起远程过程调用时，方法的参数需要通过底层的网络协议如 TCP 传递到 B 服务器，由于网络协议是基于二进制的，内存中的参数的值要序列化成二
进制的形式，也就是序列化（Serialize）或编组（marshal），通过寻址和传输将序列化的二进制发送给 B 服务器。

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

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

技术分享图片

JAVAEE 里面的 stub 是为屏蔽客户调用远程主机上的对象，必须提供某种方式来模拟本地对象,这种本地对象称为存根(stub),存根负责接收本地方法调用,并将它们委派给各自的具
体实现对象
Skeleton：服务器的骨架

1.5 RPC 基于 RMI 的的简单实现

技术分享图片

2.Dubbo
2.1 框架基本概念

Dubbo 是由阿里巴巴开源的一个高性能、基于 Java 开源的远程调用框架。正如在许多RPC 系统中一样，dubbo 是基于定义服务的概念，指定可以通过参数和返回类型远程调用的方法。在服务器端，服务器实现这个接口，并运行一个 dubbo 服务器来处理客户端调用。在客户端，客户机有一个存根，它提供与服务器相同的方法。

技术分享图片

Dubbo 提供三个核心功能：基于接口的远程调用、容错和负载均衡，以及服务的自动注册与发现。Dubbo 框架广泛的在阿里巴巴内部使用，以及京东、当当、去哪儿、考拉等都在
使用。

2.2 Dubbo 快速入门
2.2.1 系统要求
jdk1.6 以上和 maven3.0 以上，采用 maven 分模块构建 api 模块，provider
模块以及 consumer 模块
2.2.2 导包 Dubbo的坐标

技术分享图片

2.2.3 定义服务接口
由于服务的生产者和消费者都会依赖这个接口，因此强烈建议把这个接口定义在一个独立的模块，然后由生产者模块和消费者模块各自依赖即可

技术分享图片

2.3.4

技术分享图片

2.3.5 配置生产者
将服务接口进行发布 dubbo-demo-provider.xml 服务接口的发布，推荐使用spring 集成配置

<?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/bea
ns http://www.springframework.org/schema/beans/spring-
beans.xsd http://code.alibabatech.com/schema/dubbo
http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
<dubbo:application name="demo-provider"/>
<dubbo:registry address="multicast://224.5.6.7:1234"/>
<dubbo:protocol name="dubbo" port="20880"/>
<dubbo:service interface="com.shsxt.service.DemoService"
ref="demoService"/>
<bean id="demoService" class="
com.shsxt.impl.DemoServiceImpl"/>
</beans>

2.3.6 启动服务提供程序

public class Provider {
public static void main(String[] args) throws Exception {
ClassPathXmlApplicationContext context = new
ClassPathXmlApplicationContext(
new String[] {"classpath:dubbo-demo-
provider.xml"});
context.start();
System.in.read(); // press any key to exit
}
}

2.3.7配置服务的消费端

消费端配置 dubbo-demo-consumer.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/bea
ns http://www.springframework.org/schema/beans/spring-
beans.xsd http://code.alibabatech.com/schema/dubbo
http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
<dubbo:application name="demo-consumer"/>
<dubbo:registry address="multicast://224.5.6.7:1234"/>
<dubbo:reference id="demoService" interface="
com.shsxt.service.DemoService"/>
</beans>

2.3.8 启动服务消费端进行消费

public class Consumer {
public static void main(String[] args) throws Exception {
ClassPathXmlApplicationContext context = new
ClassPathXmlApplicationContext(
new String[]{"classpath:dubbo-demo-
consumer.xml"});
context.start();
DemoService demoService = (DemoService)
context.getBean("demoService"); // obtain proxy object for
remote invocation
String hello = demoService.sayHello("world"); //
execute remote invocation

System.out.println(hello); // show the result
}
}

3.Dubbo schema配置

技术分享图片

https://dubbo.gitbooks.io/dubbo-user-book/configuration/xml.html

Dubbo 配置项说明

dubbo:application

应?信息配置。对应的配置类:com.alibaba.dubbo.config.ApplicationConfig

技术分享图片

dubbo:registry

注册中?配置。对应的配置类： com.alibaba.dubbo.config.RegistryConfig。同时如果有多
个不同的注册中?, 可以声明多个 <dubbo:registry> 标签 ,并在 <dubbo:service> 或
<dubbo:reference> 的 registry 属性指定使?的注册中?

技术分享图片