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