显示进度的 java FTP上传文件，ftp上传文件,java实现FTP上传有
分享于 点击 39846 次 点评：178
显示进度的 java FTP上传文件，ftp上传文件,java实现FTP上传有
java实现FTP上传有2种方式，一种是org.apache.commons.net.ftp.FTPClient这个jar包，一种是sun.net.ftp.FtpClient。不知道为什么，在使用前一种方式时，在遇到大批量的上传文件时总会抛出异常，我却找不出原因，所以使用的是后者。sun的FtpClient就在自带的systemlibrary中，如果程序找不到，Remove一下systemlibrary，再重新添加一次就好。这边我套用的是别人封装好的方法进行上传的，只不过稍加修改，再上传之前计算了一下所选文件（夹）的总大小，然后单独开了一个线程每隔一段时间计算总的上传量，然后刷新swing界面UI。这边直接贴上FtpClient封装好后的类的代码:java实现FTP上传有2种方式，一种是org.apache.commons.net.ftp.FTPClient这个jar包，一种是sun.net.ftp.FtpClient。不知道为什么，在使用前一种方式时，在遇到大批量的上传文件时总会抛出异常，我却找不出原因，所以使用的是后者。
sun的FtpClient就在自带的system library中，如果程序找不到，Remove一下system，再重新添加一遍就好。
下面主要贴上封装好的FtpUtils类的代码：
package com.fisee.ftp; import java.io.DataInputStream; import java.io.File; import java.io.FileInputStream; import java.io.FileOutputStream; import java.io.IOException; import java.io.OutputStream; import java.util.ArrayList; import java.util.List; import java.util.StringTokenizer; import sun.net.TelnetInputStream; import sun.net.TelnetOutputStream; import sun.net.ftp.FtpClient; /** * ftp上传，下载 * * @author why 2009-07-30 * */ public class FtpUtils { private String ip = ""; private String username = ""; private String password = ""; private int port = -1; private String path = ""; FtpClient ftpClient = null; OutputStream os = null; FileInputStream is = null; public static long trans = 0;//已传输文件大小 public static long totalSize = 0;//文件总大小 public FtpUtils(String serverIP, int port, String username, String password) { this.ip = serverIP; this.username = username; this.password = password; this.port = port; trans = 0; } /** * 连接ftp服务器 * * @throws IOException */ public boolean connectServer() { ftpClient = new FtpClient(); try { if (this.port != -1) { ftpClient.openServer(this.ip, this.port); } else { ftpClient.openServer(this.ip); } ftpClient.login(this.username, this.password); if (this.path.length() != 0) { ftpClient.cd(this.path);// path是ftp服务下主目录的子目录 } ftpClient.binary();// 用2进制上传、下载 System.out.println("已登录到\"" + ftpClient.pwd() + "\"目录"); return true; } catch (IOException e) { e.printStackTrace(); return false; } } /** * 断开与ftp服务器连接 * * @throws IOException */ public boolean closeServer() { try { if (is != null) { is.close(); } if (os != null) { os.close(); } if (ftpClient != null) { ftpClient.closeServer(); } System.out.println("已从服务器断开"); return true; } catch (IOException e) { e.printStackTrace(); return false; } } /** * 检查文件夹在当前目录下是否存在 * * @param dir * @return */ private boolean isDirExist(String dir) { String pwd = ""; try { pwd = ftpClient.pwd(); ftpClient.cd(dir); ftpClient.cd(pwd); } catch (Exception e) { return false; } return true; } /** * 在当前目录下创建文件夹 * * @param dir * @return * @throws Exception */ private boolean createDir(String dir) { try { ftpClient.ascii(); StringTokenizer s = new StringTokenizer(dir, "/"); // sign s.countTokens(); String pathName = ftpClient.pwd(); while (s.hasMoreElements()) { pathName = pathName + "/" + (String) s.nextElement(); try { ftpClient.sendServer("MKD " + pathName + "\r\n"); } catch (Exception e) { e = null; return false; } ftpClient.readServerResponse(); } ftpClient.binary(); return true; } catch (IOException e1) { e1.printStackTrace(); return false; } } /** * ftp上传 如果服务器段已存在名为filename的文件夹，该文件夹中与要上传的文件夹中同名的文件将被替换 * * @param filename * 要上传的文件（或文件夹）名 * @return * @throws Exception */ public boolean upload(String filename) { String newname = ""; if (filename.indexOf("/") > -1) { newname = filename.substring(filename.lastIndexOf("/") + 1); } else { newname = filename; } return upload(filename, newname); } /** * ftp上传 如果服务器段已存在名为newName的文件夹，该文件夹中与要上传的文件夹中同名的文件将被替换 * * @param fileName * 要上传的文件（或文件夹）名 * @param newName * 服务器段要生成的文件（或文件夹）名 * @return */ public boolean upload(String fileName, String newName) { try { /*String savefilename = new String(fileName.getBytes("ISO-8859-1"), "GBK");*/ String savefilename = fileName; File file_in = new File(savefilename);// 打开本地待长传的文件 if (!file_in.exists()) { throw new Exception("此文件或文件夹[" + file_in.getName() + "]有误或不存在!"); } if (file_in.isDirectory()) { upload(file_in.getPath(), newName, ftpClient.pwd()); } else { uploadFile(file_in.getPath(), newName); } if (is != null) { is.close(); } if (os != null) { os.close(); } return true; } catch (Exception e) { e.printStackTrace(); System.err.println("Exception e in Ftp upload(): " + e.toString()); return false; } finally { try { if (is != null) { is.close(); } if (os != null) { os.close(); } } catch (IOException e) { e.printStackTrace(); } } } /** * 真正用于上传的方法 * * @param fileName * @param newName * @param path * @throws Exception */ private void upload(String fileName, String newName, String path) throws Exception { //String savefilename = new String(fileName.getBytes("ISO-8859-1"), "GBK"); String savefilename = fileName; File file_in = new File(savefilename);// 打开本地待长传的文件 if (!file_in.exists()) { throw new Exception("此文件或文件夹[" + file_in.getName() + "]有误或不存在!"); } if (file_in.isDirectory()) { if (!isDirExist(newName)) { createDir(newName); } ftpClient.cd(newName); File sourceFile[] = file_in.listFiles(); for (int i = 0; i < sourceFile.length; i++) { if (!sourceFile[i].exists()) { continue; } if (sourceFile[i].isDirectory()) { this.upload(sourceFile[i].getPath(), sourceFile[i].getName(), path + "/" + newName); } else { this.uploadFile(sourceFile[i].getPath(), sourceFile[i].getName()); } } } else { uploadFile(file_in.getPath(), newName); } ftpClient.cd(path); } /** * upload 上传文件 * * @param filename * 要上传的文件名 * @param newname * 上传后的新文件名 * @return -1 文件不存在 >=0 成功上传，返回文件的大小 * @throws Exception */ public long uploadFile(String filename, String newname) throws Exception { long result = 0; TelnetOutputStream os = null; FileInputStream is = null; try { java.io.File file_in = new java.io.File(filename); if (!file_in.exists()) return -1; os = ftpClient.put(newname); result = file_in.length(); is = new FileInputStream(file_in); byte[] bytes = new byte[1024]; int c; while ((c = is.read(bytes)) != -1) { os.write(bytes, 0, c); trans = trans + c; } } finally { if (is != null) { is.close(); } if (os != null) { os.close(); } } return result; } /** * 从ftp下载文件到本地 * * @param filename * 服务器上的文件名 * @param newfilename * 本地生成的文件名 * @return * @throws Exception */ public long downloadFile(String filename, String newfilename) { long result = 0; TelnetInputStream is = null; FileOutputStream os = null; try { is = ftpClient.get(filename); java.io.File outfile = new java.io.File(newfilename); os = new FileOutputStream(outfile); byte[] bytes = new byte[1024]; int c; while ((c = is.read(bytes)) != -1) { os.write(bytes, 0, c); result = result + c; } } catch (IOException e) { e.printStackTrace(); } finally { try { if (is != null) { is.close(); } if (os != null) { os.close(); } } catch (IOException e) { e.printStackTrace(); } } return result; } /** * 取得相对于当前连接目录的某个目录下所有文件列表 * * @param path * @return */ public List getFileList(String path) { List list = new ArrayList(); DataInputStream dis; try { dis = new DataInputStream(ftpClient.nameList(this.path + path)); String filename = ""; while ((filename = dis.readLine()) != null) { list.add(filename); } } catch (IOException e) { e.printStackTrace(); } return list; } public static void main(String[] args) { FtpUtils ftp = new FtpUtils("192.168.1.100", 8833, "ScumVirus", "123456"); ftp.connectServer(); boolean result = ftp.upload("E:/11game", ""); System.out.println(result ? "上传成功！" : "上传失败！"); ftp.closeServer(); /** * FTP远程命令列表 USER PORT RETR ALLO DELE SITE XMKD CDUP FEAT PASS PASV STOR * REST CWD STAT RMD XCUP OPTS ACCT TYPE APPE RNFR XCWD HELP XRMD STOU * AUTH REIN STRU SMNT RNTO LIST NOOP PWD SIZE PBSZ QUIT MODE SYST ABOR * NLST MKD XPWD MDTM PROT * 在服务器上执行命令,如果用sendServer来执行远程命令(不能执行本地FTP命令)的话，所有FTP命令都要加上\r\n * ftpclient.sendServer("XMKD /test/bb\r\n"); //执行服务器上的FTP命令 * ftpclient.readServerResponse一定要在sendServer后调用 * nameList("/test")获取指目录下的文件列表 XMKD建立目录，当目录存在的情况下再次创建目录时报错 XRMD删除目录 * DELE删除文件 */ } } 刷新进度条线程：```java //刷新进度条线程
class ProgressThread extends Thread {
private JProgressBar progressBar;
public ProgressThread(JProgressBar progressBar) { this.progressBar = progressBar; } public void run() { while (flag) { int k = (int) (FtpUtils.trans * 100 / FtpUtils.totalSize); progress.setValue(k); try { Thread.sleep(1000); } catch (InterruptedException e) { e.printStackTrace(); } } } }```界面效果图附上源码：点击下载来自：http://blog.csdn.net/u013401219/article/details/46468349
用户点评