From 3074604c86aea6f9a62f6f467fc88394b2d1aaf8 Mon Sep 17 00:00:00 2001 From: skiffer-git <44203734@qq.com> Date: Mon, 13 May 2024 10:22:41 +0800 Subject: [PATCH] Add etcd as a service discovery mechanism --- internal/msggateway/n_ws_server.go | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/internal/msggateway/n_ws_server.go b/internal/msggateway/n_ws_server.go index 29cbb51d8..a29b58528 100644 --- a/internal/msggateway/n_ws_server.go +++ b/internal/msggateway/n_ws_server.go @@ -212,8 +212,11 @@ func (ws *WsServer) sendUserOnlineInfoToOtherNode(ctx context.Context, client *C // Online push user online message to other node for _, v := range conns { log.ZDebug(ctx, " sendUserOnlineInfoToOtherNode conn ", "target", v.Target()) - if v.Target() == ws.disCov.GetSelfConnTarget() { - log.ZDebug(ctx, "Filter out this node", "node", v.Target()) + //if v.Target() == ws.disCov.GetSelfConnTarget() { + // log.ZDebug(ctx, "Filter out this node", "node", v.Target()) + // continue + //} + if true { continue }