Spring框架学习[Spring HTTP调用器实现远程调用] - JAVA

Gzip压缩的，则需要先解压 if (isGzipResponse(con)) {

return new GZIPInputStream(con.getInputStream()); }

//正常的HTTP响应 else {

return con.getInputStream(); }

} //是否是Gzip格式压缩

protected boolean isGzipResponse(HttpURLConnection con) { //获取HTTP响应头信息中的压缩方式

String encodingHeader = con.getHeaderField(HTTP_HEADER_CONTENT_ENCODING); return (encodingHeader != null && encodingHeader.toLowerCase().indexOf(ENCODING_GZIP) != -1);

} }

public class SimpleHttpInvokerRequestExecutor extends AbstractHttpInvokerRequestExecutor {
//HTTP调用请求执行器真正进行远程调用的方法，该方法有其父类//AbstractHttpInvokerRequestExecutor的executeRequest方法调用
	protected RemoteInvocationResult doExecuteRequest(
			HttpInvokerClientConfiguration config, ByteArrayOutputStream baos)
			throws IOException, ClassNotFoundException {
		//打开一个标准的J2SE HttpURLConnection
		HttpURLConnection con = openConnection(config);
		//准备连接
		prepareConnection(con, baos.size());
//远程调用被封装成了RemoteInvocation对象，它通过序列化被写到对应的//HttpURLConnection中
		writeRequestBody(config, con, baos);
		//获取远程调用的结果，校验返回的结果
		validateResponse(config, con);
		InputStream responseBody = readResponseBody(config, con);
		//将远程调用结果转换成RemoteInvocationResult返回
		return readRemoteInvocationResult(responseBody, config.getCodebaseUrl());
	}
//打开一个HttpURLConnection
	protected HttpURLConnection openConnection(HttpInvokerClientConfiguration config) throws IOException {
		//getServiceUrl()方法获取配置的远程调用URL，打开一个URL连接
		URLConnection con = new URL(config.getServiceUrl()).openConnection();
		if (!(con instanceof HttpURLConnection)) {
			throw new IOException("Service URL [" + config.getServiceUrl() + "] is not an HTTP URL");
		}
		return (HttpURLConnection) con;
	}
	//准备HTTP请求连接
	protected void prepareConnection(HttpURLConnection con, int contentLength) throws IOException {
		con.setDoOutput(true);
		//HTTP调用器只支持POST请求方法
		con.setRequestMethod(HTTP_METHOD_POST);
	//设置HTTP请求头内容类型，设置为：application/x-java-serialized-object
		con.setRequestProperty(HTTP_HEADER_CONTENT_TYPE, getContentType());
		//设置HTTP请求头内容长度
		con.setRequestProperty(HTTP_HEADER_CONTENT_LENGTH, Integer.toString(contentLength));
		LocaleContext locale = LocaleContextHolder.getLocaleContext();
		//设置HTTP请求的Locale
		if (locale != null) {
			con.setRequestProperty(HTTP_HEADER_ACCEPT_LANGUAGE, StringUtils.toLanguageTag(locale.getLocale()));
		}
		//设置HTTP请求压缩方式
		if (isAcceptGzipEncoding()) {
			con.setRequestProperty(HTTP_HEADER_ACCEPT_ENCODING, ENCODING_GZIP);
		}
	}
//把序列化对象输出到HTTP请求体中
	protected void writeRequestBody(
			HttpInvokerClientConfiguration config, HttpURLConnection con, ByteArrayOutputStream baos)
			throws IOException {
		baos.writeTo(con.getOutputStream());
	}
//校验远程调用的HTTP响应
	protected void validateResponse(HttpInvokerClientConfiguration config, HttpURLConnection con)
			throws IOException {
		//如果HTTP响应状态码大于等于300，则证明调用发生错误
		if (con.getResponseCode() ><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>= 300) {
			throw new IOException(
					"Did not receive successful HTTP response: status code = " + con.getResponseCode() +
					", status message = [" + con.getResponseMessage() + "]");
		}
	}
	//提取远程调用结果的HTTP响应信息
	protected InputStream readResponseB</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=39443" onclick="" class="link">JAVA的堆栈和内存、垃圾回收解说</a>
                    </div>
                    <div class="next">
                        <span class="label">下一篇</span>
                        <a href="bencandy.php?fid=76&id=39441" onclick="" class="link">spoj 417 The lazy programmer（..</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 HTTP调用器实现远程调用](六)