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 属性指定使?的注册中?
dubbo:protocol
服务提供者协议配置。对应的配置类:com.alibaba.dubbo.config.ProtocolConfig,同时, 如
果需要?持多协议, 可以声明多个 <dubbo:protocol> 标签, 并在 <dubbo:service> 中通过
protocol 属性指定使?的协议
dubbo:service
服务提供者暴露服务配置。对应的配置类:com.alibaba.dubbo.config.ServiceConfig
dubbo:reference
服务消费者引?服务配置。对应的配置类: com.alibaba.dubbo.config.ReferenceConfig
dubbo:monitor
dubbo:module
模块信息配置。 对应的配置类 com.alibaba.dubbo.config.ModuleConfig
dubbo:provider
服务提供者缺省值配置。 对应的配置类: com.alibaba.dubbo.config.ProviderConfig 。 同时
该标签为 <dubbo:service>和 <dubbo:protocol> 标签的缺省值设置。
dubbo:consumer服务消费者缺省值配置。
配置类: com.alibaba.dubbo.config.ConsumerConfig 。 同时
该标签为 <dubbo:reference> 标签的缺省值设置。
dubbo:method
?法级配置。 对应的配置类: com.alibaba.dubbo.config.MethodConfig 。 同时该标签
为 <dubbo:service> 或<dubbo:reference> 的?标签, ?于控制到?法级。
Multicast 注册中心
配置
原文地址:https://www.cnblogs.com/liu1459310172/p/9918231.html