java实现ftp登录上传下载关闭等操作【转】

d295sz2y9p

　　
　　我们采用的apache封装的FTP，
　　
　　import org.apache.commons.net.ftp.FTPClient;
　　import org.apache.commons.net.ftp.FTPClientConfig;
　　import org.apache.commons.net.ftp.FTPReply;
　　
　　这是apache封装FTP相关的引入
　　
　　====================================================
　　
　　类名为：FtpUtil
　　
　　

private FTPClient ftpClient = null;
private String hostname;
private int port;
private String username;
private String password;
private String remoteDir;
//构造方法
public FtpUtil(String hostname, int port, String username, String password, String remoteDir){
this.hostname = hostname;
this.port = port;
this.username = username;
this.password = password;
this.remoteDir = remoteDir;
if(remoteDir==null) {
remoteDir = "/";
}
}
//登录
/**
* FTP登陆
* @throws IOException
*/
public void login() throws Exception{
ftpClient = new FTPClient();
ftpClient.configure(getFTPClientConfig());
ftpClient.setDefaultPort(port);
ftpClient.setControlEncoding("UTF-8");
ftpClient.connect(hostname);
if(!ftpClient.login(username, password)){
throw new Exception("FTP登陆失败，请检测登陆用户名和密码是否正确!");
}
ftpClient.setFileType(FTPClient.BINARY_FILE_TYPE);
ftpClient.changeWorkingDirectory(remoteDir);
}


/**
* 得到配置
* @return
*/
private FTPClientConfig getFTPClientConfig() {
// 创建配置对象
FTPClientConfig conf = new FTPClientConfig(FTPClientConfig.SYST_NT);
conf.setServerLanguageCode("zh");
return conf;
}

/**
* 关闭FTP服务器
*/
public void closeServer(){
try{
if(ftpClient!=null){
ftpClient.logout();
ftpClient.disconnect();
}
}catch(IOException e){
e.printStackTrace();
}
}

/**
* 链接是否已经打开
* @return
*/
public boolean serverIsOpen(){
if(ftpClient==null){
return false;
}
return !ftpClient.isConnected();
}

/**
* 列表FTP文件
* @param regEx
* @return
*/
public String[] listFiles(String regEx){
String[] names;
try{
names = ftpClient.listNames(regEx);
if(names == null) return new String[0];
return names;
}catch(IOException e){
e.printStackTrace();
}
return new String[0];
}

/**
* 取得FTP操作类的句柄
* @return
*/
public FTPClient getFtpClient() {
return ftpClient;
}

/**
* 上传
* @throws Exception
*/
public boolean upload(String localFilePath, String remoteFilePath)throws Exception {
boolean state = false;
File localFile = new File(localFilePath);
if(!localFile.isFile()||localFile.length()==0){
return state;
}
FileInputStream localIn = new FileInputStream(localFile);
state = this.upload(localIn, remoteFilePath);
localIn.close();
return state;
}
/**
* 上传
* @throws Exception
*/
public boolean upload(InputStream localIn, String remoteFilePath)throws Exception {
this.createDir(new File(remoteFilePath).getParent());
boolean result = ftpClient.storeFile(remoteFilePath, localIn);
return result;
}
/**
* 是否存在FTP目录
* @param dir
* @param ftpClient
* @return
*/
public boolean isDirExist(String dir) {
try {
int retCode = ftpClient.cwd(dir);
return FTPReply.isPositiveCompletion(retCode);
} catch (Exception e) {
return false;
}
}
/**
* 创建FTP多级目录
* @param remoteFilePath
* @throws IOException
*/
public void createDir(String dir) throws IOException{
if(!isDirExist(dir)){
File file = new File(dir);
this.createDir(file.getParent());
ftpClient.makeDirectory(dir);
}
}
/**
* 删除文件
* @param remoteFilePath
*/
public boolean delFile(String remoteFilePath) {
try {
return ftpClient.deleteFile(remoteFilePath);
} catch (IOException e) {
e.printStackTrace();
}
return false;
}

/**
* 下载
* @throws Exception
*/
public void download(String localFilePath, String remoteFilePath)throws Exception {
OutputStream localOut = new FileOutputStream(localFilePath);
this.download(localOut, remoteFilePath);
localOut.close();
}
/**
* 下载
* @throws Exception
*/
public void download(OutputStream localOut, String remoteFilePath)throws Exception {
boolean result = ftpClient.retrieveFile(remoteFilePath, localOut);
if (!result) {
throw new Exception("文件下载失败!");
}
}