資訊專欄INFORMATION COLUMN
摘要：客戶端對象字節輸出流請求對象響應對象增加協議頭發送請求獲得請求后的狀態碼三該類實現了接口，是創建的工廠類。該類的實現跟類類似，但是是標準的接口調用會采用的工廠類，而是的協議調用。
遠程調用——hessian協議
目標：介紹遠程調用中跟hessian協議相關的設計和實現，介紹dubbo-rpc-hessian的源碼。前言
本文講解多是dubbo集成的第二種協議，hessian協議，Hessian 是 Caucho 開源的一個 RPC 框架，其通訊效率高于 WebService 和 Java 自帶的序列化。dubbo集成hessian所提供的hessian協議相關介紹可以參考官方文檔，我就不再贅述。
文檔地址：http://dubbo.apache.org/zh-cn...源碼分析 （一）DubboHessianURLConnectionFactory
該類繼承了HessianURLConnectionFactory類，是dubbo，用于創建與服務器的連接的內部工廠，重寫了父類中open方法。
public class DubboHessianURLConnectionFactory extends HessianURLConnectionFactory {
/**
* 打開與HTTP服務器的新連接或循環連接
* @param url
* @return
* @throws IOException
*/
@Override
public HessianConnection open(URL url) throws IOException {
// 獲得一個連接
HessianConnection connection = super.open(url);
// 獲得上下文
RpcContext context = RpcContext.getContext();
for (String key : context.getAttachments().keySet()) {
// 在http協議頭里面加入dubbo中附加值，key為 header+key value為附加值的value
connection.addHeader(Constants.DEFAULT_EXCHANGER + key, context.getAttachment(key));
}
return connection;
}
}
在hessian上加入dubbo自己所需要的附加值，放到協議頭里面進行發送。
（二）HttpClientConnection該類是基于HttpClient封裝來實現HessianConnection接口，其中邏輯比較簡單。
public class HttpClientConnection implements HessianConnection {
/**
* http客戶端對象
*/
private final HttpClient httpClient;
/**
* 字節輸出流
*/
private final ByteArrayOutputStream output;
/**
* http post請求對象
*/
private final HttpPost request;
/**
* http 響應對象
*/
private volatile HttpResponse response;
public HttpClientConnection(HttpClient httpClient, URL url) {
this.httpClient = httpClient;
this.output = new ByteArrayOutputStream();
this.request = new HttpPost(url.toString());
}
/**
* 增加協議頭
* @param key
* @param value
*/
@Override
public void addHeader(String key, String value) {
request.addHeader(new BasicHeader(key, value));
}
@Override
public OutputStream getOutputStream() throws IOException {
return output;
}
/**
* 發送請求
* @throws IOException
*/
@Override
public void sendRequest() throws IOException {
request.setEntity(new ByteArrayEntity(output.toByteArray()));
this.response = httpClient.execute(request);
}
/**
* 獲得請求后的狀態碼
* @return
*/
@Override
public int getStatusCode() {
return response == null || response.getStatusLine() == null ? 0 : response.getStatusLine().getStatusCode();
}
@Override
public String getStatusMessage() {
return response == null || response.getStatusLine() == null ? null : response.getStatusLine().getReasonPhrase();
}
@Override
public String getContentEncoding() {
return (response == null || response.getEntity() == null || response.getEntity().getContentEncoding() == null) ? null : response.getEntity().getContentEncoding().getValue();
}
@Override
public InputStream getInputStream() throws IOException {
return response == null || response.getEntity() == null ? null : response.getEntity().getContent();
}
@Override
public void close() throws IOException {
HttpPost request = this.request;
if (request != null) {
request.abort();
}
}
@Override
public void destroy() throws IOException {
}
（三）HttpClientConnectionFactory
該類實現了HessianConnectionFactory接口，是創建HttpClientConnection的工廠類。該類的實現跟DubboHessianURLConnectionFactory類類似，但是DubboHessianURLConnectionFactory是標準的Hessian接口調用會采用的工廠類，而HttpClientConnectionFactory是Dubbo 的 Hessian 協議調用。當然Dubbo 的 Hessian 協議也是基于http的。
public class HttpClientConnectionFactory implements HessianConnectionFactory {
/**
* httpClient對象
*/
private final HttpClient httpClient = new DefaultHttpClient();
@Override
public void setHessianProxyFactory(HessianProxyFactory factory) {
// 設置連接超時時間
HttpConnectionParams.setConnectionTimeout(httpClient.getParams(), (int) factory.getConnectTimeout());
// 設置讀取數據時阻塞鏈路的超時時間
HttpConnectionParams.setSoTimeout(httpClient.getParams(), (int) factory.getReadTimeout());
}
@Override
public HessianConnection open(URL url) throws IOException {
// 創建一個HttpClientConnection實例
HttpClientConnection httpClientConnection = new HttpClientConnection(httpClient, url);
// 獲得上下文，用來獲得附加值
RpcContext context = RpcContext.getContext();
// 遍歷附加值，放入到協議頭里面
for (String key : context.getAttachments().keySet()) {
httpClientConnection.addHeader(Constants.DEFAULT_EXCHANGER + key, context.getAttachment(key));
}
return httpClientConnection;
}
}
實現了兩個方法，第一個方法是給http連接設置兩個參數配置，第二個方法是創建一個連接。
（四）HessianProtocol該類繼承了AbstractProxyProtocol類，是hessian協議的實現類。其中實現類基于hessian協議的服務引用、服務暴露等方法。
1.屬性
