hessian 服務端源碼分析

　　我們在回頭看看 web.xml 中 servlet 配置

　　<servlet>

　　　　<servlet-name>HelloHessian</servlet-name>

　　　　<servlet-class>com.caucho.hessian.server.HessianServlet</servlet-class>

　　　　<init-param>

　　　　　　<param-name>service-class</param-name>

　　　　　　<param-value>com.hessian.server.HelloHessianImpl</param-value>

　　　　</init-param>

　　</servlet>

　　服務端HessianServlet 處理hessian 請求 ，HessianServlet 繼承HttpServlet， 每個servlet有兩個重要的方法 init 和 service

1、void init(ServletConfig config) 初始化遠程服務實現類、遠程服務接口類以及HessianSkeleton

a、初始化遠程服務實現類， home-class 、service-class

?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);

}

?

b 、初始化遠程服務接口

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();

}

?

c 、初始化 HessianSkeleton

_homeSkeleton = new HessianSkeleton(_homeImpl, _homeAPI);

// 取服務類的方法

Method []methodList = apiClass.getMethods()

// 遍歷 服務類的方法，放入_methodMap

for (int i = 0; i < methodList.length; i++) {

Method method = methodList[i];

Class []param = method.getParameterTypes();

String mangledName = method.getName() + "__" + param.length;

_methodMap.put(method.getName(), methodList[i]);

_methodMap.put(mangledName, methodList[i]);

_methodMap.put(mangleName(method, false), methodList[i]);

}

hessian 支持重載處理，關鍵點： 比如對于一個方法 public void sayHello(User user)， 那么在_methodMap中會存放三個key sayHello sayHello_1, sayHello_User

?

?

2、service(ServletRequest request, ServletResponse response) 重寫父類的service 方法

2.1、 檢查請求方式是否為POST

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

　　res.setStatus(500); // ?"Hessian Requires POST"

　　?return;

}

2.2、獲取輸入輸出流、對象的序列化工廠 執行目標目標服務方法

ServletInputStream e = request.getInputStream();

ServletOutputStream os = response.getOutputStream();

SerializerFactory serializerFactory = this.getSerializerFactory();

hessianSkeleton.invoke(is, os, serializerFactory)

?

hessianServlet 處理請求時序圖

?

?

HessianSkeleton invoke 方法解析：

　　public void invoke(Object service,AbstractHessianInput in,AbstractHessianOutput out){

　　//讀取方法調用名

　　String methodName = in.readMethod();

　　int argLength = in.readMethodArgLength();

　　Method method = this.getMethod(methodName + "_" + argLength);

　　 //讀取調用方法參數

　　 Class[] args = method.getParameterTypes();

　　 Object[] values = new Object[args.length];

? ? ? for(int i= 0; i < args.length; ++i) {

　　　　 values[i] = in.readObject(args[i]);

　　 }

　　//執行目標方法調用

? ? ?result = method.invoke(service, values)

? ? ?//結果輸出

? ? out.writeReply(result);

? ? out.close();

?

? ? ? 輸出格式：

? ??

? ? ??此處為16進制數表示

? ? ? 72 01 00 53 00 05 74 69 67 65 72 7A

? ? ? ?r ? ? ? ? ? ?s ? ? ? ? ? ? ?t ? i ? g ? ?e ? r ? z?

?

轉載于:https://www.cnblogs.com/wwg168/p/6337067.html

總結

以上是生活随笔為你收集整理的hessian原理解析二(服务端分析)的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。