Android中关于FTP的文件上传和下载

此篇博客为整理文章，文章出处：http://www.cnblogs.com/xyc20080413/archive/2013/04/08/3008646.html 1.首先下载commons-net jar包，可以百度下载。 FTP的文件上传和下载的工具类：

package ryancheng.example.progressbar;import java.io.File;import java.io.FileOutputStream;import java.io.InputStream;import java.io.OutputStream;import java.io.RandomAccessFile;import org.apache.commons.net.ftp.FTP;import org.apache.commons.net.ftp.FTPClient;import org.apache.commons.net.ftp.FTPFile;import org.apache.commons.net.ftp.FTPReply;import android.os.Environment;public class FTPManager {FTPClient ftpClient = null;public FTPManager() {ftpClient = new FTPClient();}// 连接到ftp服务器public synchronized boolean connect() throws Exception {boolean bool = false;if (ftpClient.isConnected()) {//判断是否已登陆ftpClient.disconnect();}ftpClient.setDataTimeout(20000);//设置连接超时时间ftpClient.setControlEncoding("utf-8");ftpClient.connect("ip地址", 端口);if (FTPReply.isPositiveCompletion(ftpClient.getReplyCode())) {if (ftpClient.login("用户名", "密码")) {bool = true;System.out.println("ftp连接成功");}}return bool;}// 创建文件夹public boolean createDirectory(String path) throws Exception {boolean bool = false;String directory = path.substring(0, path.lastIndexOf("/") + 1);int start = 0;int end = 0;if (directory.startsWith("/")) {start = 1;}end = directory.indexOf("/", start);while (true) {String subDirectory = directory.substring(start, end);if (!ftpClient.changeWorkingDirectory(subDirectory)) {ftpClient.makeDirectory(subDirectory);ftpClient.changeWorkingDirectory(subDirectory);bool = true;}start = end + 1;end = directory.indexOf("/", start);if (end == -1) {break;}}return bool;}// 实现上传文件的功能public synchronized boolean uploadFile(String localPath, String serverPath)throws Exception {// 上传文件之前，先判断本地文件是否存在File localFile = new File(localPath);if (!localFile.exists()) {System.out.println("本地文件不存在");return false;}System.out.println("本地文件存在，名称为：" + localFile.getName());createDirectory(serverPath); // 如果文件夹不存在，创建文件夹System.out.println("服务器文件存放路径：" + serverPath + localFile.getName());String fileName = localFile.getName();// 如果本地文件存在，服务器文件也在，上传文件，这个方法中也包括了断点上传long localSize = localFile.length(); // 本地文件的长度FTPFile[] files = ftpClient.listFiles(fileName);long serverSize = 0;if (files.length == 0) {System.out.println("服务器文件不存在");serverSize = 0;} else {serverSize = files[0].getSize(); // 服务器文件的长度}if (localSize <= serverSize) {if (ftpClient.deleteFile(fileName)) {System.out.println("服务器文件存在,删除文件,开始重新上传");serverSize = 0;}}RandomAccessFile raf = new RandomAccessFile(localFile, "r");// 进度long step = localSize / 100;long process = 0;long currentSize = 0;// 好了，正式开始上传文件ftpClient.enterLocalPassiveMode();ftpClient.setFileType(FTP.BINARY_FILE_TYPE);ftpClient.setRestartOffset(serverSize);raf.seek(serverSize);OutputStream output = ftpClient.appendFileStream(fileName);byte[] b = new byte[1024];int length = 0;while ((length = raf.read(b)) != -1) {output.write(b, 0, length);currentSize = currentSize + length;if (currentSize / step != process) {process = currentSize / step;if (process % 10 == 0) {System.out.println("上传进度：" + process);}}}output.flush();output.close();raf.close();if (ftpClient.completePendingCommand()) {System.out.println("文件上传成功");return true;} else {System.out.println("文件上传失败");return false;}}// 实现下载文件功能，可实现断点下载public synchronized boolean downloadFile(String localPath, String serverPath)throws Exception {// 先判断服务器文件是否存在FTPFile[] files = ftpClient.listFiles(serverPath);if (files.length == 0) {System.out.println("服务器文件不存在");return false;}System.out.println("远程文件存在,名字为：" + files[0].getName());localPath = localPath + files[0].getName();// 接着判断下载的文件是否能断点下载long serverSize = files[0].getSize(); // 获取远程文件的长度File localFile = new File(localPath);long localSize = 0;if (localFile.exists()) {localSize = localFile.length(); // 如果本地文件存在，获取本地文件的长度if (localSize >= serverSize) {System.out.println("文件已经下载完了");File file = new File(localPath);file.delete();System.out.println("本地文件存在，删除成功，开始重新下载");return false;}}// 进度long step = serverSize / 100;long process = 0;long currentSize = 0;// 开始准备下载文件ftpClient.enterLocalActiveMode();ftpClient.setFileType(FTP.BINARY_FILE_TYPE);OutputStream out = new FileOutputStream(localFile, true);ftpClient.setRestartOffset(localSize);InputStream input = ftpClient.retrieveFileStream(serverPath);byte[] b = new byte[1024];int length = 0;while ((length = input.read(b)) != -1) {out.write(b, 0, length);currentSize = currentSize + length;if (currentSize / step != process) {process = currentSize / step;if (process % 10 == 0) {System.out.println("下载进度：" + process);}}}out.flush();out.close();input.close();// 此方法是来确保流处理完毕，如果没有此方法，可能会造成现程序死掉if (ftpClient.completePendingCommand()) {System.out.println("文件下载成功");return true;} else {System.out.println("文件下载失败");return false;}}// 如果ftp上传打开，就关闭掉public void closeFTP() throws Exception {if (ftpClient.isConnected()) {ftpClient.disconnect();}}}

具体实现看代码注释写的很详细。
一.Android中FTP文件上传代码：

// 上传例子private void ftpUpload() {   new Thread() {    public void run() {     try {      System.out.println("正在连接ftp服务器....");      FTPManager ftpManager = new FTPManager();      if (ftpManager.connect()) {       if (ftpManager.uploadFile(ftpManager.rootPath + "UpdateXZMarketPlatform.apk", "mnt/sdcard/")) {        ftpManager.closeFTP();       }      }     } catch (Exception e) {      // TODO: handle exception      // System.out.println(e.getMessage());     }    }   }.start(); }

二.Android中FTP文件下载代码：

// 下载例子private void ftpDownload() {   new Thread() {    public void run() {     try {      System.out.println("正在连接ftp服务器....");      FTPManager ftpManager = new FTPManager();      if (ftpManager.connect()) {       if (ftpManager.downloadFile(ftpManager.rootPath, "20120723_XFQ07_XZMarketPlatform.db")) {        ftpManager.closeFTP();       }      }     } catch (Exception e) {      // TODO: handle exception      // System.out.println(e.getMessage());     }    }   }.start(); }

自己之前做项目的时候写过的FTP上传代码：

package com.kandao.yunbell.videocall;import java.io.File;import java.io.FileInputStream;import java.io.FileNotFoundException;import java.io.IOException;import java.io.UnsupportedEncodingException;import java.net.SocketException;import org.apache.commons.net.ftp.FTP;import org.apache.commons.net.ftp.FTPClient;import org.apache.commons.net.ftp.FTPReply;import com.kandao.yunbell.common.SysApplication;import android.content.Context;import android.util.Log;public class MyUploadThread extends Thread {private String fileName;// 文件名字private String filePath;// 文件本地路径private String fileStoragePath;// 文件服务器存储路径private String serverAddress;// 服务器地址private String ftpUserName;// ftp账号private String ftpPassword;// ftp密码private Context mContext;public MyUploadThread() {super();// TODO Auto-generated constructor stub}public MyUploadThread(Context mContext,String fileName, String filePath, String fileStoragePath,String serverAddress,String ftpUserName,String ftpPassword) {super();this.fileName = fileName;this.filePath = filePath;this.fileStoragePath = fileStoragePath;this.serverAddress = serverAddress;this.ftpUserName = ftpUserName;this.ftpPassword = ftpPassword;this.mContext=mContext;}@Overridepublic void run() {super.run();try {FileInputStream fis=null;FTPClient ftpClient = new FTPClient();String[] idPort = serverAddress.split(":");ftpClient.connect(idPort[0], Integer.parseInt(idPort[1]));int returnCode = ftpClient.getReplyCode();Log.i("caohai", "returnCode,upload:"+returnCode);boolean loginResult = ftpClient.login(ftpUserName, ftpPassword);Log.i("caohai", "loginResult:"+loginResult);if (loginResult && FTPReply.isPositiveCompletion(returnCode)) {// 如果登录成功// 设置上传目录if (((SysApplication) mContext).getIsVideo()) {((SysApplication) mContext).setIsVideo(false);boolean ff=ftpClient.changeWorkingDirectory(fileStoragePath + "/video/");Log.i("caohai", "ff:"+ff);}else{boolean ee=ftpClient.changeWorkingDirectory(fileStoragePath + "/photo/");Log.i("caohai", "ee:"+ee);}ftpClient.setBufferSize(1024);// ftpClient.setControlEncoding("iso-8859-1");// ftpClient.enterLocalPassiveMode();ftpClient.setFileType(FTP.BINARY_FILE_TYPE); fis = new FileInputStream(filePath + "/"+ fileName); Log.i("caohai", "fileStoragePath00000:"+fileStoragePath);String[] path = fileStoragePath.split("visitorRecord");boolean fs = ftpClient.storeFile(new String((path[1]+ "/photo/" + fileName).getBytes(), "iso-8859-1"), fis);Log.i("caohai", "shifoushangchuanchenggong:"+fs);fis.close();ftpClient.logout();//ftpClient.disconnect();} else {// 如果登录失败ftpClient.disconnect();}} catch (NumberFormatException e) {// TODO Auto-generated catch blocke.printStackTrace();} catch (SocketException e) {// TODO Auto-generated catch blocke.printStackTrace();} catch (FileNotFoundException e) {// TODO Auto-generated catch blocke.printStackTrace();} catch (UnsupportedEncodingException e) {// TODO Auto-generated catch blocke.printStackTrace();} catch (IOException e) {// TODO Auto-generated catch blocke.printStackTrace();}}}

Android中关于FTP的文件上传和下载

Android中关于FTP的文件上传和下载

更多相关文章

随机推荐