修改RPC的超时时间

byit-myth-core/myth-admin-core/src/main/java/com/byit/service/impl/RunJavaServiceImpl.java

@@ -13,7 +13,7 @@ import org.springframework.stereotype.Service;
  */
 @Service
 public class RunJavaServiceImpl implements RunJavaService {
-    @TaskClient
+    @TaskClient(timeout = 30000)
     private TaskServer taskServer;
 
     @Override

byit-myth-core/myth-admin-core/src/main/java/com/byit/service/impl/RunScriptServiceImpl.java

@@ -12,7 +12,7 @@ import org.springframework.stereotype.Service;
  */
 @Service
 public class RunScriptServiceImpl implements RunScriptService {
-    @RpcReference
+    @RpcReference(timeout = 30000)
     private ScriptExecutorService scriptExecutorService;
     @Override
     public DispatchResponseDto runScript(ScriptDto scriptDto) {

byit-myth-core/myth-admin-core/src/main/java/com/byit/thread/helper/JavaTaskThreadRunHelper.java

@@ -48,10 +48,11 @@ public class JavaTaskThreadRunHelper  extends BaseThreadRunHelper {
                         javaTaskService.deleteJob(javaTask.getId());
                     }
 
-                }
+                }else{
                     javaTaskAndLogService.updateJavaTaskAndSaveLog(javaTask);
                 }
             }
+        }
         return JAVA_TASK_WAIT_TIME;
     }
 

byit-plugin-core/myth-plugin-rpc-client/src/main/java/com/byit/init/PluginClientInitialization.java

@@ -13,6 +13,7 @@ import org.apache.commons.lang3.StringUtils;
 import java.lang.reflect.Proxy;
 import java.util.TreeSet;
 import java.util.UUID;
+import java.util.concurrent.TimeUnit;
 
 /**
  * 插件端 客户端的数据初始化
@@ -88,7 +89,7 @@ public class PluginClientInitialization {
                         //发送请求
                         pluginClient.send(address,pluginRpcRequestPacket);
                         //获取结果
-                        PluginRpcResponsePacket pluginRpcResponsePacket = pluginFutureResponse.get();
+                        PluginRpcResponsePacket pluginRpcResponsePacket = pluginFutureResponse.get(timeout, TimeUnit.MILLISECONDS);
                         pluginRpcResponsePacket.setRunIp(address);
                         return pluginRpcResponsePacket;
                     }catch (Exception e){