From 84a846e553d4feca7b628db6c12328fee525462a Mon Sep 17 00:00:00 2001
From: liwei1dao <liwei1dao@gmail.com>
Date: Tue, 13 Dec 2022 15:05:56 +0800
Subject: [PATCH] =?UTF-8?q?=E4=B8=8A=E4=BC=A0=E6=88=98=E6=96=97=E6=B5=8B?=
 =?UTF-8?q?=E8=AF=95=E7=A8=8B=E5=BA=8F?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 modules/battle/module_test.go | 19 ++++++++++++-------
 1 file changed, 12 insertions(+), 7 deletions(-)

diff --git a/modules/battle/module_test.go b/modules/battle/module_test.go
index e67bc2b2a..ef05e2da9 100644
--- a/modules/battle/module_test.go
+++ b/modules/battle/module_test.go
@@ -112,6 +112,7 @@ func Test_Comment(t *testing.T) {
 					fmt.Println(err)
 					break locp
 				}
+				fmt.Printf("收到消息: %d\n", time.Now().UnixMilli())
 				if err = proto.Unmarshal(data, msg); err != nil {
 					fmt.Println(err)
 					break locp
@@ -119,14 +120,18 @@ func Test_Comment(t *testing.T) {
 				fmt.Println(msg)
 			}
 		}()
-
-		msg := &pb.BattleRpcMessage{
-			Rid:    1,
-			Method: "Check",
+		for i := 0; i < 3; i++ {
+			msg := &pb.BattleRpcMessage{
+				Rid:    1,
+				Method: "Check",
+			}
+			msg.Data, _ = anypb.New(&pb.BattleReport{})
+			data, _ := proto.Marshal(msg)
+			fmt.Printf("发送消息: %d\n", time.Now().UnixMilli())
+			connect.WriteMessage(websocket.BinaryMessage, data)
+			time.Sleep(time.Second)
 		}
-		msg.Data, _ = anypb.New(&pb.BattleReport{})
-		data, _ := proto.Marshal(msg)
-		connect.WriteMessage(websocket.BinaryMessage, data)
+
 		//监听外部关闭服务信号
 		c := make(chan os.Signal, 1)
 		//添加进程结束信号