首先我们要用到commons-net-3.3.jar包
可以去网上下载
找不到可私信我
好了，下面直接上代码
封装了一个类出来可直接使用
import android.util.Log;
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 java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
/**
* FTP封装类.
*/
public class FTP {
/**
* 服务器名.
*/
private String hostName;
/**
* 用户名.
*/
private String userName;
/**
* 密码.
*/
private String password;
/**
* FTP连接.
*/
private FTPClient ftpClient;
/**
* FTP列表.
*/
private List<FTPFile> list;
/**
* FTP根目录.
*/
public static final String REMOTE_PATH = "\\";
public static final String REMOTE_PATH2 = "\\bbb\\";
/**
* FTP当前目录.
*/
private String currentPath = "";
/**
* 统计流量.
*/
private double response;
/**
* 构造函数.
*
* @param host
* hostName 服务器名
* @param user
* userName 用户名
* @param pass
* password 密码
*/
public FTP(String host, String user, String pass) {
this.hostName = host;
this.userName = user;
this.password = pass;
this.ftpClient = new FTPClient();
this.list = new ArrayList<FTPFile>();
}
/**
* 打开FTP服务.
*
* @throws IOException
*/
public boolean openConnect() throws IOException {
// 中文转码
ftpClient.setControlEncoding("UTF-8");
int reply; // 服务器响应值
// 连接至服务器
ftpClient.connect(hostName);
// 获取响应值
reply = ftpClient.getReplyCode();
if (!FTPReply.isPositiveCompletion(reply)) {
// 断开连接
ftpClient.disconnect();
throw new IOException("connect fail: " + reply);
}
// 登录到服务器
boolean login = ftpClient.login(userName, password);
// 获取响应值
reply = ftpClient.getReplyCode();
if (!FTPReply.isPositiveCompletion(reply)) {
// 断开连接
ftpClient.disconnect();
throw new IOException("connect fail: " + reply);
} else {
// 获取登录信息
FTPClientConfig config = new FTPClientConfig(ftpClient.getSystemType().split(" ")[0]);
config.setServerLanguageCode("zh");
ftpClient.configure(config);
// 使用被动模式设为默认
ftpClient.enterLocalPassiveMode();
// 二进制文件支持
ftpClient.setFileType(org.apache.commons.net.ftp.FTP.BINARY_FILE_TYPE);
System.out.println("login");
}
return login;
}
/**
* 关闭FTP服务.
*
* @throws IOException
*/
public void closeConnect() throws IOException {
if (ftpClient != null) {
if (ftpClient.isConnected()) {
// 登出FTP
ftpClient.logout();
// 断开连接
ftpClient.disconnect();
System.out.println("logout");
}
}
}
/**
* 列出FTP下所有文件.
*
* @param remotePath
* 服务器目录
* @return FTPFile集合
* @throws IOException
*/
public List<FTPFile> listFiles(String remotePath) throws IOException {
if (ftpClient != null) {
// 获取文件
try {
FTPFile[] files = ftpClient.listFiles(remotePath);
if (files != null && files.length > 0) {
// 遍历并且添加到集合
for (FTPFile file : files) {
list.add(file);
}
}
} catch (Exception e) {
Log.e("TAG", "请稍等...");
}
}
return list;
}
/**
* 下载.
*
* @param remotePath
* FTP目录
* @param fileName
* 文件名
* @param localPath
* 本地目录
* @return Result
* @throws IOException
*/
public Result download(String remotePath, String fileName, String localPath) throws IOException {
boolean flag = true;
Result result = null;
// 初始化FTP当前目录
currentPath = remotePath;
// 初始化当前流量
response = 0;
// 更改FTP目录
ftpClient.changeWorkingDirectory(remotePath);
// 得到FTP当前目录下所有文件
FTPFile[] ftpFiles = ftpClient.listFiles();
// 循环遍历
for (FTPFile ftpFile : ftpFiles) {
// 找到需要下载的文件
if (ftpFile.getName().equals(fileName)) {
System.out.println("download...");
// 创建本地目录
File file = new File(localPath + "/" + fileName);
// 下载前时间
Date startTime = new Date();
if (ftpFile.isDirectory()) {
// 下载多个文件
flag = downloadMany(file);
} else {
// 下载当个文件
flag = downloadSingle(file, ftpFile);
}
// 下载完时间
Date endTime = new Date();
// 返回值
result = new Result(flag, Util.getFormatTime(endTime.getTime() - startTime.getTime()),
Util.getFormatSize(response));
}
}
return result;
}
/**
* 下载单个文件.
*
* @param localFile
* 本地目录
* @param ftpFile
* FTP目录
* @return true下载成功, false下载失败
* @throws IOException
*/
private boolean downloadSingle(File localFile, FTPFile ftpFile) throws IOException {
boolean flag = true;
// 创建输出流
OutputStream outputStream = new FileOutputStream(localFile);
// 统计流量
response += ftpFile.getSize();
// 下载单个文件
flag = ftpClient.retrieveFile(localFile.getName(), outputStream);
// 关闭文件流
outputStream.close();
return flag;
}
/**
* 下载多个文件.
*
* @param localFile
* 本地目录
* @return true下载成功, false下载失败
* @throws IOException
*/
private boolean downloadMany(File localFile) throws IOException {
boolean flag = true;
// FTP当前目录
if (!currentPath.equals(REMOTE_PATH)) {
currentPath = currentPath + REMOTE_PATH + localFile.getName();
} else {
currentPath = currentPath + localFile.getName();
}
// 创建本地文件夹
localFile.mkdir();
// 更改FTP当前目录
ftpClient.changeWorkingDirectory(currentPath);
// 得到FTP当前目录下所有文件
FTPFile[] ftpFiles = ftpClient.listFiles();
// 循环遍历
for (FTPFile ftpFile : ftpFiles) {
// 创建文件
File file = new File(localFile.getPath() + "/" + ftpFile.getName());
if (ftpFile.isDirectory()) {
// 下载多个文件
flag = downloadMany(file);
} else {
// 下载单个文件
flag = downloadSingle(file, ftpFile);
}
}
return flag;
}
/**
* 上传.
*
* @param localFile
* 本地文件
* @param remotePath
* FTP目录
* @return Result
* @throws IOException
*/
public Result uploading(File localFile, String remotePath) throws IOException {
boolean flag = true;
Result result = null;
// 初始化FTP当前目录
currentPath = remotePath;
// 初始化当前流量
response = 0;
// 二进制文件支持
ftpClient.setFileType(org.apache.commons.net.ftp.FTP.BINARY_FILE_TYPE);
// 使用被动模式设为默认
ftpClient.enterLocalPassiveMode();
// 设置模式
ftpClient.setFileTransferMode(org.apache.commons.net.ftp.FTP.STREAM_TRANSFER_MODE);
// 改变FTP目录
ftpClient.changeWorkingDirectory(REMOTE_PATH);
// 获取上传前时间
Date startTime = new Date();
if (localFile.isDirectory()) {
// 上传多个文件
flag = uploadingMany(localFile);
} else {
// 上传单个文件
flag = uploadingSingle(localFile);
}
// 获取上传后时间
Date endTime = new Date();
// 返回值
result = new Result(flag, Util.getFormatTime(endTime.getTime() - startTime.getTime()),
Util.getFormatSize(response));
return result;
}
/**
* 上传单个文件.
*
* @param localFile
* 本地文件
* @return true上传成功, false上传失败
* @throws IOException
*/
private boolean uploadingSingle(File localFile) throws IOException {
boolean flag = true;
// 创建输入流
InputStream inputStream = new FileInputStream(localFile);
// 统计流量
response += (double) inputStream.available() / 1;
// 上传单个文件
flag = ftpClient.storeFile(localFile.getName(), inputStream);
// 关闭文件流
inputStream.close();
return flag;
}
/**
* 上传多个文件.
*
* @param localFile
* 本地文件夹
* @return true上传成功, false上传失败
* @throws IOException
*/
private boolean uploadingMany(File localFile) throws IOException {
boolean flag = true;
// FTP当前目录
if (!currentPath.equals(REMOTE_PATH)) {
currentPath = currentPath + REMOTE_PATH + localFile.getName();
} else {
currentPath = currentPath + localFile.getName();
}
// FTP下创建文件夹
ftpClient.makeDirectory(currentPath);
// 更改FTP目录
ftpClient.changeWorkingDirectory(currentPath);
// 得到当前目录下所有文件
File[] files = localFile.listFiles();
// 遍历得到每个文件并上传
for (File file : files) {
if (file.isHidden()) {
continue;
}
if (file.isDirectory()) {
// 上传多个文件
flag = uploadingMany(file);
} else {
// 上传单个文件
flag = uploadingSingle(file);
}
}
return flag;
}
}
Result类如下：
/**
* 执行每一个动作后响应的结果，包括成功的和失败的.
*/
public class Result {
/**
* 响应的内容.
*/
private String response;
/**
* 响应的结果.
*/
private boolean succeed;
/**
* 响应的时间.
*/
private String time;
/**
* 无参的构造方法.
*/
public Result() {
}
/**
* 构造方法.
*
* @param res 响应的内容
*/
public Result(String res) {
this.response = res;
}
/**
* 构造方法.
*
* @param suc 响应的结果
* @param ti 响应的时间
* @param res 响应的内容
*/
public Result(boolean suc, String ti, String res) {
this.succeed = suc;
this.time = ti;
this.response = res;
}
/**
* 得到相应内容.
*
* @return 相应内容
*/
public String getResponse() {
return response;
}
/**
* 设置相应内容.
*
* @param response 响应内容
*/
public void setResponse(String response) {
this.response = response;
}
/**
* 得到相应结果.
*
* @return 相应结果
*/
public boolean isSucceed() {
return succeed;
}
/**
* 设置响应结果.
*
* @param succeed 响应结果
*/
public void setSucceed(boolean succeed) {
this.succeed = succeed;
}
/**
* 得到响应时间.
*
* @return 响应时间
*/
public String getTime() {
return time;
}
/**
* 设置响应时间.
*
* @param time 响应时间
*/
public void setTime(String time) {
this.time = time;
}
}
记得先使用openConnect方法打开FTP服务
在进行下载或上传
最后记得调用closeConnect方法关闭FTP服务
贴一下Util工具类
import java.io.UnsupportedEncodingException;
import java.math.BigDecimal;
/**
* 工具类.
*/
public final class Util {
/**
* 存储单位.
*/
private static final int STOREUNIT = 1024;
/**
* 时间毫秒单位.
*/
private static final int TIMEMSUNIT = 1000;
/**
* 时间单位.
*/
private static final int TIMEUNIT = 60;
/**
* 私有构造函数.
*/
private Util() {
}
/**
* 转化文件单位.
* @param size 转化前大小(byte)
* @return 转化后大小
*/
public static String getFormatSize(double size) {
double kiloByte = size / STOREUNIT;
if (kiloByte < 1) {
return size + " Byte";
}
double megaByte = kiloByte / STOREUNIT;
if (megaByte < 1) {
BigDecimal result = new BigDecimal(Double.toString(kiloByte));
return result.setScale(2, BigDecimal.ROUND_HALF_UP).toPlainString() + " KB";
}
double gigaByte = megaByte / STOREUNIT;
if (gigaByte < 1) {
BigDecimal result = new BigDecimal(Double.toString(megaByte));
return result.setScale(2, BigDecimal.ROUND_HALF_UP).toPlainString() + " MB";
}
double teraBytes = gigaByte / STOREUNIT;
if (teraBytes < 1) {
BigDecimal result = new BigDecimal(Double.toString(gigaByte));
return result.setScale(2, BigDecimal.ROUND_HALF_UP).toPlainString() + " GB";
}
BigDecimal result = new BigDecimal(teraBytes);
return result.setScale(2, BigDecimal.ROUND_HALF_UP).toPlainString() + " TB";
}
/**
* 转化时间单位.
* @param time 转化前大小(MS)
* @return 转化后大小
*/
public static String getFormatTime(long time) {
double second = (double) time / TIMEMSUNIT;
if (second < 1) {
return time + " MS";
}
double minute = second / TIMEUNIT;
if (minute < 1) {
BigDecimal result = new BigDecimal(Double.toString(second));
return result.setScale(2, BigDecimal.ROUND_HALF_UP).toPlainString() + " SEC";
}
double hour = minute / TIMEUNIT;
if (hour < 1) {
BigDecimal result = new BigDecimal(Double.toString(minute));
return result.setScale(2, BigDecimal.ROUND_HALF_UP).toPlainString() + " MIN";
}
BigDecimal result = new BigDecimal(Double.toString(hour));
return result.setScale(2, BigDecimal.ROUND_HALF_UP).toPlainString() + " H";
}
/**
* 转化字符串.
* @param source 转化前字符串
* @param encoding 编码格式
* @return 转化后字符串
*/
public static String convertString(String source, String encoding) {
try {
byte[] data = source.getBytes("ISO8859-1");
return new String(data, encoding);
} catch (UnsupportedEncodingException ex) {
return source;
}
}
}
有帮助的话记得点赞哈！
