chenzihao/sac
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

单机消息发布、订阅,代码整改,加掉了

Browse Source
This commit is contained in:
ztzh_xieyun 2024-05-11 18:09:16 +08:00
parent 028035dec5
commit b8429e1d6a
1 changed files with 22 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

39
sf-vertx/src/main/java/com/sf/vertx/handle/AppConfigHandler.java
View File

@ -373,6 +373,7 @@ public class AppConfigHandler {
initConnectionCircuitBreaker(); initConnectionCircuitBreaker();
createVertxRouter(); createVertxRouter();
consumerClusterEventMsg();
} }
private static Config hazelcastConfig(SacVertxConfig sacVertxConfig) { private static Config hazelcastConfig(SacVertxConfig sacVertxConfig) {
@ -415,23 +416,7 @@ public class AppConfigHandler {
log.info("hazelcastClusterManager create success"); log.info("hazelcastClusterManager create success");
initConnectionCircuitBreaker(); initConnectionCircuitBreaker();
createVertxRouter(); createVertxRouter();
// 订阅消息 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());
}
}
}
});
} else { } else {
res.cause().printStackTrace(); res.cause().printStackTrace();
log.info("hazelcastClusterManager create failure"); 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());
}
}
}
});
}
/*** /***
* 发布消息，订阅消息 * 发布消息，订阅消息
* *