From b8429e1d6a75842320513f77927a5eda2babd574 Mon Sep 17 00:00:00 2001
From: ztzh_xieyun <ztzh_xieyun@ztzh.com>
Date: Sat, 11 May 2024 18:09:16 +0800
Subject: [PATCH] =?UTF-8?q?=E5=8D=95=E6=9C=BA=E6=B6=88=E6=81=AF=E5=8F=91?=
 =?UTF-8?q?=E5=B8=83=E3=80=81=E8=AE=A2=E9=98=85,=E4=BB=A3=E7=A0=81?=
 =?UTF-8?q?=E6=95=B4=E6=94=B9,=E5=8A=A0=E6=8E=89=E4=BA=86?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../com/sf/vertx/handle/AppConfigHandler.java | 39 +++++++++++--------
 1 file changed, 22 insertions(+), 17 deletions(-)

diff --git a/sf-vertx/src/main/java/com/sf/vertx/handle/AppConfigHandler.java b/sf-vertx/src/main/java/com/sf/vertx/handle/AppConfigHandler.java
index cd9f80b..cd3a8bc 100644
--- a/sf-vertx/src/main/java/com/sf/vertx/handle/AppConfigHandler.java
+++ b/sf-vertx/src/main/java/com/sf/vertx/handle/AppConfigHandler.java
@@ -373,6 +373,7 @@ public class AppConfigHandler {
 
 		initConnectionCircuitBreaker();
 		createVertxRouter();
+		consumerClusterEventMsg();
 	}
 
 	private static Config hazelcastConfig(SacVertxConfig sacVertxConfig) {
@@ -415,23 +416,7 @@ public class AppConfigHandler {
 				log.info("hazelcastClusterManager create success");
 				initConnectionCircuitBreaker();
 				createVertxRouter();
-				// 订阅消息
-				VERTX.eventBus().consumer("sac_cluster_event", message -> {
-					if (message.body() != null) {
-						ClusterEventMsg msg = JSONObject.parseObject(message.body().toString(), ClusterEventMsg.class);
-						log.info("Received message: {}", msg);
-						// message.reply("我是返回数据===" + message.body());
-						if (msg.getType() == 1) {
-							if (msg.getOperation() == 1) {
-								// 初始化AppConfig本地缓存
-								AppConfigHandler.initAppConfig(msg.getAppCode(), true);
-							} else if (msg.getOperation() == 3) {
-								// 禁用本地缓存
-								AppConfigHandler.addDisabledAppcode(msg.getAppCode());
-							}
-						}
-					}
-				});
+				consumerClusterEventMsg();
 			} else {
 				res.cause().printStackTrace();
 				log.info("hazelcastClusterManager create failure");
@@ -439,6 +424,26 @@ public class AppConfigHandler {
 		});
 	}
 
+	private static void consumerClusterEventMsg() {
+		// 订阅消息
+		VERTX.eventBus().consumer("sac_cluster_event", message -> {
+			if (message.body() != null) {
+				ClusterEventMsg msg = JSONObject.parseObject(message.body().toString(), ClusterEventMsg.class);
+				log.info("Received message: {}", msg);
+				// message.reply("我是返回数据===" + message.body());
+				if (msg.getType() == 1) {
+					if (msg.getOperation() == 1) {
+						// 初始化AppConfig本地缓存
+						AppConfigHandler.initAppConfig(msg.getAppCode(), true);
+					} else if (msg.getOperation() == 3) {
+						// 禁用本地缓存
+						AppConfigHandler.addDisabledAppcode(msg.getAppCode());
+					}
+				}
+			}
+		});
+	}
+	
 	/***
 	 * 发布消息，订阅消息
 	 *