一、概念和原理
rpc（remote procedure call），遠程過程調用，是客戶端應用和服務端之間的會話。在客戶端，它所需要的一些功能并不在該應用的實現范圍之內，所以應用要向提供這些功能的其他系統尋求幫助。而遠程應用通過遠程服務暴露這些功能。rpc 是同步操作，會阻塞調用代碼的執行，直到被調用的過程執行完畢。
spring支持多種不同的rpc模型，包括rmi、caucho的hessian和burlap以及spring自帶的http invoker：
客戶端：
在所有的模型中，服務都是作為 spring 所管理的 bean 配置到我們的應用中。這是通過一個代理工廠 bean 實現的，這個bean能夠把遠程服務像本地對象一樣裝配到其他bean的屬性中。
客戶端向代理發起調用，就像代理提供了這些服務一樣。代理代表客戶端和遠程服務進行通信，由它負責處理連接的細節并向遠程服務發起調用。
服務端：
spring 使用遠程導出器（remote exporter）將bean方法發布為遠程服務。
二、rmi
rmi 最初在jdk 1.1被引入到java平臺中，它為java開發者提供了一種強大的方法來實現java程序間的交互。
spring 提供了簡單的方式來發布rmi服務，在服務端，rmiserviceexporter 可以把任何 spring 管理的bean發布為rmi服務 ，如圖所示，rmiserviceexporter 把bean包裝在一個適配器類中，然后適配器類被綁定到rmi注冊表中，并且代理到服務類的請求。
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
|
/** * 服務端： * <p> * 1、默認情況下，rmiserviceexporter 會嘗試綁定到本地機器1099端口上的rmi注冊表。 * 2、如果在這個端口沒有發現rmi注冊表，rmiserviceexporter 將會啟動一個注冊表。 * 3、可重寫注冊表的路徑和端口，這個是個大坑，當你設置了registryhost屬性的時候，源碼中就不創建registry，而是直接去獲取，可是我們自己也沒有創建，所以就會報連接不上。 * * @param userservice * @return */ @bean(name = "rmiserviceexporter") public rmiexporter rmiserviceexporter(userservice userservice, environment environment) { string registryhost = environment.getproperty("registryhost"); int registryport = environment.getproperty("registryport", integer.class); rmiexporter rmiexporter = new rmiexporter(); rmiexporter.setservice(userservice); //要把該bean(即rmiserviceimpl)發布為一個rmi服務 rmiexporter.setservicename("rmiservice"); //命名rmi 服務 rmiexporter.setserviceinterface(userservice.class); //指定服務所實現的接口 rmiexporter.setregistryhost(registryhost); rmiexporter.setregistryport(registryport); return rmiexporter; } |
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
|
/** * created by xiuyin.cui on 2018/5/14. * * 解決設置 registryhost 后，報連接拒絕的問題。 */public class rmiexporter extends rmiserviceexporter { @override protected registry getregistry(string registryhost, int registryport, rmiclientsocketfactory clientsocketfactory, rmiserversocketfactory serversocketfactory) throws remoteexception { if (registryhost != null) { try { if (logger.isinfoenabled()) { logger.info("looking for rmi registry at port '" + registryport + "' of host [" + registryhost + "]"); } //把spring源代碼中這里try起來，報異常就創建一個 registry reg = locateregistry.getregistry(registryhost, registryport, clientsocketfactory); testregistry(reg); return reg; } catch (remoteexception ex) { locateregistry.createregistry(registryport); registry reg = locateregistry.getregistry(registryhost, registryport, clientsocketfactory); testregistry(reg); return reg; } } else { return getregistry(registryport, clientsocketfactory, serversocketfactory); } }} |
接下來，來看看客戶端是怎么使用這些遠程服務的吧！spring的rmiproxyfactorybean是一個工廠bean，該bean可以為rmi服務創建代理。該代理代表客戶端來負責與遠程的rmi服務進行通信。客戶端通過服務的接口與代理進行交互，就如同遠程服務就是一個本地的pojo。
|
1
2
3
4
5
6
7
8
9
10
|
@bean(name = "rmiuserserviceclient") public rmiproxyfactorybean rmiuserserviceclient(){ rmiproxyfactorybean rmiproxyfactorybean = new rmiproxyfactorybean(); rmiproxyfactorybean.setserviceurl("rmi://127.0.0.1:9999/rmiservice"); rmiproxyfactorybean.setserviceinterface(userservice.class); rmiproxyfactorybean.setlookupstubonstartup(false);//不在容器啟動后創建與server端的連接 rmiproxyfactorybean.setrefreshstubonconnectfailure(true);//連接出錯的時候自動重連 rmiproxyfactorybean.afterpropertiesset(); return rmiproxyfactorybean; } |
|
1
2
|
@resource(name="rmiuserserviceclient") private userservice userservice; |
rmi 的缺陷：
1、rmi很難穿越防火墻，這是因為rmi使用任意端口來交互——這是防火墻通常所不允許的。
2、rmi是基于java的。這意味著客戶端和服務端必須都是用java開發。因為rmi使用了java的序列化機制，所以通過網絡傳輸的對象類型必須要保證在調用兩端的java運行時中是完全相同的版本。
tips：最近發現dubbo 底層也是用 rmi 實現的，它把 zookeeper 當作注冊表。
三、hessian 和 burlap
hessian 和 burlap 是 caucho technology 的兩種基于http的輕量級遠程服務解決方案。借助于盡可能簡單的api和通信協議，它們都致力于簡化web服務。
hessian，像rmi一樣，使用二進制消息進行客戶端和服務端的交互。但是它與rmi不同的是，它的二進制消息可以移植到其他非java的語言中。由于它是基于二進制的，所以它在帶寬上更具優勢。
burlap 是一種基于xml的遠程調用技術，這使得它可以自然而然的移植到任何能夠解析xml的語言上。正因為它基于xml，所以相比起hessian的二進制格式而言，burlap可讀性更強。但是和其他基于xml的遠程技術（例如soap或xml-rpc）不同，burlap的消息結構盡可能的簡單。
下面我們會介紹 hessian 的使用。spring 不推薦使用burlap，burlapserviceexporter 在4.0后被廢棄，不再提供支持。5.0 后直接從開發包丟棄了。
服務端，類似于 rmiserviceexporter ，hessian 也有一個hessianserviceexporter 將 spring 管理的 bean 發布為 hessian 服務，不同于rmi的是，hessianserviceexporter是一個spring mvc控制器，它接收hessian請求（http協議的請求），并將這些請求轉換成對被導出pojo的方法調用。既然是http請求，那我們就必須配置spring 的dispatcherservlet ，并配置handlermapping，將相應的url映射給hessianserviceexporter。
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
|
/** * hessian沒有注冊表，不需要設置 servicename */ @bean(name = "hessianserviceexporter") public hessianserviceexporter hessianserviceexporter(userservice userservice) { hessianserviceexporter hessianserviceexporter = new hessianserviceexporter(); hessianserviceexporter.setservice(userservice); hessianserviceexporter.setserviceinterface(userservice.class); return hessianserviceexporter; } /** * 需要配置一個url映射來確保dispatcherservlet把請求轉給hessianserviceexporter */ @bean(name = "handlermapping") public handlermapping handlermapping() { simpleurlhandlermapping handlermapping = new simpleurlhandlermapping(); properties mappings = new properties(); mappings.setproperty("/user.service", "hessianserviceexporter"); handlermapping.setmappings(mappings); return handlermapping; } |
客戶端，類似于rmiproxyfactorybean ，hessian 也有一個代理工廠bean——hessianproxyfactorybean，來創建代理與遠程服務進行通信：
|
1
2
3
4
5
6
7
|
@bean(name = "hessianuserserviceclient") public hessianproxyfactorybean hessianuserserviceclient(){ hessianproxyfactorybean proxy = new hessianproxyfactorybean(); proxy.setserviceurl("http://127.0.0.1:8080/user.service"); proxy.setserviceinterface(userservice.class); return proxy; } |
|
1
2
|
@resource(name="hessianuserserviceclient")private userservice userservice; |
hessian 的缺陷：
hessian 和 burlap 都是基于http的，它們都解決了rmi所頭疼的防火墻滲透問題。但是當傳遞過來的rpc消息中包含序列化對象時，rmi就完勝 hessian 和 burlap 了。因為 hessian 和 burlap 都采用了私有的序列化機制，而rmi使用的是java本身的序列化機制。
四、httpinvoker
rmi 和 hessian 各有自己的缺陷，一方面，rmi使用java標準的對象序列化機制，但是很難穿透防火墻。另一方面，hessian和burlap能很好地穿透防火墻，但是使用私有的對象序列化機制。就這樣，spring的http invoker應運而生了。http invoker是一個新的遠程調用模型，作為spring框架的一部分，能夠執行基于http的遠程調用，并使用java的序列化機制。
httpinvoker 的使用和 hessian 很類似，httpinvokerserviceexporter 也是一個spring mvc 控制器，也是通過dispatcherservlet 將請求分發給它...
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
|
/*http invoker*/ @bean(name = "httpinvokerserviceexporter") public httpinvokerserviceexporter httpinvokerserviceexporter(userservice userservice){ httpinvokerserviceexporter httpinvokerserviceexporter = new httpinvokerserviceexporter(); httpinvokerserviceexporter.setservice(userservice); httpinvokerserviceexporter.setserviceinterface(userservice.class); return httpinvokerserviceexporter; } /** * 需要配置一個url映射來確保dispatcherservlet把請求轉給hessianserviceexporter */ @bean(name = "handlermapping") public handlermapping handlermapping() { simpleurlhandlermapping handlermapping = new simpleurlhandlermapping(); properties mappings = new properties(); mappings.setproperty("/user.service", "hessianserviceexporter"); mappings.setproperty("/userinvoker.service", "httpinvokerserviceexporter"); handlermapping.setmappings(mappings); return handlermapping; } |
客戶端，像 rmiproxyfactorybean 和 hessianproxyfactorybean 一樣，httpinvoker 也提供了一個代理工廠bean——httpinvokerproxyfactorybean，用于創建httpinvoker代理來與遠程服務通信：
|
1
2
3
4
5
6
7
|
@bean(name = "httpinvokeruserserviceclient") public httpinvokerproxyfactorybean httpinvokeruserserviceclient(){ httpinvokerproxyfactorybean proxy = new httpinvokerproxyfactorybean(); proxy.setserviceurl("http://127.0.0.1:8080//userinvoker.service"); proxy.setserviceinterface(userservice.class); return proxy; } |
參考資料：《spring 實戰第四版》
演示源代碼鏈接：https://github.com/jmcuixy/springforrpc
以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支持服務器之家。
原文鏈接：https://www.cnblogs.com/jmcui/p/9044212.html
