NonRepeatableRequestException: Cannot retry request with a non-repeatable request entity

報錯信息：org.apache.http.client.NonRepeatableRequestException: Cannot retry request with a non-repeatable request entity
解決方案：

public static InputStream getAsStream(String url) {try (CloseableHttpClient client = HttpClients.createDefault();CloseableHttpResponse response = client.execute(new HttpGet(url))) {HttpEntity httpEntity = response.getEntity();// 包裝一層解決BufferedHttpEntity bhe = new BufferedHttpEntity(httpEntity);return bhe.getContent();} catch (IOException e) {LOGGER.error("doGet failed: " + e.getMessage());}return null; }

參考：
stackoverflow

Going to buffer response body of large or unknown size. Using getResponseBodyAsStream instead is recommended.

使用HttpClient，大量報出Going to buffer response body of large or unknown size. Using getResponseBodyAsStream instead is recommended的WARN日志，定位到HttpClient的源碼如下：

public abstract class HttpMethodBase implements HttpMethod {public byte[] getResponseBody() throws IOException {if (responseBody == null) {InputStream instream = getResponseBodyAsStream();if (instream != null) {long contentLength = getResponseContentLength();if (contentLength > 2147483647L) {throw new IOException("Content too large to be buffered: " + contentLength + " bytes");}int limit = getParams().getIntParameter("http.method.response.buffer.warnlimit", 1048576);if (contentLength == -1L || contentLength > (long) limit) {LOG.warn("Going to buffer response body of large or unknown size. Using getResponseBodyAsStream instead is recommended.");}LOG.debug("Buffering response body");ByteArrayOutputStream outstream = new ByteArrayOutputStream(contentLength <= 0L ? 4096: (int) contentLength);byte buffer[] = new byte[4096];int len;while ((len = instream.read(buffer)) > 0) {outstream.write(buffer, 0, len);}outstream.close();setResponseStream(null);responseBody = outstream.toByteArray();}}return responseBody;} }

報WARN的條件(contentLength == -1) || (contentLength > limit)，即返回的HTTP頭沒有指定contentLength，或contentLength大于上限（默認1M）。如果能確定返回結(jié)果的大小對程序沒有顯著影響，這個WARN就可以忽略，可在日志配置中把HttpClient的日志級別調(diào)到ERROR。

不過這都是忽略潛在的問題，并沒有解決問題。

HttpClient建議使用InputStream getResponseBodyAsStream()代替byte[] getResponseBody()。對于返回結(jié)果很大或無法預(yù)知的情況，使用InputStreamgetResponseBodyAsStream()，避免byte[] getResponseBody()可能帶來的內(nèi)存耗盡問題。

解決方案，將stream轉(zhuǎn)化為string：

private String convert(InputStream inputStream) throws IOException {BufferedReader br = new BufferedReader(new InputStreamReader(inputStream));StringBuilder sb = new StringBuilder();String str;while ((str = br.readLine()) != null) {sb.append(str);}return sb.toString(); }

ConnectException: Connection refused

使用企業(yè)微信推送消息時遇到的問題，具體的報錯信息：

java.lang.Exception: org.apache.http.conn.HttpHostConnectException: Connect to qyapi.weixin.qq.com:443 [qyapi.weixin.qq.com/81.69.87.29, qyapi.weixin.qq.com/81.69.54.213] failed: Connection refused報錯行at com.xy.cloudiview.common.util.HttpUtil.doGet(HttpUtil.java:49)at com.xy.cloudiview.common.util.SendWeChatUtil.getToken(SendWeChatUtil.java:193)at com.xy.cloudiview.common.util.SendWeChatUtil.sendWeChat(SendWeChatUtil.java:57)at com.xy.cloudiview.datasetsubscript.business.service.impl.TableWarnServiceImpl.sendWeChat(TableWarnServiceImpl.java:330)at com.xy.cloudiview.datasetsubscript.business.service.impl.TableWarnServiceImpl.sendMsg(TableWarnServiceImpl.java:417)at com.xy.cloudiview.datasetsubscript.business.service.impl.TableWarnServiceImpl.executeTableWarnJob(TableWarnServiceImpl.java:99)at com.xy.cloudiview.datasetsubscript.business.xxljob.IviewTableWarnJobHandler.execute(IviewTableWarnJobHandler.java:45)at com.ppdai.job.core.thread.JobThread.run(JobThread.java:142) Caused by: org.apache.http.conn.HttpHostConnectException: Connect to qyapi.weixin.qq.com:443 [qyapi.weixin.qq.com/81.69.87.29, qyapi.weixin.qq.com/81.69.54.213] failed: Connection refusedat org.apache.http.impl.conn.DefaultHttpClientConnectionOperator.connect(DefaultHttpClientConnectionOperator.java:156)at org.apache.http.impl.conn.PoolingHttpClientConnectionManager.connect(PoolingHttpClientConnectionManager.java:376)at org.apache.http.impl.execchain.MainClientExec.establishRoute(MainClientExec.java:393)at org.apache.http.impl.execchain.MainClientExec.execute(MainClientExec.java:236)at org.apache.http.impl.execchain.ProtocolExec.execute(ProtocolExec.java:186)at org.apache.http.impl.execchain.RetryExec.execute(RetryExec.java:89)at org.apache.http.impl.execchain.RedirectExec.execute(RedirectExec.java:110)at org.apache.http.impl.client.InternalHttpClient.doExecute(InternalHttpClient.java:185)at org.apache.http.impl.client.CloseableHttpClient.execute(CloseableHttpClient.java:83)at org.apache.http.impl.client.CloseableHttpClient.execute(CloseableHttpClient.java:108)at com.xy.cloudiview.common.util.HttpUtil.doGet(HttpUtil.java:39)... 7 common frames omitted Caused by: java.net.ConnectException: Connection refusedat java.net.PlainSocketImpl.socketConnect(Native Method)at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:350)at java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:206)at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:188)at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)at java.net.Socket.connect(Socket.java:589)at org.apache.http.conn.ssl.SSLConnectionSocketFactory.connectSocket(SSLConnectionSocketFactory.java:368)at org.apache.http.impl.conn.DefaultHttpClientConnectionOperator.connect(DefaultHttpClientConnectionOperator.java:142)... 17 common frames omitted

HttpUtil.doGet方法定義：

public static String doGet(String url) throws Exception {// 創(chuàng)建Httpclient對象CloseableHttpClient httpclient = HttpClients.createDefault();// 創(chuàng)建http GET請求HttpGet httpGet = new HttpGet(url);CloseableHttpResponse response = null;String content = "";try {// 執(zhí)行請求response = httpclient.execute(httpGet);// 判斷返回狀態(tài)是否為200if (response.getStatusLine().getStatusCode() == 200) {//請求體內(nèi)容content = EntityUtils.toString(response.getEntity(), "UTF-8");} else {log.error("doget error, url:{}, return code:{}", url,response.getStatusLine().getStatusCode());}} catch (Exception e) {// 報錯行throw new Exception(e);} finally {if (response != null) {response.close();}//相當于關(guān)閉瀏覽器httpclient.close();}return content; }

沒有什么意義的參考：

• 偶現(xiàn)訪問 qyapi.weixin.qq.com被拒絕的情況？
• how-to-fix-java-net-connectexception-connection-refused-connect-in-java

參考

• HttpClient警告

總結(jié)

以上是生活随笔為你收集整理的httpClient笔记的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。