Android平台的用户行为记录解决方案

在我们展开讨论之前，首先要明白什么是用户行为记录？

我的理解是 用户行为记录是针对使用我们软件的用户的信息统计，这些信息主要是 用户的操作信息 以及 其他一些相关感兴趣的日志信息，这些信息通常由用户的操作而产生，经我们包装处理后上传到服务器，以供数据分析员使用分析。不要小看这些信息，分析信息可以让我们了解软件的用户群，平台信息，以及用户的操作习惯等，现在已经有越来越多的开发者和公司重试并利用这一块。

ok,既然我们是讨论解决方案的，闲话之后直入主题，怎么做？

1.用户行为记录信息的组成 一条完整有价值的用户行为记录应该包含哪些内容呢？无疑，用户本身的点击代表的操作是主要信息，比如用户在支付页面点击了支付，这样的一个行为能提取出“支付页”和“支付”两个有价值的信息，此外，产生这个操作的时间戳信息，用户的机器信息（手机型号等），SDK版本号以及用户的网络类型信息等。

2.用户行为记录从哪来？到哪去？ 每一条用户行为记录都是由用户的操作产生的，这些信息最终会被上传到服务端保存分析。我们要做的工作就是将每条有价值的用户行为记录信息保存并上传至服务器。当然，出于应用耗电量以及程序效率的考虑，我们不可能在每次用户产生操作记录时，都发送服务将信息上传到服务器。所以我们可以采用 缓存--文件--上传服务器的策略。

明白了上面这些信息，解决方案就出来了。

/**
 * 用户行为记录
 * 
 * @author derson2388
 *
 */
public class UserActionManager {

    private static UserActionManager manager;

    /**
     * 工作线程消息队列处理
     */
    private Handler mHandler;
    /**
     * 日志缓存
     */
    private ArrayList<String> mCache = new ArrayList<String>();

    /**
     * 单例访问，同步上锁
     * 
     * @return
     */
    public synchronized UserActionManager getInstance() {
        if (null == manager) {
            manager = new UserActionManager();
        }
        return manager;
    }

    private UserActionManager() {
        new Thread(new Runnable() {

            @Override
            public void run() {
                // 新启动一个工作线程，启动Looper后创建handler处理写入请求
                Looper.prepare();
                mHandler = new Handler(Looper.myLooper());
                Looper.loop();
            }
        }).start();
    }
}

上面的代码有几点值得注意：

1.UserActionManager为全局程序提供了一个单例访问的实例，缓存cache用于缓存用户行为记录，当缓存到达一定的阀值时，才把缓存里的日志写入文件，当文件大小到达一定大小时，才将日志信息通过网络发送到服务器。

2.构造函数里在新启的工作线程里启动了一个新的Looper并以此构造了一个专门处理该工作线程消息队列的handler,这样记录用户，写入文件，上传服务器等都可以通过这个handler分发/处理到工作线程的消息队列MessageQueue里，避免了主线程ANR的风险。

    /**
     * 用户行为记录
     * 
     * @param action
     */
    public synchronized void writeUserCode(String action) {
        // TODO 在这里对用户行为信息做格式化组装
        mCache.add(action);
        if (mCache.size() > MAXSIZE_CACHE) {
            if (null != mHandler) {
                mHandler.post(new Runnable() {

                    @Override
                    public void run() {
                        if (!isSending) {
                            // 写日志到文件
                            pushToFile();
                            // 发送日志到服务端
                            sendActionToServer();
                        }
                    }
                });
            }
        }
    }

在监听到用户操作的时候调用记录方法，先将信息存入缓存，当缓存到达阀值时，清空缓存并写入文件。

    /**
     * 写入文件
     */
    private void pushToFile() {
        String logs = "";
        // 组装信息
        for (String str : mCache) {
            logs += str + "\n";
        }
        // 清空缓存日志
        mCache.clear();
        File file = new File(userActionFilePath);
        if (!file.exists()) {
            try {
                file.createNewFile();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
        BufferedWriter writer = null;
        try {
            writer = new BufferedWriter(new OutputStreamWriter(new FileOutputStream(file)));
            writer.write(logs + "\n");
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            if (null != writer) {
                try {
                    writer.close();
                } catch (IOException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
            }
        }
    }

    private void sendActionToServer() {
        if (!isSending && null != mHandler) {
            mHandler.post(new Runnable() {

                @Override
                public void run() {
                    if (isSending) {
                        return;
                    }
                    File temp = new File(userActionFilePath);
                    if (null != temp) {
                        long length = temp.length();
                        if (length > MAXSIZE_FILE_CACHE) {
                            // 文件大于阀值，删除文件，重置重试次数
                            retryCount = 0;
                            return;
                        }
                        if (length > SIZE_FILE_CACHE && retryCount >= 3) {
                            // 文件大小大于设置值并失败次数大于3次，删除文件重置重试次数
                            retryCount = 0;
                            return;
                        }
                        // 开始发送服务
                        isSending = true;
                        new Thread(new Runnable() {

                            @Override
                            public void run() {
                                if (sendService()) {
                                    // 发送服务成功，清空文件内容
                                    retryCount = 0;
                                } else {
                                    // 发送服务失败，增加重试次数
                                    retryCount++;
                                }
                                // 服务发送完毕，重置标记位
                                isSending = false;
                            }
                        }).start();
                    }
                }
            });
        }
    }

以上代码在文件大小大于阀值时会删除了文件，在发送服务次数到达了3次后删除文件。