From a7ff64fdbd7014f1a60b02725dcb493839e68362 Mon Sep 17 00:00:00 2001 From: mountain Date: Wed, 6 Sep 2023 19:16:24 +0900 Subject: [PATCH] =?UTF-8?q?redisClient=EC=97=90=EC=84=9C=20redisUri?= =?UTF-8?q?=EB=A1=9C=20=EB=B3=80=EA=B2=BD?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- wshandler/wshandler.go | 13 +++++++++---- 1 file changed, 9 insertions(+), 4 deletions(-) diff --git a/wshandler/wshandler.go b/wshandler/wshandler.go index ccf6fe1..77e1ffd 100644 --- a/wshandler/wshandler.go +++ b/wshandler/wshandler.go @@ -156,12 +156,17 @@ func init() { gob.Register([]any{}) } -func NewWebsocketHandler(consumer session.Consumer, redisClient *redis.Client) (*WebsocketHandler, error) { +func NewWebsocketHandler(consumer session.Consumer, redisUri string) (*WebsocketHandler, error) { var config wsConfig if err := gocommon.LoadConfig(&config); err != nil { return nil, err } + redisSync, err := gocommon.NewRedisClient(redisUri) + if err != nil { + return nil, err + } + sendchan := make(chan send_msg_queue_elem, 1000) go func() { sender := func(elem *send_msg_queue_elem) { @@ -180,9 +185,9 @@ func NewWebsocketHandler(consumer session.Consumer, redisClient *redis.Client) ( }() return &WebsocketHandler{ - redisMsgChanName: fmt.Sprintf("_wsh_msg_%d", redisClient.Options().DB), - redisCmdChanName: fmt.Sprintf("_wsh_cmd_%d", redisClient.Options().DB), - redisSync: redisClient, + redisMsgChanName: fmt.Sprintf("_wsh_msg_%d", redisSync.Options().DB), + redisCmdChanName: fmt.Sprintf("_wsh_cmd_%d", redisSync.Options().DB), + redisSync: redisSync, connInOutChan: make(chan *wsconn), deliveryChan: make(chan any, 1000), localDeliveryChan: make(chan any, 100),