diff --git a/snail-job-client/snail-job-client-common/src/main/java/com/aizuda/snailjob/client/common/NettyClient.java b/snail-job-client/snail-job-client-common/src/main/java/com/aizuda/snailjob/client/common/NettyClient.java index 70a1ab8be..afc5a28a4 100644 --- a/snail-job-client/snail-job-client-common/src/main/java/com/aizuda/snailjob/client/common/NettyClient.java +++ b/snail-job-client/snail-job-client-common/src/main/java/com/aizuda/snailjob/client/common/NettyClient.java @@ -3,7 +3,12 @@ package com.aizuda.snailjob.client.common; import com.aizuda.snailjob.client.common.annotation.Mapping; import com.aizuda.snailjob.client.common.rpc.client.RequestMethod; import com.aizuda.snailjob.common.core.constant.SystemConstants.HTTP_PATH; +import com.aizuda.snailjob.common.core.model.NettyResult; import com.aizuda.snailjob.common.core.model.Result; +import com.aizuda.snailjob.server.model.dto.LogTaskDTO; +import com.aizuda.snailjob.server.model.dto.RetryTaskDTO; + +import java.util.List; /** @@ -15,11 +20,16 @@ import com.aizuda.snailjob.common.core.model.Result; */ public interface NettyClient { - @Mapping(method = RequestMethod.GET, path = HTTP_PATH.SYNC_CONFIG) + @Mapping(method = RequestMethod.POST, path = HTTP_PATH.BATCH_REPORT) + NettyResult reportRetryInfo(List list); + + @Mapping(method = RequestMethod.POST, path = HTTP_PATH.BATCH_LOG_REPORT) + NettyResult reportLogTask(List list); + + @Mapping(method = RequestMethod.POST, path = HTTP_PATH.SYNC_CONFIG) Result syncRemoteConfig(); - @Mapping(method = RequestMethod.GET, path = HTTP_PATH.BEAT) + @Mapping(method = RequestMethod.POST, path = HTTP_PATH.BEAT) Result beat(String mark); - } diff --git a/snail-job-client/snail-job-client-common/src/main/java/com/aizuda/snailjob/client/common/client/NettyClient.java b/snail-job-client/snail-job-client-common/src/main/java/com/aizuda/snailjob/client/common/client/NettyClient.java deleted file mode 100644 index db1ba9543..000000000 --- a/snail-job-client/snail-job-client-common/src/main/java/com/aizuda/snailjob/client/common/client/NettyClient.java +++ /dev/null @@ -1,28 +0,0 @@ -package com.aizuda.snailjob.client.common.client; - -import com.aizuda.snailjob.client.common.annotation.Mapping; -import com.aizuda.snailjob.client.common.rpc.client.RequestMethod; -import com.aizuda.snailjob.common.core.constant.SystemConstants.HTTP_PATH; -import com.aizuda.snailjob.common.core.model.NettyResult; -import com.aizuda.snailjob.server.model.dto.LogTaskDTO; -import com.aizuda.snailjob.server.model.dto.RetryTaskDTO; - -import java.util.List; - - -/** - * netty 客户端请求类 - * - * @author: opensnail - * @date : 2023-05-11 21:28 - * @since 1.3.0 - */ -public interface NettyClient { - - @Mapping(method = RequestMethod.POST, path = HTTP_PATH.BATCH_REPORT) - NettyResult reportRetryInfo(List list); - - @Mapping(method = RequestMethod.POST, path = HTTP_PATH.BATCH_LOG_REPORT) - NettyResult reportLogTask(List list); - -} diff --git a/snail-job-client/snail-job-client-common/src/main/java/com/aizuda/snailjob/client/common/log/report/ReportLogListener.java b/snail-job-client/snail-job-client-common/src/main/java/com/aizuda/snailjob/client/common/log/report/ReportLogListener.java index 378703631..e747f092e 100644 --- a/snail-job-client/snail-job-client-common/src/main/java/com/aizuda/snailjob/client/common/log/report/ReportLogListener.java +++ b/snail-job-client/snail-job-client-common/src/main/java/com/aizuda/snailjob/client/common/log/report/ReportLogListener.java @@ -1,6 +1,6 @@ package com.aizuda.snailjob.client.common.log.report; -import com.aizuda.snailjob.client.common.client.NettyClient; +import com.aizuda.snailjob.client.common.NettyClient; import com.aizuda.snailjob.client.common.rpc.client.RequestBuilder; import com.aizuda.snailjob.common.core.model.NettyResult; import com.aizuda.snailjob.common.core.window.Listener; diff --git a/snail-job-client/snail-job-client-job-core/src/main/java/com/aizuda/snailjob/client/job/core/dto/ShardingJobArgs.java b/snail-job-client/snail-job-client-job-core/src/main/java/com/aizuda/snailjob/client/job/core/dto/ShardingJobArgs.java index 4413f0013..cbd271598 100644 --- a/snail-job-client/snail-job-client-job-core/src/main/java/com/aizuda/snailjob/client/job/core/dto/ShardingJobArgs.java +++ b/snail-job-client/snail-job-client-job-core/src/main/java/com/aizuda/snailjob/client/job/core/dto/ShardingJobArgs.java @@ -16,5 +16,4 @@ public class ShardingJobArgs extends JobArgs { private Integer shardingIndex; - } diff --git a/snail-job-client/snail-job-client-retry-core/src/main/java/com/aizuda/snailjob/client/core/report/ReportListener.java b/snail-job-client/snail-job-client-retry-core/src/main/java/com/aizuda/snailjob/client/core/report/ReportListener.java index 8658957e1..bc0847acf 100644 --- a/snail-job-client/snail-job-client-retry-core/src/main/java/com/aizuda/snailjob/client/core/report/ReportListener.java +++ b/snail-job-client/snail-job-client-retry-core/src/main/java/com/aizuda/snailjob/client/core/report/ReportListener.java @@ -1,7 +1,7 @@ package com.aizuda.snailjob.client.core.report; +import com.aizuda.snailjob.client.common.NettyClient; import com.aizuda.snailjob.client.common.cache.GroupVersionCache; -import com.aizuda.snailjob.client.common.client.NettyClient; import com.aizuda.snailjob.client.common.config.SnailJobProperties; import com.aizuda.snailjob.client.common.rpc.client.RequestBuilder; import com.aizuda.snailjob.client.core.RetryExecutor; diff --git a/snail-job-client/snail-job-client-retry-core/src/main/java/com/aizuda/snailjob/client/core/report/SyncReport.java b/snail-job-client/snail-job-client-retry-core/src/main/java/com/aizuda/snailjob/client/core/report/SyncReport.java index a9a6c7f38..e1fc0f09b 100644 --- a/snail-job-client/snail-job-client-retry-core/src/main/java/com/aizuda/snailjob/client/core/report/SyncReport.java +++ b/snail-job-client/snail-job-client-retry-core/src/main/java/com/aizuda/snailjob/client/core/report/SyncReport.java @@ -1,7 +1,7 @@ package com.aizuda.snailjob.client.core.report; +import com.aizuda.snailjob.client.common.NettyClient; import com.aizuda.snailjob.client.common.cache.GroupVersionCache; -import com.aizuda.snailjob.client.common.client.NettyClient; import com.aizuda.snailjob.client.common.config.SnailJobProperties; import com.aizuda.snailjob.client.common.rpc.client.RequestBuilder; import com.aizuda.snailjob.client.core.retryer.RetryerInfo; diff --git a/snail-job-server/snail-job-server-common/src/main/java/com/aizuda/snailjob/server/common/rpc/server/handler/BeatHttpRequestHandler.java b/snail-job-server/snail-job-server-common/src/main/java/com/aizuda/snailjob/server/common/rpc/server/handler/BeatHttpRequestHandler.java index d8804d801..7929e7127 100644 --- a/snail-job-server/snail-job-server-common/src/main/java/com/aizuda/snailjob/server/common/rpc/server/handler/BeatHttpRequestHandler.java +++ b/snail-job-server/snail-job-server-common/src/main/java/com/aizuda/snailjob/server/common/rpc/server/handler/BeatHttpRequestHandler.java @@ -30,7 +30,7 @@ public class BeatHttpRequestHandler extends GetHttpRequestHandler { @Override public HttpMethod method() { - return HttpMethod.GET; + return HttpMethod.POST; } @Override diff --git a/snail-job-server/snail-job-server-common/src/main/java/com/aizuda/snailjob/server/common/rpc/server/handler/ConfigHttpRequestHandler.java b/snail-job-server/snail-job-server-common/src/main/java/com/aizuda/snailjob/server/common/rpc/server/handler/ConfigHttpRequestHandler.java index da83a4743..f49e843d1 100644 --- a/snail-job-server/snail-job-server-common/src/main/java/com/aizuda/snailjob/server/common/rpc/server/handler/ConfigHttpRequestHandler.java +++ b/snail-job-server/snail-job-server-common/src/main/java/com/aizuda/snailjob/server/common/rpc/server/handler/ConfigHttpRequestHandler.java @@ -31,7 +31,7 @@ public class ConfigHttpRequestHandler extends GetHttpRequestHandler { @Override public HttpMethod method() { - return HttpMethod.GET; + return HttpMethod.POST; } @Override