尝试

server/client_test.go

@@ -1,7 +1,18 @@
 package server
 
-import "testing"
+import (
+	"fmt"
+	"testing"
+	"time"
+)
 
 func TestClient_Connection(t *testing.T) {
-	
+	ticker := time.NewTicker(360)
+	for {
+		select {
+		case <-ticker.C:
+			ticker.Stop()
+			fmt.Println(1321412)
+		}
+	}
 }

server/nats.go

@@ -88,8 +88,7 @@ func (n *Nats) run() {
 		case msg := <-n.ch:
 			userIds := msg.Header.Values(headerUserId)
 			zap.L().Info("received nats message",
-				zap.Strings("ids", userIds),
-				zap.String("request_id", msg.Header.Values("request_id")[0]))
+				zap.Strings("ids", userIds))
 			if len(userIds) == 0 {
 				continue
 			}