增加日志

.gitlab-ci.yml

@@ -47,4 +47,4 @@ deploy-job:
     script: 
         - supervisorctl update
         - supervisorctl restart websocket-node-1
-        - supervisorctl restart websocket-node-2
+        # - supervisorctl restart websocket-node-2

server/hub.go

@@ -63,6 +63,9 @@ func (h *Hub) run() {
 			h.mutex.RLock()
 			// zap.L().Info("message: ", zap.Any("message", message))
 			if client, ok := h.clients[message.Receiver]; ok {
+				zap.L().Info("message to client",
+					zap.String("receiver", message.Receiver),
+					zap.String("request_id", message.RequestId))
 				client.Send <- message
 			} else {
 				h.Nats.Send <- &natsMessage{userId: message.Receiver, message: message}