Dubbo源码学习--Hession协议（四）

向右看齐 2022-05-27 06:48 183阅读 0赞

Hessian [1][] 协议用于集成 Hessian 的服务，Hessian 底层采用 Http 通讯，采用 Servlet 暴露服务，Dubbo 缺省内嵌 Jetty 作为服务器实现。

Dubbo 的 Hessian 协议可以和原生 Hessian 服务互操作，即：

*  提供者用 Dubbo 的 Hessian 协议暴露服务，消费者直接用标准 Hessian 接口调用
 *  或者提供方用标准 Hessian 暴露服务，消费方用 Dubbo 的 Hessian 协议调用。

## 特性 ##

*  连接个数：多连接
 *  连接方式：短连接
 *  传输协议：HTTP
 *  传输方式：同步传输
 *  序列化：Hessian二进制序列化
 *  适用范围：传入传出参数数据包较大，提供者比消费者个数多，提供者压力较大，可传文件。
 *  适用场景：页面传输，文件传输，或与原生hessian服务互操作

## 依赖 ##

<dependency>
        <groupId>com.caucho</groupId>
        <artifactId>hessian</artifactId>
        <version>4.0.7</version>
    </dependency>

## 约束 ##

*  参数及返回值需实现 `Serializable` 接口
 *  参数及返回值不能自定义实现 `List`, `Map`, `Number`, `Date`, `Calendar` 等接口，只能用 JDK 自带的实现，因为 hessian 会做特殊处理，自定义实现类中的属性值都会丢失。

## 配置 ##

定义 hessian 协议：

<dubbo:protocol name="hessian" port="8080" server="jetty" />

设置默认协议：

<dubbo:provider protocol="hessian" />

设置 service 协议：

<dubbo:service protocol="hessian" />

多端口：

<dubbo:protocol id="hessian1" name="hessian" port="8080" />
    <dubbo:protocol id="hessian2" name="hessian" port="8081" />

直连：

<dubbo:reference id="helloService" interface="HelloWorld" url="hessian://10.20.153.10:8080/helloWorld" />

> 1.  [Hessian][] 是 Caucho 开源的一个 RPC 框架，其通讯效率高于 WebService 和 Java 自带的序列化。

HessionProtocol和HttpProtocol基本类似，都是通过servlet容器对外提供服务，最终都是基于http进行服务调用，不过其整个实现原理是基于Hession框架来的，可以阅读一下博主之前有关hession学习相关的博客。

HessionProtocol同样也是提供了两个接口doExport和doRefer

（1）doExport中简单来说是暴露服务，但是HessionProtocol其真正是通过容器（内置容器tomcat和jetty或者外部容器）来暴露服务，其只需要将其配置初始化到容器即可。

protected <T> Runnable doExport(T impl, Class<T> type, URL url) throws RpcException {
            String addr = getAddr(url);
            HttpServer server = serverMap.get(addr);
            if (server == null) {
                server = httpBinder.bind(url, new HessianHandler());
                serverMap.put(addr, server);
            }
            final String path = url.getAbsolutePath();
    		//根据接口及url对外暴露服务
            HessianSkeleton skeleton = new HessianSkeleton(impl, type);
            skeletonMap.put(path, skeleton);
    		//创建线程用于销毁服务使用
            return new Runnable() {
                public void run() {
                    skeletonMap.remove(path);
                }
            };
        }

（2）doRefer中简单来说就是组建远程调用的IP、端口、上下文和路径信息创建代理类，通过http协议来完成远程调用，在远程调用时消费者会根据url将要调用的接口、方法及参数信息发送给服务提供者，服务提供者根据接口和方法进行反射获取实现类，根据参数运行获取结果，在将结果返回给服务消费者。

@SuppressWarnings("unchecked")
        protected <T> T doRefer(Class<T> serviceType, URL url) throws RpcException {
    		//创建hession代理工厂
            HessianProxyFactory hessianProxyFactory = new HessianProxyFactory();
            boolean isHessian2Request = url.getParameter(Constants.HESSIAN2_REQUEST_KEY, Constants.DEFAULT_HESSIAN2_REQUEST);
            hessianProxyFactory.setHessian2Request(isHessian2Request);
            boolean isOverloadEnabled = url.getParameter(Constants.HESSIAN_OVERLOAD_METHOD_KEY, Constants.DEFAULT_HESSIAN_OVERLOAD_METHOD);
            hessianProxyFactory.setOverloadEnabled(isOverloadEnabled);
            String client = url.getParameter(Constants.CLIENT_KEY, Constants.DEFAULT_HTTP_CLIENT);
            if ("httpclient".equals(client)) {
                hessianProxyFactory.setConnectionFactory(new HttpClientConnectionFactory());
            } else if (client != null && client.length() > 0 && !Constants.DEFAULT_HTTP_CLIENT.equals(client)) {
                throw new IllegalStateException("Unsupported http protocol client=\"" + client + "\"!");
            }
            int timeout = url.getParameter(Constants.TIMEOUT_KEY, Constants.DEFAULT_TIMEOUT);
            hessianProxyFactory.setConnectTimeout(timeout);
            hessianProxyFactory.setReadTimeout(timeout);
    		//代理工厂根据接口、http相关信息创建代理类
            return (T) hessianProxyFactory.create(serviceType, url.setProtocol("http").toJavaURL(), Thread.currentThread().getContextClassLoader());
        }

[1]: http://dubbo.apache.org/books/dubbo-user-book/references/protocol/hessian.html#fn_1
[Hessian]: http://hessian.caucho.com/