Spring框架学习[Spring使用Hessian实现远程调用] - JAVA

dos; } if (!isToUse.markSupported()) { isToUse = new BufferedInputStream(isToUse); isToUse.mark(1); } int code = isToUse.read(); int major; int minor; AbstractHessianInput in; AbstractHessianOutput out; //根据客户端不同的Hessian版本，设置不同的Hessian抽象输入/输出 //Hessian2.0 if (code == 'H') { major = isToUse.read(); minor = isToUse.read(); if (major != 0x02) { throw new IOException("Version " + major + "." + minor + " is not understood"); } in = new Hessian2Input(isToUse); out = new Hessian2Output(osToUse); in.readCall(); } //Hessian2.0 else if (code == 'C') { isToUse.reset(); in = new Hessian2Input(isToUse); out = new Hessian2Output(osToUse); in.readCall(); } //Hessian1.0 else if (code == 'c') { major = isToUse.read(); minor = isToUse.read(); in = new HessianInput(isToUse); if (major >= 2) { out = new Hessian2Output(osToUse); } else { out = new HessianOutput(osToUse); } } else { throw new IOException("Expected 'H'/'C' (Hessian 2.0) or 'c' (Hessian 1.0) in hessian input at " + code); } //设置Hessian序列化工厂 if (this.serializerFactory != null) { in.setSerializerFactory(this.serializerFactory); out.setSerializerFactory(this.serializerFactory); } try { //通过服务端远程对象的Hessian框架处理远程调用 skeleton.invoke(in, out); } finally { try { in.close(); isToUse.close(); } catch (IOException ex) { } try { out.close(); osToUse.close(); } catch (IOException ex) { } } } //重置类加载器 finally { resetThreadContextClassLoader(originalClassLoader); } } }

public class HessianExporter extends RemoteExporter implements InitializingBean {	//Hessian HTTP响应内容类型	public static final String CONTENT_TYPE_HESSIAN = "application/x-hessian";	//Hessian序列化工厂	private SerializerFactory serializ<div class="article-middle-ad" style="margin: 30px 0; padding: 20px 0; text-align: center; clear: both;">
<script async src="https://pagead2.googlesyndication.com/pagead/js/adsbygoogle.js?client=ca-pub-3873923678443673" crossorigin="anonymous"></script>

<ins class="adsbygoogle"
     style="display:block"
     data-ad-client="ca-pub-3873923678443673"
     data-ad-slot="5723320063"
     data-ad-format="auto"
     data-full-width-responsive="true"></ins>
<script>
     (adsbygoogle = window.adsbygoogle || []).push({});
</script>
</div>erFactory = new SerializerFactory();	//Hessian Debug日志	private Log debugLogger;	//Hessian服务端框架	private HessianSkeleton skeleton;//设置Hessian序列化工厂	public void setSerializerFactory(SerializerFactory serializerFactory) {		this.serializerFactory = (serializerFactory != null   serializerFactory : new SerializerFactory());	}	//设置序列化集合发送java集合类型	public void setSendCollectionType(boolean sendCollectionType) {	this.serializerFactory.setSendCollectionType(sendCollectionType);	}	//设置Hessian调试模式	public void setDebug(boolean debug) {		this.debugLogger = (debug   logger : null);	}	//回调方法	public void afterPropertiesSet() {		prepare();	}	//初始化Hessian服务框架	public void prepare() {		//这里调用父类RemoteExporter的方法检查服务提供类、服务接口		checkService();		checkServiceInterface();		//创建远程服务类的Hessian框架		this.skeleton = new HessianSkeleton(getProxyForService(), getServiceInterface());	}//远程调用处理入口	public void invoke(InputStream inputStream, OutputStream outputStream) throws Throwable {		Assert.notNull(this.skeleton, "Hessian exporter has not been initialized");		doInvoke(this.skeleton, inputStream, outputStream);	}	//远程调用处理方法	protected void doInvoke(HessianSkeleton skeleton, InputStream inputStream, OutputStream outputStream)			throws Throwable {		//获取类加载器		ClassLoader originalClassLoader = overrideThreadContextClassLoader();		try {			InputStream isToUse = inputStream;			OutputStream osToUse = outputStream;			//设置Hessian调试日志			if (this.debugLogger != null && this.debugLogger.isDebugEnabled()) {				PrintWriter debugWriter = new PrintWriter(new CommonsLogWriter(this.debugLogger));				HessianDebugInputStream dis = new HessianDebugInputStream(inputStream, debugWriter);	</span>
            </div>

<div class="article-footer mt-60 pt-40">
                
                <div class="share-box">
                    
                        <div class="bdsharebuttonbox"><a href="#" class="bds_more" data-cmd="more"></a><a href="#" class="bds_qzone" data-cmd="qzone" title="分享到QQ空间"></a><a href="#" class="bds_tsina" data-cmd="tsina" title="分享到新浪微博"></a><a href="#" class="bds_tqq" data-cmd="tqq" title="分享到腾讯微博"></a><a href="#" class="bds_renren" data-cmd="renren" title="分享到人人网"></a><a href="#" class="bds_weixin" data-cmd="weixin" title="分享到微信"></a></div>
                    <script>window._bd_share_config={"common":{"bdSnsKey":{},"bdText":"","bdMini":"2","bdMiniList":false,"bdPic":"","bdStyle":"0","bdSize":"24"},"share":{}};with(document)0[(getElementsByTagName('head')[0]||body).appendChild(createElement('script')).src='http://bdimg.share.baidu.com/static/api/js/share.js?v=89860593.js?cdnversion='+~(-new Date()/36e5)];</script>
                </div>

<div class="prev-next mt-20">
                    <div class="prev">
                        <span class="label">上一篇</span>
                        <a href="bencandy.php?fid=76&id=39427" onclick="" class="link">paip.提升性能----java 无锁结构(..</a>
                    </div>
                    <div class="next">
                        <span class="label">下一篇</span>
                        <a href="bencandy.php?fid=76&id=39425" onclick="" class="link">FusionCharts封装-dataset和categ..</a>
                    </div>
                </div>
            </div>
        </div>

</div>
</div>
</div>

<footer class="container mt-20 site-footer">
    <div id="copyright">
        Copyright © https://www.cppentry.com all rights reserved 
        <a href="http://www.miibeian.gov.cn" target="_blank">粤ICP备13067022号-3</a><br>
            </div>
</footer>

Spring框架学习[Spring使用Hessian实现远程调用](七)