
我正在使用ThreadSafeClientConnManager来管理客户端连接池,因为我的应用程序具有多个线程,这些线程正在同时连接到Web服务器.
抽象示例代码:
httpClIEnt httpClIEnt;ClIEntConnectionManager conMgr = new ThreadSafeClIEntConnManager(parameters,schReg);httpclIEnt = new DefaulthttpClIEnt(conMgr,parameters);现在,让我们说一下这些线程正在下载一个大文件,但是随后我的应用程序的用户正在切换到另一个活动/屏幕.因此该文件是不必要的,我想中止此下载连接.
在ThreadSafeClientConnManager中,我发现此方法:
公共ClIEntConnectionRequest requestConnection(httpRoute路由,对象状态)
返回一个新的ClIEntConnectionRequest,可以从中获取ManagedClIEntConnection或中止该请求.
到目前为止,我一直在使用:
httpGet httpRequest = new httpGet(URL_TO_file);httpResponse response = (httpResponse) httpclIEnt.execute(httpRequest);[...]现在,据我了解,我必须使用:
httpclIEnt.getConnectionManager().requestConnection(httpRoute路由,对象状态);
这就是我被困住的地方.我假设对于路由,我只能使用new httpRoute(new httpHost(“ 10.0.0.1”))或我的服务器是什么,但是在对象状态下应该输入什么呢?
其次,一旦有了ClIEntConnectionManager,我就可以调用getConnection(长时间超时,TimeUnit tunit).但是从那以后,我该如何执行httpGet httpRequest = new httpGet(URL_TO_file);就像我之前使用httpResponse response =(httpResponse)httpclIEnt.execute(httpRequest);一样吗?
我浏览了文档并尝试了很多不同的东西,但是我无法获得有效的解决方案.因此,非常欢迎任何建议和/或代码示例.
最佳答案您只需要调用httpRequest.abort()即可关闭连接.对于大文件,必须有一个循环处理数据.您只需检查取消状态并从那里取消,
httpentity entity = response.getEntity(); if (entity != null) { inputStream instream = entity.getContent(); while (instream.read(buf) >= 0) { if (cancelled) httpRequest.abort(); // Process the file } }使用池或keepalive时,中止的连接无法返回到池中,必须将其关闭.在较旧的版本中存在一个错误,该错误使连接保持活动状态,并弄乱了下一个请求.我认为这是固定的. 总结
以上是内存溢出为你收集整理的java-取消/中止来自ThreadSafeClientConnManager连接池的连接 全部内容,希望文章能够帮你解决java-取消/中止来自ThreadSafeClientConnManager连接池的连接 所遇到的程序开发问题。
如果觉得内存溢出网站内容还不错,欢迎将内存溢出网站推荐给程序员好友。
欢迎分享,转载请注明来源:内存溢出
微信扫一扫
支付宝扫一扫
评论列表(0条)