分片上传自定义变量

Author: sxci

src/main/java/com/qiniu/storage/ResumeUploader.java

@@ -168,7 +168,7 @@ public void accept(String key, Object value) {
                     b.append("/");
                     b.append(key);
                     b.append("/");
-                    b.append(value);
+                    b.append(UrlSafeBase64.encodeToString("" + value));
                 }
             });
         }

src/test/java/com/qiniu/storage/ResumeUploadTest.java

@@ -17,6 +17,35 @@
 
 public class ResumeUploadTest {
 
+    @Test
+    public void testXVar() throws IOException {
+        final String expectKey = "世/界";
+        File f = null;
+        try {
+            f = TempFile.createFile(1024 * 4 + 2341);
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+        assert f != null;
+        StringMap params = new StringMap().put("x:foo", "foo_val");
+        final String returnBody = "{\"key\":\"$(key)\",\"hash\":\"$(etag)\",\"fsize\":\"$(fsize)\""
+                + ",\"fname\":\"$(fname)\",\"mimeType\":\"$(mimeType)\",\"foo\":\"$(x:foo)\"}";
+        String token = TestConfig.testAuth.uploadToken(TestConfig.bucket, expectKey, 3600,
+                new StringMap().put("returnBody", returnBody));
+
+        try {
+            UploadManager uploadManager = new UploadManager();
+            Response res = uploadManager.put(f, expectKey, token, params, null, true);
+            StringMap m = res.jsonToMap();
+            assertEquals("foo_val", m.get("foo"));
+        } catch (QiniuException e) {
+            assertEquals("", e.response.bodyString());
+            fail();
+        } finally {
+            TempFile.remove(f);
+        }
+    }
+
     private void template(int size) throws IOException {
         final String expectKey = "\r\n?&r=" + size + "k";
         final File f = TempFile.createFile(size);