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

(UndeclaredThrowableException) targetEx; throw convertHessianAccessException(utex.getUndeclaredThrowable()); } else { throw targetEx; } } catch (Throwable ex) { throw new RemoteProxyFailureException( "Failed to invoke Hessian proxy for remote service [" + getServiceUrl() + "]", ex); } //重置类加载器 finally { resetThreadContextClassLoader(originalClassLoader); } } //将Hessian异常转换为Spring远程调用异常 protected RemoteAccessException convertHessianAccessException(Throwable ex) { if (ex instanceof HessianConnectionException || ex instanceof ConnectException) { return new RemoteConnectFailureException( "Cannot connect to Hessian remote service at [" + getServiceUrl() + "]", ex); } else { return new RemoteAccessException( "Cannot access Hessian remote service at [" + getServiceUrl() + "]", ex); } } }

public class HessianClientInterceptor extends UrlBasedRemoteAccessor implements MethodInterceptor {	//创建Hessiann代理工厂	private HessianProxyFactory proxyFactory = new HessianProxyFactory();	//Hessian代理	private Object hessianProxy;//设置Hessian代理工厂	public void setProxyFactory(HessianProxyFactory proxyFactory) {		this.proxyFactory = (proxyFactory != null   proxyFactory : new HessianProxyFactory());	}	//设置Hessian序列化工厂	public void setSerializerFactory(SerializerFactory serializerFactory) {		this.proxyFactory.setSerializerFactory(serializerFactory);	}	//设置Hessian是否发送java集合类型对象	public void setSendCollectionType(boolean sendCollectionType) {	this.proxyFactory.getSerializerFactory().setSendCollectionType(sendCollectionType);	}	//设置远程调用时是否重载方法	public void setOverloadEnabled(boolean overloadEnabled) {		this.proxyFactory.setOver<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>loadEnabled(overloadEnabled);	}	//设置远程调用用户名	public void setUsername(String username) {		this.proxyFactory.setUser(username);	}	//设置远程调用密码	public void setPassword(String password) {		this.proxyFactory.setPassword(password);	}	//设置是否使用Hessian的Debug调试模式	public void setDebug(boolean debug) {		this.proxyFactory.setDebug(debug);	}	//设置是否使用chunked端口发送Hessian请求	public void setChunkedPost(boolean chunkedPost) {		this.proxyFactory.setChunkedPost(chunkedPost);	}	//设置Hessian等待响应的超时时长	public void setReadTimeout(long timeout) {		this.proxyFactory.setReadTimeout(timeout);	}	//设置是否使用Hessain版本2协议解析请求和响应	public void setHessian2(boolean hessian2) {		this.proxyFactory.setHessian2Request(hessian2);		this.proxyFactory.setHessian2Reply(hessian2);	}	//设置是否使用Hessian版本2协议解析请求	public void setHessian2Request(boolean hessian2) {		this.proxyFactory.setHessian2Request(hessian2);	}	//设置是否使用Hessian版本2协议解析响应	public void setHessian2Reply(boolean hessian2) {		this.proxyFactory.setHessian2Reply(hessian2);	}//子类HessianProxyFactoryBean的回调方法调用此回调方法	public void afterPropertiesSet() {		//调用其父类UrlBasedRemoteAccessor的回调方法获取客户端配置的请求url		super.afterPropertiesSet();		//初始化Hessian代理		prepare();	}	//初始化Hessian代理	public void prepare() throws RemoteLookupFailureException {		try {			//创建Hessian代理			this.hessianProxy = createHessianProxy(this.proxyFactory);		}		catch (MalformedURLException ex) {			throw new RemoteLookupFailureException("Service URL [" + getServiceUrl() + "] is invalid", ex);		}	}	//创建Hessian代理	protected Object createHessianProxy(HessianProxyFactory proxyFactory) throws MalformedURLExce</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实现远程调用](四)