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

 

我们采用的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("文件下载失败!");
  }
 }