日韩性视频-久久久蜜桃-www中文字幕-在线中文字幕av-亚洲欧美一区二区三区四区-撸久久-香蕉视频一区-久久无码精品丰满人妻-国产高潮av-激情福利社-日韩av网址大全-国产精品久久999-日本五十路在线-性欧美在线-久久99精品波多结衣一区-男女午夜免费视频-黑人极品ⅴideos精品欧美棵-人人妻人人澡人人爽精品欧美一区-日韩一区在线看-欧美a级在线免费观看

歡迎訪問 生活随笔!

生活随笔

當前位置: 首頁 > 编程资源 > 编程问答 >内容正文

编程问答

那些年我们踩到过的坑(二):3.1 版 MultiThreadedHttpConnectionManager 未releaseConnection导致应用服务器宕机...

發布時間:2025/5/22 编程问答 14 豆豆
生活随笔 收集整理的這篇文章主要介紹了 那些年我们踩到过的坑(二):3.1 版 MultiThreadedHttpConnectionManager 未releaseConnection导致应用服务器宕机... 小編覺得挺不錯的,現在分享給大家,幫大家做個參考.

昨天短信服務又宕機了,jstack打出線程信息發現 所有線程池的線程都在wait,棧信息如下:

at java.lang.Object.wait(Native Method)
- waiting on [0x000000070754fb60] (a org.apache.commons.httpclient.MultiThreadedHttpConnectionManager$ConnectionPool)
at org.apache.commons.httpclient.MultiThreadedHttpConnectionManager.doGetConnection(MultiThreadedHttpConnectionManager.java:518)
- locked [0x000000070754fb60] (a org.apache.commons.httpclient.MultiThreadedHttpConnectionManager$ConnectionPool)
at org.apache.commons.httpclient.MultiThreadedHttpConnectionManager.getConnectionWithTimeout(MultiThreadedHttpConnectionManager.java:416)
at org.apache.commons.httpclient.HttpMethodDirector.executeMethod(HttpMethodDirector.java:153)
at org.apache.commons.httpclient.HttpClient.executeMethod(HttpClient.java:397)
at org.apache.commons.httpclient.HttpClient.executeMethod(HttpClient.java:323)
at com.dhf.sms.util.HttpUtil.getHtml(HttpUtil.java:75)
at com.dhf.sms.core.impl.MDSmsserviceImpl.send(MDSmsserviceImpl.java:165)
at com.dhf.sms.core.SmsTask.run(SmsTask.java:156)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at com.kuaidadi.framework.thread.bean.TaxiFutureTask.run(TaxiFutureTask.java:48)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)

?

發現所有線程都卡在MultiThreadedHttpConnectionManager 的doGetConnection方法:

? hostPool.waitingThreads.addLast(waitingThread);connectionPool.waitingThreads.addLast(waitingThread);connectionPool.wait(timeToWait);//卡在這

查看代碼和google,發現應該是connection連接未釋放的問題的。如果不調用getMethod.getResponseBodyAsString(),就不會釋放connection。并且我們沒有指定maxConnectionsPerHost,默認為2,所以當以下代碼在第16行拋出exception后連接不會被釋放掉,一旦發生兩次,那么僅有的2個connection都被占用,新進來的線程就卡住了。

1 public static String getHtml(String url,String charSet,Integer channelId) throws IOException, SmsHttpStatusException { 2 StaticLogInfo staticLogInfo = new StaticLogInfo(); 3 staticLogInfo.setCmd("Channel "+channelId+"("+getHost(url)+")"); 4 GetMethod getMethod = null; 5 try { 6 if (StringUtils.isBlank(charSet)) { 7 charSet = SmsConstant.DEFAULT_CHARSET; 8 } 9 10 getMethod = new GetMethod(url); 11 int statusCode = httpClient.executeMethod(getMethod); 12 if (statusCode != HttpStatus.SC_OK 13 && statusCode != HttpStatus.SC_MOVED_PERMANENTLY 14 && statusCode != HttpStatus.SC_MOVED_TEMPORARILY) { 15 log.error("statusCode:" + statusCode + " url請求失敗========>" + url); 16 throw new SmsHttpStatusException("請求失敗"); 17 } 18 19 String responseBody = new String(getMethod.getResponseBodyAsString().getBytes(charSet),SmsConstant.DEFAULT_CHARSET); 20 return responseBody; 21 } catch (IOException e) { 22 staticLogInfo.setResultCode("1"); 23 throw e; 24 } catch (SmsHttpStatusException e) { 25 staticLogInfo.setResultCode("1"); 26 throw e; 27 } finally { 28 29 reqLogger.info(staticLogInfo); 30 } 31 } 32

?

?

解決辦法是在finally里釋放connection:

finally {if(getMethod!=null){getMethod.releaseConnection();}reqLogger.info(staticLogInfo);}

并且增加最大連接數:

httpConnectionManagerParams.setMaxTotalConnections(100);httpConnectionManagerParams.setDefaultMaxConnectionsPerHost(20);

?

參考:http://blog.csdn.net/xiaojianpitt/article/details/7818971

轉載于:https://www.cnblogs.com/longzhaoyu/p/4563513.html

《新程序員》:云原生和全面數字化實踐50位技術專家共同創作,文字、視頻、音頻交互閱讀

總結

以上是生活随笔為你收集整理的那些年我们踩到过的坑(二):3.1 版 MultiThreadedHttpConnectionManager 未releaseConnection导致应用服务器宕机...的全部內容,希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯,歡迎將生活随笔推薦給好友。