androidgit图片轮询,GitHubGiftedcat/UploadHelpUseDemo:Android中实现异步轮询上传文件...

Android中实现异步轮询上传文件

前言

前段时间要求项目中需要实现一个刷卡考勤的功能&＃xff0c;因为涉及到上传图片文件&＃xff0c;为加快考勤的速度&＃xff0c;封装了一个异步轮询上传文件的帮助类

效果

先上效果图

设计思路

数据库使用的框架是GreenDao&＃xff0c;一个非常好用的东西

先创建一个GreenDao的数据表的实体

来保存我们的考勤记录&＃xff0c;我这边只写了一下几个参数&＃xff0c;方便大家观看&＃xff0c;使用的时候大家记得要编译一下来生成Dao文件跟get&＃xff0c;set方法

&＃64;Entity

public class Attendance {

&＃64;Id(autoincrement &＃61; true)

public Long id;

/**

* 是否已上传

* */

public Boolean isUpload;

/**

* 文件路径

* */

public String path;

/**

* 姓名

* */

private String name;

/**

* 考勤时间

* */

private Date attendanceDate;

}

帮助类的实现

首先是轮询线程判断是否运行

/**

* 开启上传线程

*/

public void startUpThread() {

if (!isRun) {

return;

}

singleThreadExecutor.execute(upRunnable);

}

线程需要注意内存泄露&＃xff0c;这个是必须的

/**

* 自建一个Runnable判断activity是否销毁&＃xff0c;防止内存泄露

* */

private class UpRunnable implements Runnable {

private WeakReference activityWeakReference;

public UpRunnable(Activity activity) {

//使用弱引用赋值

activityWeakReference &＃61; new WeakReference<>(activity);

}

&＃64;Override

public void run() {

//判断activity是否已销毁

if (activityWeakReference.get() !&＃61; null){

upRecord();

}

}

}

先查询队列判断是否有数据需要上传

没有需要上传的数据延迟两秒后从数据库查询并填充队列

开始下一次的轮询

private void upRecord() {

Attendance Attendance &＃61; queue.poll();

if (null &＃61;&＃61; Attendance) {

//没有需要上传的文件

LogUtils.d("上传队列为空 2秒后开始 检查是否存在上报");

try {

Thread.sleep(2000);

} catch (InterruptedException e) {

e.printStackTrace();

}

handleLocalAttendance();

startUpThread();

} else {

//有需要上传的文件&＃xff0c;回调给页面

if (onUploadListener !&＃61; null) {

onUploadListener.onUpload(Attendance);

} else {

startUpThread();

}

}

}

查询数据库的代码

/**

* 查询是否有上传任务

*/

private void handleLocalAttendance() {

List attendances &＃61; DBHelper.getInstance().getSession().getAttendanceDao()

.queryBuilder().where(AttendanceDao.Properties.IsUpload.eq(false))

.list();

if (null !&＃61; attendances && attendances.size() > 0) {

queue.addAll(attendances);

}

}

帮助类的使用

首先是先在初始化帮助类

UploadHelper uploadHelper &＃61; new UploadHelper(this);

uploadHelper.setOnUploadListener(new OnUploadListener() {

&＃64;Override

public void onUpload(Attendance attendance) {

//有需要上传的文件

uploadToServer(attendance);

}

});

uploadHelper.startUpThread();

接口调用成功后标记成功&＃xff0c;开始下一次的轮询

uploadHelper.uploadSuccess(dataModel);

在打卡回调中添加数据库记录&＃xff0c;这样轮询线程就会查到

//数据库

Attendance attendance &＃61; new Attendance();

attendance.setPath(Environment.getExternalStorageDirectory() &＃43; "/" &＃43; "Images/picture.png");

attendance.setIsUpload(false);

attendance.setName("张三");

attendance.setAttendanceDate(new Date());

uploadHelper.addRecord(attendance);

updateDataList();