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

feat(sj_1.1.0-beta3): 下线客户端默认token兜底逻辑

Browse Source
This commit is contained in:
opensnail 2024-07-10 23:49:10 +08:00
parent ef94f54d3e
commit a745a2d527
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
snail-job-server/snail-job-server-common/src/main/java/com/aizuda/snailjob/server/common/cache/CacheToken.java vendored
View File

@ -37,7 +37,7 @@ public class CacheToken implements Lifecycle {
AccessTemplate template = SpringContext.getBean(AccessTemplate.class); AccessTemplate template = SpringContext.getBean(AccessTemplate.class);
GroupConfig config = template.getGroupConfigAccess().getGroupConfigByGroupName(groupName, namespaceId); GroupConfig config = template.getGroupConfigAccess().getGroupConfigByGroupName(groupName, namespaceId);
if (Objects.isNull(config)) { if (Objects.isNull(config)) {
return SystemConstants.DEFAULT_TOKEN; return StrUtil.EMPTY;
} }
token = config.getToken(); token = config.getToken();

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

@ -87,7 +87,7 @@ public class RequestHandlerActor extends AbstractActor {
String namespace = headers.get(HeadersEnum.NAMESPACE.getKey()); String namespace = headers.get(HeadersEnum.NAMESPACE.getKey());
String token = headers.get(HeadersEnum.TOKEN.getKey()); String token = headers.get(HeadersEnum.TOKEN.getKey());
if (!CacheToken.get(groupName, namespace).equals(token)) { if (StrUtil.isBlank(token) || !CacheToken.get(groupName, namespace).equals(token)) {
SnailJobLog.LOCAL.error("Token authentication failed. [{}]", token); SnailJobLog.LOCAL.error("Token authentication failed. [{}]", token);
return JsonUtil.toJsonString(new Result<>(0, "Token authentication failed")); return JsonUtil.toJsonString(new Result<>(0, "Token authentication failed"));
} }