虚位以待(AD)
虚位以待(AD)
首页 > 软件编程 > Android编程 > Android关于FTP文件上传和下载功能详解

Android关于FTP文件上传和下载功能详解
类别:Android编程   作者:码皇   来源:互联网   点击:

这篇文章主要为大家详细介绍了Android关于FTP文件上传和下载功能,具有一定的参考价值,感兴趣的小伙伴们可以参考一下

本文实例为大家分享了Android九宫格图片展示的具体代码,供大家参考,具体内容如下

此篇博客为整理文章,供大家学习。

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;
    }
    @Override public 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 block e.printStackTrace();
    }
    catch (SocketException e) {
    // TODO Auto-generated catch block e.printStackTrace();
    }
    catch (FileNotFoundException e) {
    // TODO Auto-generated catch block e.printStackTrace();
    }
    catch (UnsupportedEncodingException e) {
    // TODO Auto-generated catch block e.printStackTrace();
    }
    catch (IOException e) {
    // TODO Auto-generated catch block e.printStackTrace();
    }
    }
    }

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持脚本之家。

相关热词搜索: Android FTP 文件上传 文件下载