Hessian實現RPC通訊

阿新 • • 發佈：2019-01-15

RPC即遠端程式呼叫

RPC（Remote Procedure Call）—遠端過程呼叫，它是一種通過網路從遠端計算機程式上請求服務，而不需要了解底層網路技術的協議。RPC協議假定某些傳輸協議的存在，如TCP或UDP，為通訊程式之間攜帶資訊資料。在OSI網路通訊模型中，RPC跨越了傳輸層和應用層。RPC使得開發包括網路分散式多程式在內的應用程式更加容易。

RPC採用客戶機/伺服器模式。請求程式就是一個客戶機，而服務提供程式就是一個伺服器。首先，客戶機呼叫程序傳送一個有程序引數的呼叫資訊到服務程序，然後等待應答資訊。在伺服器端，程序保持睡眠狀態直到呼叫資訊到達為止。當一個呼叫資訊到達，伺服器獲得程序引數，計算結果，傳送答覆資訊，然後等待下一個呼叫資訊，最後，客戶端呼叫程序接收答覆資訊，獲得程序結果，然後呼叫執行繼續進行。

Hessian是一個輕量級的RPC框架

它基於HTTP協議傳輸，使用Hessian二進位制序列化，對於資料包比較大的情況比較友好。

但是它的引數和返回值都需要實現Serializable介面。

說說hessian到底幹了寫什麼吧

客戶端

1.通過HessianProxyFactory生成代理物件，轉發請求，等待server端迴應

2.將方法以及引數都Serialized序列化，傳給server端

3.因為使用的是http協議，可新增許可權驗證

流程圖

首先建立HessianProxyFacotry物件，構造方法中建立了一個HessianProxyResolver物件，這個物件的lookup方法將用來查詢遠端服務。此外HessianProxyFacotry還有包括許可權驗證方面的支援。

建立了factory之後，接下來就是通過Class物件和遠端服務的URL建立代理物件了。

HessianProxyFactory使用HessianProxy物件作為代理的Handler，也就是說，我們對代理物件的所有操作，都會由這個handler來處理。handler的invoke方法，在進行一些方法名和引數的確認之後，建立HttpURLConnection物件，呼叫sendRequest方法，將方法名和引數用HessianOutput物件(設定序列化的方式)的call方法，寫入到服務端。

protected URLConnection sendRequest(String methodName, Object []args)

throws IOException

{

URLConnection conn = null;

conn = _factory.openConnection(_url);

// Used chunked mode when available, i.e. JDK 1.5.

if (_factory.isChunkedPost() && conn instanceof HttpURLConnection) {

try {

    HttpURLConnection httpConn = (HttpURLConnection) conn;

    httpConn.setChunkedStreamingMode(8 * 1024);

      } catch (Throwable e) { }

}

addRequestHeaders(conn);

OutputStream os = null;

try {

os = conn.getOutputStream();

} catch (Exception e) {

throw new HessianRuntimeException(e);

}

try {

if (log.isLoggable(Level.FINEST)) {

PrintWriter dbg = new PrintWriter(new LogWriter(log));

os = new HessianDebugOutputStream(os, dbg);

}

AbstractHessianOutput out = _factory.getHessianOutput(os);

out.call(methodName, args);

out.flush();

return conn;

} catch (IOException e) {

if (conn instanceof HttpURLConnection)

((HttpURLConnection) conn).disconnect();

throw e;

} catch (RuntimeException e) {

if (conn instanceof HttpURLConnection)

((HttpURLConnection) conn).disconnect();

throw e;

}

}

服務端拿到請求，進行反序列化，然後將方法呼叫，再將結果序列化之後寫回到connection。所以，客戶端在sendRequest之後，所要做的就是將返回的結果進行解析，看返回的code是不是200：

conn = sendRequest(mangleName, args);

if (conn instanceof HttpURLConnection) {

httpConn = (HttpURLConnection) conn;

int code = 500;

try {

code = httpConn.getResponseCode();

} catch (Exception e) {

}

parseResponseHeaders(conn);

if (code != 200) {

StringBuffer sb = new StringBuffer();

int ch;

.....

AbstractHessianInput in = _factory.getHessianInput(is);

in.startReply();

Object value = in.readObject(method.getReturnType());

if (value instanceof InputStream) {

value = new ResultInputStream(httpConn, is, in, (InputStream) value);

is = null;

httpConn = null;

}

else in.completeReply();

return value;

解析HessianInput物件，並且從中讀取到結果返回。

伺服器端

1.初始化的時候生成一個HessianServle，在init（）的時候生成methodMap；

2.service（）方法會呼叫 _objectSkeleton.invoke(）實現方法的執行

3.寫會到客戶端

流程圖

我們所有的工作都圍繞在HessianServlet在展開。該Servlet中有兩個比較重要的方法：init()、service();

init方法初始化服務和服務物件，主要分為3步：

通過home-class或者service-class建立服務端的實現類例項；

if (_homeImpl != null) { }

else if (getInitParameter("home-class") != null) {

    String className = getInitParameter("home-class");

    Class homeClass = loadClass(className);

    _homeImpl = homeClass.newInstance();

    init(_homeImpl);

}

else if (getInitParameter("service-class") != null) {

      String className = getInitParameter("service-class");

    Class homeClass = loadClass(className);

      _homeImpl = homeClass.newInstance();

      init(_homeImpl);

}

else {

if (getClass().equals(HessianServlet.class))

throw new ServletException("server must extend HessianServlet");

_homeImpl = this;

}

通過home-api或者api-class載入實現類的介面物件；

if (_homeAPI != null) { }

else if (getInitParameter("home-api") != null) {

    String className = getInitParameter("home-api");

      _homeAPI = loadClass(className);

}

else if (getInitParameter("api-class") != null) {

      String className = getInitParameter("api-class");

      _homeAPI = loadClass(className);

}

else if (_homeImpl != null) _homeAPI = _homeImpl.getClass();

init方法還會建立HessianSkeleton物件，這是Hessian服務端的核心功能部分。

HessianSkeleton繼承自AbstractSkeleton，其構造方法，將會從實現類中抽取方法和方法的Method物件，並且儲存到_methodMap中。

對於一個Servlet來說其service方法是對外提供服務的方法：

public void service(ServletRequest request, ServletResponse response)

throws IOException, ServletException

{

HttpServletRequest req = (HttpServletRequest) request;

HttpServletResponse res = (HttpServletResponse) response;

if (! req.getMethod().equals("POST")) {

res.setStatus(500, "Hessian Requires POST");

PrintWriter out = res.getWriter();

res.setContentType("text/html");

out.println("Hessian Requires POST");

return;

}

String serviceId = req.getPathInfo();

String objectId = req.getParameter("id");

if (objectId == null)

objectId = req.getParameter("ejbid");

ServiceContext.begin(req, serviceId, objectId);

try {

InputStream is = request.getInputStream();

OutputStream os = response.getOutputStream();

HessianInput in = new HessianInput(is);

HessianOutput out = new HessianOutput(os);

if (objectId != null)

_objectSkeleton.invoke(in, out);

else _homeSkeleton.invoke(in, out);

} catch (RuntimeException e) {

throw e;

} catch (ServletException e) {

throw e;

} catch (Throwable e) {

throw new ServletException(e);

} finally {

ServiceContext.end();

}

}

最主要的是呼叫HessianSkeleton物件的invoke方法。注意，Servlet例項中有兩個HessianSkeleton變數，分別是：_objectSkeleton和 _homeSkeleton，呼叫誰，是由objectid決定的。

invoke方法：

首先從HessianInput物件中獲取到Method資訊，獲取到真正的service物件。

根據反射機制，呼叫service物件的invoke方法，獲取到返回值。

最後呼叫HessianOutput物件將結果寫回到呼叫方。

Spring也為Hessian提供了很友好的支援，通過使用spring-remoting包，我們可以很方便地釋出和呼叫服務。

最原始的實現，我們的服務是通過Servlet來繫結的，而Spring的實現，我們使用了SpringMVC的載入時機，將配置檔案載入。HessianServiceExporter

public classHessianServiceExporterextendsRemoteExporterimplementsHttpRequestHandler,InitializingBean{....}

這個類實現了InitializingBean介面，這是spring-beans包中很重要的一個擴充套件介面。

這個介面的說明如下：

Interface to be implemented by beans that need to react once all their properties have been set by a BeanFactory: for example, to perform custom initialization, or merely to check that all mandatory properties have been set.

也就是說，它會隨著Spring容器(此處為Spring MVC容器)的啟動而被載入。看看HessianServiceExporter的實現：

public void prepare() {

HessianSkeleton skeleton = null;

try {

try {

Constructor ctor = (class$com$caucho$hessian$server$HessianSkeleton == null?(class$com$caucho$hessian$server$HessianSkeleton = class$("com.caucho.hessian.server.HessianSkeleton")) : class$com$caucho$hessian$server$HessianSkeleton).getConstructor(new Class[]{class$java$lang$Object == null?(class$java$lang$Object = class$("java.lang.Object")):class$java$lang$Object, class$java$lang$Class == null?(class$java$lang$Class = class$("java.lang.Class")):class$java$lang$Class});

this.checkService();

this.checkServiceInterface();

skeleton = (HessianSkeleton)ctor.newInstance(new Object[]{this.getProxyForService(), this.getServiceInterface()});

} catch (NoSuchMethodException var4) {

Constructor ctor = (class$com$caucho$hessian$server$HessianSkeleton == null?(class$com$caucho$hessian$server$HessianSkeleton = class$("com.caucho.hessian.server.HessianSkeleton")):class$com$caucho$hessian$server$HessianSkeleton).getConstructor(new Class[]{class$java$lang$Object == null?(class$java$lang$Object = class$("java.lang.Object")):class$java$lang$Object});

skeleton = (HessianSkeleton)ctor.newInstance(new Object[]{this.getProxyForService()});

}

} catch (Throwable var5) {

throw new BeanInitializationException("Hessian skeleton initialization failed", var5);

}

if(hessian2Available) {

this.skeletonInvoker = new Hessian2SkeletonInvoker(skeleton, this.serializerFactory);

} else {

this.skeletonInvoker = new Hessian1SkeletonInvoker(skeleton, this.serializerFactory);

}

}

public void handleRequest(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {

Assert.notNull(this.skeletonInvoker, "HessianServiceExporter has not been initialized");

if(!"POST".equals(request.getMethod())) {

throw new HttpRequestMethodNotSupportedException("POST", "HessianServiceExporter only supports POST requests");

} else {

try {

this.skeletonInvoker.invoke(request.getInputStream(), response.getOutputStream());

} catch (Throwable var4) {

throw new NestedServletException("Hessian skeleton invocation failed", var4);

}

}

}

在prepare方法中，獲取service和serviceInterface的配置，建立HessianSkeleton物件。

同時，還實現了HttpRequestHandler，spring-web中的介面。

又因為實現了HttpRequestHandler介面，所以在handleRequest方法中，可以像HessianServlet的service方法一樣，呼叫Hessian2SkeletonInvoker的invoke方法進行實際的方法呼叫。

spring boot 中Hessian的配置就不多言，Demo就是一個小例子

Hessian實現RPC通訊

Hessian實現RPC通訊

Java通過Hadoop實現RPC通訊簡單例項

用AKKA實現簡單的RPC通訊模型2

RabbitMq初探——用隊列實現RPC

Python-RabbitMQ消息隊列實現rpc

RocketMQ(二)：RPC通訊

PHP + Redis 訂閱/發布實現即時通訊功能

java 實現udp通訊

徒手擼框架--實現 RPC 遠程調用

Spark內建框架rpc通訊機制及RpcEnv基礎設施-Spark商業環境實戰

一個簡單RPC框架是如何煉成的(IV)——實現RPC訊息的編解碼

Rabbitmq中的RPC通訊機制

golang和c通過unix域實現雙向通訊

Java以GET和POST方式實現HTTP通訊

mqtt協議實現即時通訊-activemq nginx.支援JS,JAVA,微信小程式

RPC 通訊和 RMI 區別

Websocket實現前後臺通訊，demo小測試

用udp實現廣播通訊

Http與RPC通訊協議的比較

ubuntu16.04下ROS作業系統學習（四 / 三）ROS基礎-實現分散式通訊

Hessian實現RPC通訊

相關推薦