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

feat: 3.2.0

Browse Source 
1. 优化组缓存的过期问题
2. 优化sql
This commit is contained in:
byteblogs168 2024-03-31 13:40:57 +08:00
parent 9cf223278a
commit 2aeb43cfd2
2 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
easy-retry-datasource/easy-retry-mysql-datasource/src/main/resources/mysql/mapper/ServerNodeMapper.xml
View File

@ -52,7 +52,6 @@
</foreach> </foreach>
) tt ) tt
SET rt.expire_at = tt.expire_at, rt.context_path = tt.context_path, SET rt.expire_at = tt.expire_at, rt.context_path = tt.context_path,
rt.context_path = tt.context_path
WHERE rt.host_id = tt.host_id and rt.host_ip = tt.host_ip WHERE rt.host_id = tt.host_id and rt.host_ip = tt.host_ip
</update> </update>
<select id="countActivePod" <select id="countActivePod"

2
easy-retry-server/easy-retry-server-common/src/main/java/com/aizuda/easy/retry/server/common/register/ServerRegister.java
View File

@ -122,6 +122,8 @@ public class ServerRegister extends AbstractRegister {
for (final ServerNode node : serverNodes) { for (final ServerNode node : serverNodes) {
// 刷新全量本地缓存 // 刷新全量本地缓存
CacheRegisterTable.addOrUpdate(node); CacheRegisterTable.addOrUpdate(node);
// 刷新过期时间
CacheConsumerGroup.addOrUpdate(node.getGroupName(), node.getNamespaceId());
} }
} }
} catch (Exception e) { } catch (Exception e) {