upload gzip

Author: YangSen-qn

library/src/main/java/com/qiniu/android/collect/Config.java

@@ -13,7 +13,7 @@ public final class Config {
     /**
      * 上传信息收集文件的地址
      */
-    public final static String serverURL = "https://uplog.qbox.me/log/4";
+    public final static String serverURL = "https://uplog.qbox.me/log/4?compressed=gzip";
     /**
      * 是否记录上传状态信息。 true 表示记录，false 表示不记录。
      * <p>

library/src/main/java/com/qiniu/android/collect/UploadInfoCollector.java

@@ -2,11 +2,13 @@
 
 import com.qiniu.android.http.UserAgent;
 import com.qiniu.android.storage.UpToken;
+import com.qiniu.android.utils.GZipUtil;
 
 import java.io.File;
 import java.io.FileNotFoundException;
 import java.io.FileOutputStream;
 import java.io.IOException;
+import java.io.RandomAccessFile;
 import java.nio.charset.Charset;
 import java.util.Date;
 import java.util.concurrent.ExecutorService;
@@ -241,9 +243,17 @@ private void tryUploadAndClean(final UpToken upToken, File recordFile) {
 
     //同步上传
     private boolean upload(final UpToken upToken, File recordFile) {
+
+        byte[] logData = getLogData(recordFile);
+        logData = GZipUtil.gZip(logData);
+        if (logData == null || logData.length == 0){
+            return false;
+        }
+
         try {
+
             OkHttpClient client = getHttpClient();
-            RequestBody reqBody = RequestBody.create(MediaType.parse("text/plain"), recordFile);
+            RequestBody reqBody = RequestBody.create(MediaType.parse("text/plain"), logData);
 
             Request.Builder requestBuilder = new Request.Builder().url(serverURL).
                     addHeader("Authorization", "UpToken " + upToken.token).
@@ -271,6 +281,30 @@ private boolean upload(final UpToken upToken, File recordFile) {
         }
     }
 
+    private byte[] getLogData(File recordFile){
+        if (recordFile == null || recordFile.length() == 0){
+            return null;
+        }
+
+        long length = recordFile.length();
+        RandomAccessFile randomAccessFile = null;
+        byte[] data = null;
+        try {
+            randomAccessFile = new RandomAccessFile(recordFile, "r");
+            data = new byte[(int)length];
+            randomAccessFile.read(data);
+        } catch (FileNotFoundException ignored) {
+        } catch (IOException e) {
+            data = null;
+        }
+        if (randomAccessFile != null){
+            try {
+                randomAccessFile.close();
+            } catch (IOException e){}
+        }
+        return data;
+    }
+
     private boolean isOk(Response res) {
         return res.isSuccessful() && res.header("X-Reqid") != null;
     }