java 的FTP操作（FTPClient）

简思琪

　　

package lis.co.jp.java.common;
import java.io.IOException;
import java.io.InputStream;
import org.apache.commons.net.ftp.FTPClient;
import org.apache.commons.net.ftp.FTPFile;
import org.apache.commons.net.ftp.FTPReply;
/**
* FTP管理クラス
*
*/
public class FtpUtil {

public FTPClient ftpClient = null;
/**
* コンストラクタ
*/
public FtpUtil() {
ftpClient = new FTPClient();   
}

/**
* FTPサーバーの接続
* @param hostname サーバー名
* @param port ポート
* @param username ユーザー名
* @param password パスワード
* @return 処理結果を真偽で返します。
* @throws IOException
*/
public boolean connect(String hostname, String username,String password) throws IOException{   
ftpClient.connect(hostname, 21);  
ftpClient.enterLocalPassiveMode();
ftpClient.setControlEncoding("SHIFT_JIS");   
if(FTPReply.isPositiveCompletion(ftpClient.getReplyCode())){   
if(ftpClient.login(username, password)){   
return true;   
}   
}   
closeConnect();   
return false;   
}

/**
* ファイル内容全てファイルを取得。
* @param dirPath ファイルパス
* @return ファイルリスト
* @throws IOException
*/
public FTPFile[] getListFile(String dirPath) throws IOException {
FTPFile[] files = null;
ftpClient.enterLocalPassiveMode();   
ftpClient.setFileType(FTPClient.BINARY_FILE_TYPE);
dirPath = new String(dirPath.getBytes("SHIFT_JIS"),"ISO-8859-1");
try {
files = ftpClient.listFiles(dirPath);
} catch (IOException e) {
e.printStackTrace();
}
return files;
}
/**
* ファイルのバイナリデータを取得。
* @param filePath　ファイルパス
* @return ファイルのバイナリデータ
* @throws IOException
*/
public InputStream getInputstream(String filePath) throws IOException {
InputStream in = null;
ftpClient.enterLocalPassiveMode();   
ftpClient.setFileType(FTPClient.BINARY_FILE_TYPE);
filePath = new String(filePath.getBytes("SHIFT_JIS"),"ISO-8859-1");
try {
in = ftpClient.retrieveFileStream(filePath);

} catch (IOException e) {
e.printStackTrace();
}
return in;
}
/**
* 削除フォルダとフォルダ内のファイル
* @param dirPath フォルダのパス
* @return 処理結果を真偽で返します。
* @throws IOException
*/
public boolean deleteDirectory(String dirPath) throws IOException {
boolean result = true;
ftpClient.enterLocalPassiveMode();   
dirPath = new String(dirPath.getBytes("SHIFT_JIS"),"ISO-8859-1");
try {
FTPFile[] files = ftpClient.listFiles(dirPath);
for (int i = 0; i < files.length; i++) {
FTPFile file = files;
String name = file.getName();
name = new String(name.getBytes("SHIFT_JIS"),"ISO-8859-1");
if (file.isDirectory()) {
result = deleteDirectory(dirPath + "\\" + name);
if (!result) {
break;
}
} else {
result = ftpClient.deleteFile(dirPath + "\\" + name);
if (!result) {
break;
}
}
}
if (!result) {
return false;
}
result = ftpClient.removeDirectory(dirPath);
} catch (Exception e) {
return false;
}
return result;
}
/**
* FTPの接続を解放します。
* @throws IOException
*/
public void closeConnect() throws IOException {
if(ftpClient.isConnected()){   
ftpClient.disconnect();   
}   
}
/**
* バイナリデータを解放します。
* @param in
*/
public void close(InputStream in)  {
try {
in.close();
ftpClient.completePendingCommand();
} catch (IOException e) {
e.printStackTrace();
}
}
}

ps：特别注意的是ftpClient.completePendingCommand();要写在in.close();之后，否则有可能出现reset的问题。