Java访问FTP

嘉淑4049

　　
　　这里只提供Java从FTP下载文件（获取文件流）的示例。
　　
　　

/**
* 文件工具类
*
*/
public final class FileUtil
{
/**
* 加载properties配置文件
*
* @param filePath properties配置文件
* @return         返回Properties对象
*/
public static Properties loadProperties(String filePath)
{
Properties properties = new Properties();
try
{
properties.load(new FileInputStream(new File(filePath)));
}
catch (FileNotFoundException e)
{
e.printStackTrace();
}
catch (IOException e)
{
e.printStackTrace();
}
return properties;
}
}
　　
　　
　　


import java.io.IOException;
import java.io.InputStream;
import java.util.Properties;
import org.apache.commons.io.IOUtils;
import org.apache.commons.net.ftp.FTP;
import org.apache.commons.net.ftp.FTPClient;
import org.apache.commons.net.ftp.FTPReply;
import org.apache.log4j.Logger;
/**
* FTP操作器
*/
public class FTPHandler
{
/**
* 日志实例
*/
private static final Logger logger = Logger.getLogger(FTPHandler.class);
/**
* classes文件夹根目录全路径
*/
private static final String CLASS_PATH = FTPHandler.class.getResource("/").getPath().substring(1);
/**
* config目录名称
*/
private static final String CONFIG_DIR = "config";
/**
* ftp连接配置
*/
private Properties ftpConfig;
/**
* FTPHandler 单粒对象
*/
public static FTPHandler instance;
/**
* 构造方法私有化
*/
private FTPHandler()
{
this.init();
}
/**
*
*/
private void init()
{
//ftp配置文件路径
String ftpConfigPath = CLASS_PATH.substring(0, CLASS_PATH.length() - 8) + FTPHandler.CONFIG_DIR + "/" + "ftpserver.properties";
ftpConfig = FileUtil.loadProperties(ftpConfigPath);
}
/**
* 获取FTPHandler单粒对象
*
* @return
*/
public static synchronized FTPHandler getInstance()
{
if (null == instance)
{
instance = new FTPHandler();
}
return instance;
}
/**
* 根据区域标记。不同的区域使用不同的账号登陆FTP
*
* @param areaFlag 区域标记
* @param filePath 文件路径
* @return
*/
public InputStream  getInputStream(String areaFlag, String filePath)
{
FTPClient ftp = this.ftpFactory(areaFlag);
InputStream in = null;
try
{
in = ftp.retrieveFileStream(filePath);
}
catch (IOException e)
{
logger.error("获取文件流失败，文件路径：" + filePath, e);
}
this.closeFtp(ftp);
return in;
}
/**
* ftpClient对象工厂方法
*
* @param areaFlag 区域标记 目前不同的区域使用不同的FTP登陆账号
* @return
*/
private FTPClient ftpFactory(String areaFlag)
{
FTPClient ftp = new FTPClient();
if (null != ftpConfig.getProperty("ftp.controlkeepalivetimeout"))
{
ftp.setControlKeepAliveTimeout(Long.valueOf(ftpConfig.getProperty("ftp.controlkeepalivetimeout")));
}
try
{
//ftp服务器地址
ftp.connect(ftpConfig.getProperty("ftp.server"));
int reply = ftp.getReplyCode();
//检查连接是否正常
if (!FTPReply.isPositiveCompletion(reply))
{
ftp.disconnect();
logger.error("FTP服务器拒绝连接！");
}
//登陆
if (!ftp.login(getAccountInfoByFlag(areaFlag, "username"), this.getAccountInfoByFlag(areaFlag, "password")))
{
ftp.logout();
}
else
{
//二进制传输
ftp.setFileType(FTP.BINARY_FILE_TYPE);
}
}
catch (Exception e)
{
logger.error("创建ftpClient对象失败!", e);
}
return ftp;
}
private void closeFtp(FTPClient ftp)
{
try
{
ftp.noop();
ftp.logout();
}
catch (IOException e)
{
logger.error("ftpClient登出失败！", e);
}
finally
{
if (ftp.isConnected())
{
try
{
ftp.disconnect();
}
catch (IOException f)
{
logger.error("ftp连接关闭失败！", f);
}
}
}
}
/**
* 获取账号信息
*
* @param areaFlag 区域缩写
* @param suffix   properties后缀
* @return         返回账号信息
*/
private String getAccountInfoByFlag(String areaFlag, String suffix)
{
//默认情况key值
String key = "ftp." + suffix;
if (null != areaFlag && !"".equals(areaFlag))
{
key = "ftp." + areaFlag + "_" + suffix;
}
return ftpConfig.getProperty(key);
}
//public static void main(String[] args)
//{
//FTPHandler tmp = FTPHandler.getInstance();
//
//try
//{
//System.out.println(IOUtils.toString(tmp.getInputStream("11", "jQuery_Backup.txt")));
//}
//catch (IOException e)
//{
//// TODO Auto-generated catch block
//e.printStackTrace();
//}
//}
}

　　
　　
　　配置文件 
　　################################################
　　#Connection Configuration
　　ftp.server=IP地址
　　ftp.controlkeepalivetimeout=300
　　
　　#Account Configuration
　　ftp.11_username=123
　　ftp.11_password=123
　　
　　ftp.33_username=456
　　ftp.33_password=456