不走nats

server/client.go

@@ -388,7 +388,7 @@ func (c *Client) loadOfflineMessage() {
 	}()
 
 	// 五秒后自动推送
-	time.Sleep(5 * time.Second)
+	// time.Sleep(5 * time.Second)
 
 	rid := uuid.NewString()
 	unreadMsg, err := c.repos.MessageRepository.FindUnread(c.ctx, c.UserId)
@@ -420,12 +420,13 @@ func (c *Client) loadOfflineMessage() {
 		}
 
 		zap.L().Info("[conn] 客户端离线时的离线消息", zap.Any("msg", chating), zap.String("user_id", c.UserId))
-		if _, err := nc.RequestMsg(&nats.Msg{
-			Subject: natx.GetSubject(),
-			Data:    chating.Data(),
-		}, time.Second*5); err != nil {
-			c.ReplySend <- newErrorMessage(rid, err)
-		}
+		// if _, err := nc.RequestMsg(&nats.Msg{
+		// 	Subject: natx.GetSubject(),
+		// 	Data:    chating.Data(),
+		// }, time.Second*5); err != nil {
+		// 	c.ReplySend <- newErrorMessage(rid, err)
+		// }
+		c.Received <- &chating
 	}
 
 	// 未收到的通知消息
@@ -457,12 +458,13 @@ func (c *Client) loadOfflineMessage() {
 		}
 
 		zap.L().Info("[conn] 离线时收到的通知消息", zap.Any("notification", notify), zap.String("user_id", c.UserId))
-		if _, err := nc.RequestMsg(&nats.Msg{
-			Subject: natx.GetSubject(),
-			Data:    notify.Data(),
-		}, time.Second*5); err != nil {
-			c.ReplySend <- newErrorMessage(rid, err)
-		}
+		c.Received <- &notify
+		// if _, err := nc.RequestMsg(&nats.Msg{
+		// 	Subject: natx.GetSubject(),
+		// 	Data:    notify.Data(),
+		// }, time.Second*5); err != nil {
+		// 	c.ReplySend <- newErrorMessage(rid, err)
+		// }
 	}
 }