Android FTPUtils工具在通知栏notification显示进度

Android FTPUtils工具在通知栏notification显示进度

compile 'commons-net:commons-net:3.5'

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 java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;

public class FtpUtil {

//唯一标识
private static int NO_3 = 0x010;

/**
* Description: 向FTP服务器上传文件
* 在后台上传,带通知栏
*
* @param host     FTP服务器hostname
* @param port     FTP服务器端口
* @param username FTP登录账号
* @param password FTP登录密码
* @param basePath FTP服务器基础目录
* @param filePath FTP服务器文件存放路径。例如分日期存放：/2015/01/01。文件的路径为basePath+filePath
* @param filename 上传到FTP服务器上的文件名
* @param input    输入流
* @return 成功返回true，否则返回false
*/
public static boolean uploadFile(final Context context, String host, int port, String username, String password, String basePath,
String filePath, String filename, InputStream input) {
boolean result = false;

long len = -1;
try {
len = input.available();
if (len == -1) {
return false;
}
} catch (IOException e) {
e.printStackTrace();
}
FTPClient ftp = new FTPClient();
try {
int reply;
ftp.connect(host, port);// 连接FTP服务器
// 如果采用默认端口，可以使用ftp.connect(host)的方式直接连接FTP服务器
ftp.login(username, password);// 登录
ftp.setBufferSize(1024);
ftp.setControlEncoding("UTF-8");
ftp.enterLocalPassiveMode();
/*-------------------------------在通知栏显示上传进度----start------------------------*/
final NotificationCompat.Builder builder = new NotificationCompat.Builder(context);
builder.setSmallIcon(R.drawable.ic_launcher);
builder.setContentTitle("文件上传");
builder.setContentText("正在上传");
final NotificationManager manager = (NotificationManager)
4000
context.getSystemService(Context.NOTIFICATION_SERVICE);
manager.notify(NO_3, builder.build());
builder.setProgress(100, 0, false);
final long finalLen = len;
ftp.setCopyStreamListener(new CopyStreamListener() {
@Override
public void bytesTransferred(CopyStreamEvent copyStreamEvent) {
}

@Override
public void bytesTransferred(long l, int i, long l1) {

//总进度
float totle = finalLen;
//当前进度
float current = l;
//用于进行当前实时进度判断
float progress2 = ((current / totle) * 100);
//同于通知栏进度显示
int progress = ((int) ((current / totle) * 100));

Log.i("UploadProgress", "totle: " + totle + "  current: " + current + "  progress: " + progress);
try {
if (progress2 < 100) {
builder.setProgress(100, progress, false);
builder.setContentText("正在上传" + progress + "%");
manager.notify(NO_3, builder.build());
} else if (progress2 == 100) {
//下载进度提示
builder.setContentText("上传成功" + progress * 100 + "%");
manager.notify(NO_3, builder.build());
manager.cancel(NO_3);//设置关闭通知栏
}
} catch (Exception e) {
e.printStackTrace();
}
}
});
/*-------------------------------在通知栏显示上传进度--end--------------------------*/
reply = ftp.getReplyCode();
if (!FTPReply.isPositiveCompletion(reply)) {
ftp.disconnect();
return result;
}
//切换到上传目录
if (!ftp.changeWorkingDirectory(basePath + filePath)) {
//如果目录不存在创建目录
String[] dirs = filePath.split("/");
String tempPath = basePath;
for (String dir : dirs) {
if (null == dir || "".equals(dir)) continue;
tempPath += "/" + dir;
if (!ftp.changeWorkingDirectory(tempPath)) {
if (!ftp.makeDirectory(tempPath)) {
return result;
} else {
ftp.changeWorkingDirectory(tempPath);
}
}
}
}
//设置上传文件的类型为二进制类型
ftp.setFileType(FTP.BINARY_FILE_TYPE);
//上传文件
if (!ftp.storeFile(filename, input)) {
return result;
}
input.close();
ftp.logout();
result = true;
} catch (IOException e) {
e.printStackTrace();
} finally {
if (ftp.isConnected()) {
try {
ftp.disconnect();
} catch (IOException ioe) {
}
}
}
return result;
}

/**
* Description: 从FTP服务器下载文件
*
* @param host       FTP服务器hostname
* @param port       FTP服务器端口
* @param username   FTP登录账号
* @param password   FTP登录密码
* @param remotePath FTP服务器上的相对路径
* @param fileName   要下载的文件名
* @param localPath  下载后保存到本地的路径
* @return
*/
public static boolean downloadFile(Context context, String host, int port, String username, String password, String remotePath,
String fileName, String localPath) {
boolean result = false;
FTPClient ftp = new FTPClient();
try {
int reply;
ftp.connect(host, port);
// 如果采用默认端口，可以使用ftp.connect(host)的方式直接连接FTP服务器
ftp.login(username, password);// 登录
reply = ftp.getReplyCode();
if (!FTPReply.isPositiveCompletion(reply)) {
ftp.disconnect();
return result;
}
ftp.changeWorkingDirectory(remotePath);// 转移到FTP服务器目录
FTPFile[] fs = ftp.listFiles();
/*-------------------------------在通知栏显示上传进度----start------------------------*/
final NotificationCompat.Builder builder = new NotificationCompat.Builder(context);
builder.setSmallIcon(R.drawable.ic_launcher);
builder.setContentTitle("文件上传");
builder.setContentText("正在上传");
final NotificationManager manager = (NotificationManager) context.getSystemService(Context.NOTIFICATION_SERVICE);
manager.notify(NO_3, builder.build());
builder.setProgress(100, 0, false);
final long Len = fs.length;
ftp.setCopyStreamListener(new CopyStreamListener() {
@Override
public void bytesTransferred(CopyStreamEvent copyStreamEvent) {
}

@Override
public void bytesTransferred(long l, int i, long l1) {

//总进度
float totle = Len;
//当前进度
float current = l;
//用于进行当前实时进度判断
float progress2 = ((current / totle) * 100);
//同于通知栏进度显示
int progress = ((int) ((current / totle) * 100));

Log.i("UploadProgress", "totle: " + totle + "  current: " + current + "  progress: " + progress);
try {
if (progress2 < 100) {
builder.setProgress(100, progress, false);
builder.setContentText("正在上传" + progress + "%");
manager.notify(NO_3, builder.build());
} else if (progress2 == 100) {
//下载进度提示
builder.setContentText("上传成功" + progress * 100 + "%");
manager.notify(NO_3, builder.build());
manager.cancel(NO_3);//设置关闭通知栏
}
} catch (Exception e) {
e.printStackTrace();
}
}
});

for (FTPFile ff : fs) {
if (ff.getName().equals(fileName)) {
File localFile = new File(localPath + "/" + ff.getName());

OutputStream is = new FileOutputStream(localFile);
ftp.retrieveFile(ff.getName(), is);
is.close();
}
}

ftp.logout();
result = true;
} catch (IOException e) {
e.printStackTrace();
} finally {
if (ftp.isConnected()) {
try {
ftp.disconnect();
} catch (IOException ioe) {
}
}
}
return result;
}
}

测试方法

//上传文件在子线程中进行
public void UploadFile() {

new Thread(new Runnable() {
@Override
public void run() {

for (Map.Entry<Integer, CourseItemInfo> map : courseItemInfoMap.entrySet()) {
CourseItemInfo info = map.getValue();
//换成你的本地文件地址就可以了
String url = info.getLocalUrl();
try {
//根据日期生成路径
String filepath = "/" + TimeUtils.getTime() + "/";
//文件名
String filename = System.currentTimeMillis() + url.substring(url.lastIndexOf(".") - 1, url.length());

FileInputStream in = new FileInputStream(new File(info.getLocalUrl()));
//"/home/ftpuser/www/videos"服务器上的默认路径
boolean isUpload = FtpUtil.uploadFile(RQUri.LOCAL_UPLOAD, 21, "ftpuser", "ftpuser", "/home/ftpuser/www/videos",
filepath, filename, in);

a474
Log.i("file-path", filepath);
Log.i("file-name", filename);
if (isUpload == true) {
Log.e("upload-file", isUpload + "");
}
} catch (FileNotFoundException e) {
Log.i("file-error", e.getMessage());

}
Log.i("CourseItemInfo", "postion:==>" + map.getKey() + "  session-->" + info.getSection() + "  coursename-->" + info.getCourseName() + "   url-->" + info.getLocalUrl());

}
}
}).start();
}