[JAVA]Apache FTPClient操作“卡死”问题的分析和解决(一)

2014-11-24 07:32:03 · 作者: · 浏览: 0
最近在和一个第三方的合作中不得已需要使用FTP文件接口。由于FTP Server由对方提供,而且双方背后各自的网络环境环境都很不单纯等等原因,造成测试环境无法模拟实际情况。测试环境中程序一切正常,但是在部署到生产环境之后发现FTP操作不规律性出现“卡死”现象:程序捕获不到任何异常一直卡着,导致轮巡无法正常工作(由于担心在轮巡时间间隔内处理不能完成,我没有采用类似quartz或者crontab的定时任务,而是采用while-true然后sleep的方式)。
为了解决这个问题,我首先考虑的是对于FTPClient的使用上没有设置超时时间,于是设置了ConnectTimeout、DataTimeout、DefaultTimeout后在生产环境上继续观察,但是问题依旧没有解决。后来我有些怀疑FTPClient api本身是不是有什么问题,想实在不行自己实现一个超时机制吧,不过还是不甘心,还是想从FTPClient api本身去解决问题。又经过一翻研究之后发现:需要使用被动模式,以下摘抄别人的一段简单描述:
在项目中使用commons-net-3.0.1.jar实现FTP文件的 下载,在 windows xp上运行正常,但是放到linux上,却出现问题,程序运行到 FTPClient.listFiles()或者FTPClient.retrieveFile()方法时,就停止在那里,什么反应都没有,出现假死状态。google一把,发现很多人也出现了此类问题,最终在一个帖子里找到了解决办法。在调用这两个方法之前,调用FTPClient.enterLocalPassiveMode();这个方法的意思就是每次数据连接之前,ftp client告诉ftp server开通一个端口来传输数据。为什么要这样做呢,因为ftp server可能每次开启不同的端口来传输数据,但是在linux上,由于安全限制,可能某些端口没有开启,所以就出现阻塞。OK,问题解决。
于是我回滚了之前的修改,改为被动模式(关于FTP主动/被动模式的解释,这里我不多说了,关注的朋友可以自己查阅)。但是问题依旧。于是能想到的就是最有的绝招:实在不行自己实现一个超时机制吧。经过一翻研究最简单的方式就是使用:Future解决:
1 public static void main(String[] args) throws InterruptedException, ExecutionException {
2 final ExecutorService exec = Executors.newFixedThreadPool(1);
3
4 Callable call = new Callable() {
5 public String call() throws Exception {
6 Thread.sleep(1000 * 5);
7 return "线程执行完成.";
8 }
9 };
10
11 try {
12 Future future = exec.submit(call);
13 String obj = future.get(4 * 1000, TimeUnit.MILLISECONDS); // 任务处理超时时间设置
14 System.out.println("任务成功返回:" + obj);
15 } catch (TimeoutException ex) {
16 System.out.println("处理超时啦....");
17 ex.printStackTrace();
18 } catch (Exception e) {
19 System.out.println("处理失败.");
20 e.printStackTrace();
21 }
22 // 关闭线程池
23 exec.shutdown();
24
25 System.out.println("完毕");
26 }
虽然找到了终极的“必杀技”,但是此时我还是不甘心,还是想从FTPClient api本身去解决问题,但此时看来也别无它他法。只能试试:即设置被动模式又设置超时时间。经过实际测试,发现问题得以解决。下面把我的FTP工具类贴给大家分享,希望能帮到遇到同样问题的人。
1 import org.apache.commons.net.ftp.FTP;
2 import org.apache.commons.net.ftp.FTPClient;
3 import org.apache.commons.net.ftp.FTPFile;
4 import org.apache.commons.net.ftp.FTPReply;
5
6 import java.io.BufferedInputStream;
7 import java.io.BufferedOutputStream;
8 import java.io.File;
9 import java.io.FileInputStream;
10 import java.io.FileNotFoundException;
11 import java.io.FileOutputStream;
12 import java.io.IOException;
13 import java.io.InputStream;
14 import java.io.OutputStream;
15 import java.net.UnknownHostException;
16 import java.util.ArrayList;
17 import java.util.List;
18
19 public class FtpUtil {
20 public static final String ANONYMOUS_LOGIN = "anonymous";
21 private FTPClient ftp;
22 private boolean is_connected;
23
24 public FtpUtil() {
25 ftp = new FTPClient();
26 is_connected = false;
27 }
28
29 public FtpUtil(int defaultTimeoutSecond, int connectTimeoutSecond, int dataTimeoutSecond){
30 ftp = new FTPClient();
31 is_connected = false;
32
33 ftp.setDefaultTimeout(defaul