gtsoft/gtsoft-snail-job-server
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects 1 Releases Wiki Activity

feat(sj_1.1.0-beta2): 优化客户端访问方式统一改成post

Browse Source
This commit is contained in:
opensnail 2024-06-27 18:37:02 +08:00
parent daf563a163
commit 7db7f83d93
8 changed files with 18 additions and 37 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
snail-job-client/snail-job-client-common/src/main/java/com/aizuda/snailjob/client/common/NettyClient.java
View File

@ -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<RetryTaskDTO> list);
@Mapping(method = RequestMethod.POST, path = HTTP_PATH.BATCH_LOG_REPORT)
NettyResult reportLogTask(List<LogTaskDTO> 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);
}

28
snail-job-client/snail-job-client-common/src/main/java/com/aizuda/snailjob/client/common/client/NettyClient.java
View File

@ -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<RetryTaskDTO> list);
@Mapping(method = RequestMethod.POST, path = HTTP_PATH.BATCH_LOG_REPORT)
NettyResult reportLogTask(List<LogTaskDTO> list);
}

2
snail-job-client/snail-job-client-common/src/main/java/com/aizuda/snailjob/client/common/log/report/ReportLogListener.java
View File

@ -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;

1
snail-job-client/snail-job-client-job-core/src/main/java/com/aizuda/snailjob/client/job/core/dto/ShardingJobArgs.java
View File

@ -16,5 +16,4 @@ public class ShardingJobArgs extends JobArgs {
private Integer shardingIndex;
}

2
snail-job-client/snail-job-client-retry-core/src/main/java/com/aizuda/snailjob/client/core/report/ReportListener.java
View File

@ -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;

2
snail-job-client/snail-job-client-retry-core/src/main/java/com/aizuda/snailjob/client/core/report/SyncReport.java
View File

@ -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;

2
snail-job-server/snail-job-server-common/src/main/java/com/aizuda/snailjob/server/common/rpc/server/handler/BeatHttpRequestHandler.java
View File

@ -30,7 +30,7 @@ public class BeatHttpRequestHandler extends GetHttpRequestHandler {
@Override
public HttpMethod method() {
return HttpMethod.GET;
return HttpMethod.POST;
}
@Override

2
snail-job-server/snail-job-server-common/src/main/java/com/aizuda/snailjob/server/common/rpc/server/handler/ConfigHttpRequestHandler.java
View File

@ -31,7 +31,7 @@ public class ConfigHttpRequestHandler extends GetHttpRequestHandler {
@Override
public HttpMethod method() {
return HttpMethod.GET;
return HttpMethod.POST;
}
@Override