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