recorder

Author: longbai

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

@@ -30,5 +30,12 @@ public interface Recorder {
      */
     void del(String key);
 
+    /**
+     * 根据服务器的key和本地文件名生成持久化纪录的key
+     *
+     * @param key  服务器的key
+     * @param file 本地文件名
+     * @return 持久化上传纪录的key
+     */
     String recorderKeyGenerate(String key, File file);
 }

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

@@ -25,12 +25,7 @@
  */
 public class RecordUploadTest {
     final Random r = new Random();
-    final RecordKeyGenerator keyGen = new RecordKeyGenerator() {
-        @Override
-        public String gen(String key, File file) {
-            return key + "_._" + file.getAbsolutePath();
-        }
-    };
+
     final Client client = new Client();
     FileRecorder recorder = null;
     private Response response = null;
@@ -42,7 +37,7 @@ private void template(final int size) throws IOException {
         recorder = new FileRecorder(f.getParentFile());
         try {
             final String token = TestConfig.testAuth.uploadToken(TestConfig.bucket, expectKey);
-            final String recordKey = keyGen.gen(expectKey, f);
+            final String recordKey = recorder.recorderKeyGenerate(expectKey, f);
 
             // 开始第一部分上传
             final Up up = new Up(f, expectKey, token);
@@ -273,13 +268,11 @@ public Response up() throws Exception {
                 System.out.println("UP: " + i + ",  enter up");
 
                 String recorderKey = key;
-                if (keyGen != null) {
-                    recorderKey = keyGen.gen(key, file);
-                }
 
                 if (recorder == null) {
                     recorder = new FileRecorder(file.getParentFile());
                 }
+                recorderKey = recorder.recorderKeyGenerate(key, file);
                 uploader = new ResumeUploader(client, token, key, file,
                         null, Client.DefaultMime, recorder, new Configuration(Zone.zone0()));
                 Response res = uploader.upload();