摘要：客户端对象字节输出流请求对象响应对象增加协议头发送请求获得请求后的状态码三该类实现了接口，是创建的工厂类。该类的实现跟类类似，但是是标准的接口调用会采用的工厂类，而是的协议调用。
远程调用——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.属性
