From a2b72e4c06217f07dd62abedb6ae2afb93d4047e Mon Sep 17 00:00:00 2001
From: byteblogs168 <598092184@qq.com>
Date: Sun, 31 Mar 2024 13:40:57 +0800
Subject: [PATCH] =?UTF-8?q?feat:=203.2.0=201.=20=E4=BC=98=E5=8C=96?=
 =?UTF-8?q?=E7=BB=84=E7=BC=93=E5=AD=98=E7=9A=84=E8=BF=87=E6=9C=9F=E9=97=AE?=
 =?UTF-8?q?=E9=A2=98=202.=20=E4=BC=98=E5=8C=96sql?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../src/main/resources/mysql/mapper/ServerNodeMapper.xml        | 1 -
 .../easy/retry/server/common/register/ServerRegister.java       | 2 ++
 2 files changed, 2 insertions(+), 1 deletion(-)

diff --git a/easy-retry-datasource/easy-retry-mysql-datasource/src/main/resources/mysql/mapper/ServerNodeMapper.xml b/easy-retry-datasource/easy-retry-mysql-datasource/src/main/resources/mysql/mapper/ServerNodeMapper.xml
index 55eb60f2..ea0209bf 100644
--- a/easy-retry-datasource/easy-retry-mysql-datasource/src/main/resources/mysql/mapper/ServerNodeMapper.xml
+++ b/easy-retry-datasource/easy-retry-mysql-datasource/src/main/resources/mysql/mapper/ServerNodeMapper.xml
@@ -52,7 +52,6 @@
         </foreach>
         ) tt
         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
     </update>
     <select id="countActivePod"
diff --git a/easy-retry-server/easy-retry-server-common/src/main/java/com/aizuda/easy/retry/server/common/register/ServerRegister.java b/easy-retry-server/easy-retry-server-common/src/main/java/com/aizuda/easy/retry/server/common/register/ServerRegister.java
index 29537443..2a76ef29 100644
--- a/easy-retry-server/easy-retry-server-common/src/main/java/com/aizuda/easy/retry/server/common/register/ServerRegister.java
+++ b/easy-retry-server/easy-retry-server-common/src/main/java/com/aizuda/easy/retry/server/common/register/ServerRegister.java
@@ -122,6 +122,8 @@ public class ServerRegister extends AbstractRegister {
                 for (final ServerNode node : serverNodes) {
                     // 刷新全量本地缓存
                     CacheRegisterTable.addOrUpdate(node);
+                    // 刷新过期时间
+                    CacheConsumerGroup.addOrUpdate(node.getGroupName(), node.getNamespaceId());
                 }
             }
         } catch (Exception e) {