RPC框架實現原理

一、什么是RPC框架?
RPC,全稱為Remote Procedure Call,即遠程過程調用,是一種計算機通信協議。
比如現在有兩臺機器:A機器和B機器,并且分別部署了應用A和應用B。假設此時位于A機器上的A應用想要調用位于B機器上的B應用提供的函數或是方法,由于A應用和B應用不在一個內存空間里面,所以不能直接調用,此時就需要通過網絡來表達調用的方式和傳輸調用的數據。也即所謂的遠程調用。
二、RPC框架的實現原理?
主要有以下幾個步驟:

1、建立通信
首先要解決通訊的問題:即A機器想要調用B機器,首先得建立起通信連接。主要是通過在客戶端和服務器之間建立TCP連接,遠程過程調用的所有相關的數據都在這個連接里面進行傳輸交換。

通常這個連接可以是按需連接(需要調用的時候就先建立連接,調用結束后就立馬斷掉),也可以是長連接(客戶端和服務器建立起連接之后保持長期持有,不管此時有無數據包的發送,可以配合心跳檢測機制定期檢測建立的連接是否存活有效),多個遠程過程調用共享同一個連接。

2、服務尋址
解決尋址的問題:即A機器上的應用A要調用B機器上的應用B,那么此時對于A來說如何告知底層的RPC框架所要調用的服務具體在哪里呢?

通常情況下我們需要提供B機器(主機名或IP地址)以及特定的端口,然后指定調用的方法或者函數的名稱以及入參出參等信息,這樣才能完成服務的一個調用。比如基于Web服務協議棧的RPC,就需要提供一個endpoint URI,或者是從UDDI服務上進行查找。如果是RMI調用的話,還需要一個RMI Registry來注冊服務的地址。

3、網絡傳輸
3.1、序列化

當A機器上的應用發起一個RPC調用時,調用方法和其入參等信息需要通過底層的網絡協議如TCP傳輸到B機器,由于網絡協議是基于二進制的,所有我們傳輸的參數數據都需要先進行序列化(Serialize)或者編組(marshal)成二進制的形式才能在網絡中進行傳輸。然后通過尋址操作和網絡傳輸將序列化或者編組之后的二進制數據發送給B機器。

3.2、反序列化
當B機器接收到A機器的應用發來的請求之后,又需要對接收到的參數等信息進行反序列化操作(序列化的逆操作),即將二進制信息恢復為內存中的表達方式,然后再找到對應的方法(尋址的一部分)進行本地調用(一般是通過生成代理Proxy去調用, 通常會有JDK動態代理、CGLIB動態代理、Javassist生成字節碼技術等),之后得到調用的返回值。

4、服務調用
B機器進行本地調用(通過代理Proxy)之后得到了返回值,此時還需要再把返回值發送回A機器,同樣也需要經過序列化操作,然后再經過網絡傳輸將二進制數據發送回A機器,而當A機器接收到這些返回值之后,則再次進行反序列化操作,恢復為內存中的表達方式,最后再交給A機器上的應用進行相關處理(一般是業務邏輯處理操作)。

通常,經過以上四個步驟之后,一次完整的RPC調用算是完成了,另外可能因為網絡抖動等原因需要重試等。

三、為什么需要RPC?
主要就是因為在幾個進程內(應用分布在不同的機器上),無法共用內存空間,或者在一臺機器內通過本地調用無法完成相關的需求,比如不同的系統之間的通訊,甚至不同組織之間的通訊。此外由于機器的橫向擴展,需要在多臺機器組成的集群上部署應用等等。

四、RPC支持哪些協議?
最早的CORBA、Java RMI, WebService方式的RPC風格, Hessian, Thrift甚至Rest API。

五、RPC的實現基礎?

1、需要有非常高效的網絡通信,比如一般選擇Netty作為網絡通信框架
2、需要有比較高效的序列化框架,比如谷歌的Protobuf序列化框架
3、可靠的尋址方式(主要是提供服務的發現),比如可以使用Zookeeper來注冊服務等等
4、如果是帶會話(狀態)的RPC調用,還需要有會話和狀態保持的功能

六、RPC調用過程?
6.1 一個基本的RPC架構里面應該至少包含以下4個組件:

1、客戶端(Client):服務調用方(服務消費者)
2、客戶端存根(Client Stub):存放服務端地址信息,將客戶端的請求參數數據信息打包成網絡消息,再通過網絡傳輸發送給服務端
3、服務端存根(Server Stub):接收客戶端發送過來的請求消息并進行解包,然后再調用本地服務進行處理
4、服務端(Server):服務的真正提供者

6.2 具體的調用過程如下:

1、服務消費者(client客戶端)通過本地調用的方式調用服務
2、客戶端存根(client stub)接收到調用請求后負責將方法、入參等信息序列化(組裝)成能夠進行網絡傳輸的消息體
3、客戶端存根(client stub)找到遠程的服務地址,并且將消息通過網絡發送給服務端
4、服務端存根(server stub)收到消息后進行解碼(反序列化操作)
5、服務端存根(server stub)根據解碼結果調用本地的服務進行相關處理
6、本地服務執行具體業務邏輯并將處理結果返回給服務端存根(server stub)
7、服務端存根(server stub)將返回結果重新打包成消息(序列化)并通過網絡發送至消費方
8、客戶端存根(client stub)接收到消息,并進行解碼(反序列化)
9、服務消費方得到最終結果

在這里插入圖片描述
而RPC框架的實現目標則是將上面的第2-10步完好地封裝起來,也就是把調用、編碼/解碼的過程給封裝起來,讓用戶感覺上像調用本地服務一樣的調用遠程服務。

七、RPC框架需要解決的問題?

1、如何確定客戶端和服務端之間的通信協議?
2、如何更高效地進行網絡通信?
3、服務端提供的服務如何暴露給客戶端?
4、客戶端如何發現這些暴露的服務?
5、如何更高效地對請求對象和響應結果進行序列化和反序列化操作?

八、使用了哪些技術?
8.1、動態代理

生成Client Stub(客戶端存根)和Server Stub(服務端存根)的時候需要用到java動態代理技術,可以使用jdk提供的原生的動態代理機制,也可以使用開源的:Cglib代理,Javassist字節碼生成技術。

8.2、序列化
在網絡中,所有的數據都將會被轉化為字節進行傳送,所以為了能夠使參數對象在網絡中進行傳輸,需要對這些參數進行序列化和反序列化操作。

序列化:把對象轉換為字節序列的過程稱為對象的序列化,也就是編碼的過程。
反序列化:把字節序列恢復為對象的過程稱為對象的反序列化,也就是解碼的過程。

目前比較高效的開源序列化框架:如Kryo、fastjson和Protobuf等。

8.3、NIO通信
出于并發性能的考慮,傳統的阻塞式 IO 顯然不太合適,因此我們需要異步的 IO,即 NIO。
Java 提供了 NIO 的解決方案,Java 7 也提供了更優秀的 NIO.2 支持。可以選擇Netty或者mina來解決NIO數據傳輸的問題。

8.4、服務注冊中心
可選:Redis、Zookeeper、Consul 、Etcd。
一般使用ZooKeeper提供服務注冊與發現功能,解決單點故障以及分布式部署的問題(注冊中心)。

本文來自互聯網用戶投稿,該文觀點僅代表作者本人,不代表本站立場。本站僅提供信息存儲空間服務,不擁有所有權,不承擔相關法律責任。
如若轉載,請注明出處:http://www.pswp.cn/news/249713.shtml
繁體地址,請注明出處:http://hk.pswp.cn/news/249713.shtml
英文地址,請注明出處:http://en.pswp.cn/news/249713.shtml

如若內容造成侵權/違法違規/事實不符,請聯系多彩編程網進行投訴反饋email:809451989@qq.com,一經查實,立即刪除!

相關文章

jQuery安裝

http://www.runoob.com/jquery/jquery-install.html 網頁中添加jQuery: 方法一:可以從http://jquery.com/download/ 下載jQuery庫 方法二:從CDN中載入jQuery 下載 jQuery 有兩個版本的 jQuery 可供下載: Production version - 用于…

redhat相關配置

網絡配置: vi /etc/sysconfig/network-scripts/ifcfg-eth BOOTPROTOstaticONBOOTyesIP配置IPADDR192.168.31.102NETMASK255.255.255.0GATEWAY192.168.31.1DNS1192.168.31.1redhat6:防火墻:1. 永久性生效開啟:chkconfig iptables o…

zookeeper入門系列

zookeeper可謂是目前使用最廣泛的分布式組件了。其功能和職責單一,但卻非常重要。 在現今這個年代,介紹zookeeper的書和文章可謂多如牛毛,本人不才,試圖通過自己的理解來介紹zookeeper,希望通過一個初學者的視角來學習…

java.lang.NumberFormatException: multiple points錯誤問題

最近項目一直會出現時間轉換報錯,一直不知道是什么問題??? java.lang.NumberFormatException: multiple pointsat sun.misc.FloatingDecimal.readJavaFormatString(FloatingDecimal.java:1110)at java.lang.Double.parseDouble(Double.java:540)at java.text.Dig…

plsql查詢數據中文亂碼

在plsql中進行表數據查詢的時候,發現查詢出來的中文居然顯示為亂碼,通過查找資料解決該問題。 1、查看數據的編碼(語句:select * from v$nls_parameters) 發現顯示的語言不是我們常用的GBK模式 2、配置本機語言環境變量…

Zookeeper的功能以及工作原理

1.ZooKeeper是什么? ZooKeeper是一個分布式的,開放源碼的分布式應用程序協調服務,是Google的Chubby一個開源的實現,它是集群的管理者,監視著集群中各個節點的狀態根據節點提交的反饋進行下一步合理操作。最終&#xf…

前端學習總結——CSS布局方式之傳統布局

傳統布局 傳統布局即是早期在平板電腦、智能手機等移動設備并不流行的時候使用的布局方式。 一、表格布局 例如&#xff1a;采用表格方式實現如下簡單模型的布局 &#xff08;1&#xff09;固定布局 即用具體的像素值來確定模型的寬和高等值。 HTML代碼如下所示 <tabl…

aspose word for java去除目錄文字藍色樣式以及文字下方藍色下劃線

//去除目錄文字藍色樣式以及文字下方藍色下劃線for(FieldStart field: (Iterable<FieldStart>)doc.getChildNodes(NodeType.FIELD_START, true)){if (field.getFieldType() FieldType.FIELD_HYPERLINK){FieldHyperlink hyperlink (FieldHyperlink)field.getField();//判…

[POI2007]MEG-Megalopolis

傳送門&#xff1a;嘟嘟嘟 第一反應是樹鏈剖分&#xff0c;但是太長懶得寫&#xff0c;然后就想出了一個很不錯的做法。 想一下&#xff0c;如果我們改一條邊&#xff0c;那么影響的只有他的子樹&#xff0c;只要先搞一個dfs序&#xff0c;為什么搞出這個呢&#xff1f;因為有一…

memcache在ThinkPHP中的使用1---PHP下安裝memcache

1.什么是Memcached緩存 Memcached是一套小巧、高效且成熟的內存數據庫。與普通的數據庫不同&#xff0c;Memcached存儲的數據只能是簡單的鍵值對&#xff0c;在查詢時需要根據存放的key獲取數據。 Memcached最大的特點是數據存放于內存&#xff0c;性能會比傳統文件系統高出…

【集合工具類:Collections】

集合工具類&#xff1a;Collections(1) 是針對集合進行操作的工具類(2) 面試題&#xff1a;Collection 和 Collections 的區別A:Collection 是單列集合的頂層接口&#xff0c;有兩個子接口 List 和 SetB:Collections 是針對集合進行操作的工具類&#xff0c;可以對集合進行排序…

骨骼收集器01背包

來源hdu2602 問題描述 許多年前&#xff0c;在泰迪的家鄉&#xff0c;有一個人被稱為“骨頭收藏家”。這個男人喜歡收集各種各樣的骨頭&#xff0c;比如狗狗&#xff0c;牛&#xff0c;還有他去了墳墓...... 骨頭收藏家有一個大容量的V袋&#xff0c;沿著他的收集之旅有很多骨頭…

ZooKeeper的安裝與部署

本文講述如何安裝和部署ZooKeeper。 一、系統要求 ZooKeeper可以運行在多種系統平臺上面&#xff0c;表1展示了zk支持的系統平臺&#xff0c;以及在該平臺上是否支持開發環境或者生產環境。 表1&#xff1a;ZooKeeper支持的運行平臺 | 系統 | 開發環境 | 生產環境| | Linux…

java基礎1之java語言基礎1

一、常量的概述和使用 A:什么是常量 * 在程序執行的過程中其值不可以發生改變 B:Java中常量的分類 * 字面值常量 * 自定義常量(面向對象部分講) C:字面值常量的分類 * 字符串常量 用雙引號括起來的內容 * 整數常量 所有整數 * 小數常量 所有小數 * 字符常量 …

w3c 跨域請求規范

w3c 官方跨域請求規范地址&#xff1a;https://www.w3.org/TR/cors/ 前段時間開發的一個api在IE8/9瀏覽器不能正常響應跨域請求&#xff0c;以下是解決問題中對跨域請求新的認識 1.復雜跨域 post請求在發送請求之前&#xff0c;會先發送options 請求&#xff0c;有的服務器拒絕…

python爬取豆瓣前25個影片內容的正則表達式練習

通過python正則表達式獲取豆瓣top250的第一頁的25個影片排名,影片名字,影片連接,導演,主演,上映日期,國家,劇情,評分,評價人數的內容 網頁html內容: 1 <ol class"grid_view">2 <li>3 <div class"item">4 …

JavaScript 面向對象的程序設計1

一、理解對象 1.創建一個對象&#xff0c;然后給這個對象新建屬性和方法。 ①常見的創建方式 var person new Object(); //創建一個Object 對象person.name XIE; //創建一個name 屬性并賦值person.age 20; //創建一個age 屬性并賦值person.sayName function () { //創建…

Zookeeper 使用

安裝和配置詳解 本文介紹的 Zookeeper 是以 3.2.2 這個穩定版本為基礎&#xff0c;最新的版本可以通過官網 http://hadoop.apache.org/zookeeper/來獲取&#xff0c;Zookeeper 的安裝非常簡單&#xff0c;下面將從單機模式和集群模式兩個方面介紹 Zookeeper 的安裝和配置。 單…

Asp.Net Core 工作單元 UnitOfWork UOW

Asp.Net Core 工作單元示例 來自 ABP UOW 去除所有無用特性 代碼下載 &#xff1a; 去除所有無用特性版本&#xff0c;原生AspNetCore實現 差不多 2278 行代碼&#xff1a; 鏈接&#xff1a;https://pan.baidu.com/s/1NoEIDSAPNr46xNHYEx9KCA 提取碼&#xff1a;570i 包含C…

網站性能優化--CRP

網站性能優化–CRP 為了把HTML、CSS和JavaScript轉化成活靈活現、絢麗多彩的網頁&#xff0c;瀏覽器需要處理一系列的中間過程&#xff0c;優化性能其實就是了解這個過程中發生了什么-即CRP(Critical Rendering Path&#xff0c;關鍵渲染路徑)。首先&#xff0c;我們從頭開始快…