修复map长度问题，更新版本至1.6

proxyee-down-org · Jan 3, 2018 · 0510ab9 · 0510ab9
1 parent 89e9bd5
commit 0510ab9
Show file tree

Hide file tree

Showing 4 changed files with 6 additions and 8 deletions.
diff --git a/pom.xml b/pom.xml
@@ -9,7 +9,7 @@
   </parent>
   <groupId>lee.study</groupId>
   <artifactId>proxyee-down</artifactId>
-  <version>1.5</version>
+  <version>1.6</version>
 
   <build>
     <plugins>

diff --git a/src/main/java/lee/study/down/hanndle/HttpDownInitializer.java b/src/main/java/lee/study/down/hanndle/HttpDownInitializer.java
@@ -126,9 +126,11 @@ public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception
                 "下载响应：" + chunkInfo.getIndex() + "\t" + chunkInfo.getDownSize() + "\t"
                     + httpResponse.headers().get(
                     HttpHeaderNames.CONTENT_RANGE) + "\t" + realContentSize);
-            FileChannel fileChannel = new RandomAccessFile(taskInfo.buildTaskFilePath(), "rw").getChannel();
+            FileChannel fileChannel = new RandomAccessFile(taskInfo.buildTaskFilePath(), "rw")
+                .getChannel();
             MappedByteBuffer mappedBuffer = fileChannel.map(MapMode.READ_WRITE,
-                chunkInfo.getOriStartPosition() + chunkInfo.getDownSize(), chunkInfo.getTotalSize());
+                chunkInfo.getOriStartPosition() + chunkInfo.getDownSize(),
+                chunkInfo.getTotalSize() - chunkInfo.getDownSize());
             chunkInfo.setStatus(1);
             chunkInfo.setFileChannel(fileChannel);
             chunkInfo.setMappedBuffer(mappedBuffer);

diff --git a/src/main/java/lee/study/down/util/FileUtil.java b/src/main/java/lee/study/down/util/FileUtil.java
@@ -12,10 +12,6 @@
 
 public class FileUtil {
 
-  public static RandomAccessFile getRafFile(String path) throws IOException {
-    return new RandomAccessFile(path, "rw");
-  }
-
   /**
    * 删除文件或文件夹
    */

diff --git a/src/main/java/lee/study/down/util/HttpDownUtil.java b/src/main/java/lee/study/down/util/HttpDownUtil.java
@@ -384,7 +384,7 @@ public static void safeClose(Channel channel, ChunkInfo chunkInfo) {
   }
 
   public static boolean setStatusIfNotDone(ChunkInfo chunkInfo, int update) {
-    if (chunkInfo.getStatus() != 2 && chunkInfo.getStatus() != update) {
+    if (chunkInfo.getStatus() != 2) {
       chunkInfo.setStatus(update);
       return true;
     }