1 /**
 2  * 用户行为记录
 3  *
 4  * @author derson2388
 5  *
 6  */
 7 public class UserActionManager {
 8
 9     private static UserActionManager manager;
10
11     /**
12      * 工作线程消息队列处理
13      */
14     private Handler mHandler;
15     /**
16      * 日志缓存
17      */
18     private ArrayList<String> mCache = new ArrayList<String>();
19
20     /**
21      * 单例访问，同步上锁
22      *
23      * @return
24      */
25     public synchronized UserActionManager getInstance() {
26         if (null == manager) {
27             manager = new UserActionManager();
28         }
29         return manager;
30     }
31
32     private UserActionManager() {
33         new Thread(new Runnable() {
34
35             @Override
36             public void run() {
37                 // 新启动一个工作线程，启动Looper后创建handler处理写入请求
38                 Looper.prepare();
39                 mHandler = new Handler(Looper.myLooper());
40                 Looper.loop();
41             }
42         }).start();
43     }
44 }

 1     /**
 2      * 用户行为记录
 3      *
 4      * @param action
 5      */
 6     public synchronized void writeUserCode(String action) {
 7         // TODO 在这里对用户行为信息做格式化组装
 8         mCache.add(action);
 9         if (mCache.size() > MAXSIZE_CACHE) {
10             if (null != mHandler) {
11                 mHandler.post(new Runnable() {
12
13                     @Override
14                     public void run() {
15                         if (!isSending) {
16                             // 写日志到文件
17                             pushToFile();
18                             // 发送日志到服务端
19                             sendActionToServer();
20                         }
21                     }
22                 });
23             }
24         }
25     }

 1     /**
 2      * 写入文件
 3      */
 4     private void pushToFile() {
 5         String logs = "";
 6         // 组装信息
 7         for (String str : mCache) {
 8             logs += str + "\n";
 9         }
10         // 清空缓存日志
11         mCache.clear();
12         File file = new File(userActionFilePath);
13         if (!file.exists()) {
14             try {
15                 file.createNewFile();
16             } catch (IOException e) {
17                 e.printStackTrace();
18             }
19         }
20         BufferedWriter writer = null;
21         try {
22             writer = new BufferedWriter(new OutputStreamWriter(new FileOutputStream(file)));
23             writer.write(logs + "\n");
24         } catch (Exception e) {
25             e.printStackTrace();
26         } finally {
27             if (null != writer) {
28                 try {
29                     writer.close();
30                 } catch (IOException e) {
31                     // TODO Auto-generated catch block
32                     e.printStackTrace();
33                 }
34             }
35         }
36     }

 1     private void sendActionToServer() {
 2         if (!isSending && null != mHandler) {
 3             mHandler.post(new Runnable() {
 4
 5                 @Override
 6                 public void run() {
 7                     if (isSending) {
 8                         return;
 9                     }
10                     File temp = new File(userActionFilePath);
11                     if (null != temp) {
12                         long length = temp.length();
13                         if (length > MAXSIZE_FILE_CACHE) {
14                             // 文件大于阀值，删除文件，重置重试次数
15                             retryCount = 0;
16                             return;
17                         }
18                         if (length > SIZE_FILE_CACHE && retryCount >= 3) {
19                             // 文件大小大于设置值并失败次数大于3次，删除文件重置重试次数
20                             retryCount = 0;
21                             return;
22                         }
23                         // 开始发送服务
24                         isSending = true;
25                         new Thread(new Runnable() {
26
27                             @Override
28                             public void run() {
29                                 if (sendService()) {
30                                     // 发送服务成功，清空文件内容
31                                     retryCount = 0;
32                                 } else {
33                                     // 发送服务失败，增加重试次数
34                                     retryCount++;
35                                 }
36                                 // 服务发送完毕，重置标记位
37                                 isSending = false;
38                             }
39                         }).start();
40                     }
41                 }
42             });
43         }
44     }