针对百度云400响应调整

zhang-pc · Mar 28, 2018 · 0ce34ec · 0ce34ec
1 parent adac5c2
commit 0ce34ec
Show file tree

Hide file tree

Showing 2 changed files with 16 additions and 2 deletions.
diff --git a/core/src/main/java/lee/study/down/handle/HttpDownInitializer.java b/core/src/main/java/lee/study/down/handle/HttpDownInitializer.java
@@ -12,6 +12,8 @@
 import io.netty.util.ReferenceCountUtil;
 import java.io.Closeable;
 import java.io.IOException;
+import java.util.concurrent.Executor;
+import java.util.concurrent.Executors;
 import lee.study.down.boot.AbstractHttpDownBootstrap;
 import lee.study.down.constant.HttpDownStatus;
 import lee.study.down.dispatch.HttpDownCallback;
@@ -26,6 +28,7 @@
 public class HttpDownInitializer extends ChannelInitializer {
 
   private static final Logger LOGGER = LoggerFactory.getLogger(HttpDownInitializer.class);
+  private static Executor executor = Executors.newFixedThreadPool(4);
 
   private boolean isSsl;
   private AbstractHttpDownBootstrap bootstrap;
@@ -122,9 +125,20 @@ public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception
               if (HttpUtil
                   .checkUrl(bootstrap.getHttpDownInfo().getRequest(), "^.*.baidupcs.com.*$")
                   && httpResponse.status().code() == 400) {
+                executor.execute(() -> {
+                  safeClose(ctx.channel());
+                  chunkInfo.setStatus(HttpDownStatus.CONNECTING_NORMAL);
+                  try {
+                    Thread.sleep(2000);
+                    bootstrap.retryChunkDown(chunkInfo);
+                  } catch (Exception e) {
+                    e.printStackTrace();
+                  }
+                });
                 return;
+              } else {
+                chunkInfo.setErrorCount(chunkInfo.getErrorCount() + 1);
               }
-              chunkInfo.setErrorCount(chunkInfo.getErrorCount() + 1);
               throw new RuntimeException("http down response error:" + httpResponse);
             }
             realContentSize = HttpDownUtil.getDownContentSize(httpResponse.headers());

diff --git a/ui/src/main/java/lee/study/down/model/ConfigBaseInfo.java b/ui/src/main/java/lee/study/down/model/ConfigBaseInfo.java
@@ -9,7 +9,7 @@ public class ConfigBaseInfo {
   private int sniffModel = 2;  //嗅探模式 1.全网 2.百度云 3.关闭
   private int uiModel = 1;  //嗅探模式 1.GUI 2.浏览器
   private int connections = 32;  //默认分段数
-  private int timeout = 10;  //超时重试时间
+  private int timeout = 30;  //超时重试时间
   private boolean secProxyEnable; //二级代理开关
   private String lastPath;  //最后保存文件的路径
   private int retryCount = 5;  //失败重试次数