import java.io.File; import java.io.FileOutputStream; import java.io.InputStream; import javax.swing.JOptionPane; import org.apache.commons.net.ftp.FTPClient; import org.apache.commons.net.ftp.FTPClientConfig; import org.apache.commons.net.ftp.FTPFile; import org.apache.commons.net.ftp.FTPReply; import com.sun.org.apache.regexp.internal.recompile; /**

*

* @author Administrator

*记得链接后必须关闭连接

*/ public class ftpClient {   FTPClient ftp= null;    public ftpClient() {      // TODO Auto-generated constructor stub     ftp= new FTPClient();   }    public void ftpdisconnect(){      if(ftp.isConnected()){        try{         ftp.disconnect();                } catch (Exception e) {          // TODO: handle exception         JOptionPane.showMessageDialog( null, "关闭失败！"+e.getMessage(), "关闭失败", JOptionPane.ERROR_MESSAGE);       }     }   }    public int getConn(String server,String username,String password,String path){      int i=0;      int opi=0;      if(ftp.isConnected()){       String ftpserver=ftp.getLocalAddress().getHostAddress();        if(!ftpserver.equals(server)){         opi=JOptionPane.showConfirmDialog( null, "是否断开"+ftpserver+ "--链接"+server, "提示", JOptionPane.YES_NO_OPTION);       } else{          return i;       }     }      if(opi==0){       ftp.setControlEncoding( "GBK");       FTPClientConfig conf= new FTPClientConfig( "GBK");       conf.setServerLanguageCode( "zh");        try{         ftp.connect(server);         ftp.setSoTimeout(20); //超时十几秒的时间         ftp.login(username, password);          int reply=ftp.getReplyCode();          if(!FTPReply.isPositiveCompletion(reply)){           JOptionPane.showMessageDialog( null, "登录失败，用户名或者密码错误！", "登录失败", JOptionPane.ERROR_MESSAGE);           i=1;         }          if(!ftp.changeWorkingDirectory(path)){           JOptionPane.showMessageDialog( null, "跳转失败，路径有误！", "跳转失败", JOptionPane.ERROR_MESSAGE);           i=3;         }       } catch (Exception e) {          // TODO: handle exception         JOptionPane.showMessageDialog( null, "链接失败，请重新输入！"+e.getMessage(), "链接失败", JOptionPane.ERROR_MESSAGE);         i=2;       }     }      return i;   }    //判断是否有该文件    public boolean pdFile(String filename){      boolean flag= false;      if(ftp.isConnected()){        try{         FTPFile[] file=ftp.listFiles(filename);          if(file.length>0){           flag= true;         }       } catch (Exception e) {          // TODO: handle exception       }     }      return flag;   }    public int upLoadFile(String filename,InputStream input){      int i=0;      if(ftp.isConnected()){        try{            if(!pdFile(filename)){             ftp.storeFile(filename, input);             input.close();           } else{             JOptionPane.showMessageDialog( null, "上传"+filename+ "重复", "上传失败", JOptionPane.ERROR_MESSAGE);             input.close();             i=1;         }       }        catch (Exception e) {          // TODO: handle exception         JOptionPane.showMessageDialog( null, "上传"+filename+ "失败:"+e.getMessage(), "上传失败", JOptionPane.ERROR_MESSAGE);         i=2;       }     } else{       JOptionPane.showMessageDialog( null, "未连接FTP服务器", "未连接FTP服务器", JOptionPane.ERROR_MESSAGE);       i=3;     }      return i;   }    public int downLoadFile(String filename,String locapth){      int i=0;      if(ftp.isConnected()){        if(pdFile(filename)){         locapth=locapth+"\\"+filename;         File file= new File(locapth);          try{           FileOutputStream out= new FileOutputStream(file);           ftp.retrieveFile(filename, out);           out.close();         } catch (Exception e) {            // TODO: handle exception           JOptionPane.showMessageDialog( null, "下载"+filename+ "失败:"+e.getMessage(), "下载失败", JOptionPane.ERROR_MESSAGE);           i=1;         }       } else{         JOptionPane.showMessageDialog( null, "下载"+filename+ "不存在", "下载失败", JOptionPane.ERROR_MESSAGE);         i=2;       }     } else{       JOptionPane.showMessageDialog( null, "未连接FTP服务器", "未连接FTP服务器", JOptionPane.ERROR_MESSAGE);       i=3;     }      return i;   } }