diff --git a/server/websocket/internal/logic/ws_render_cancel_notify_unity.go b/server/websocket/internal/logic/ws_render_cancel_notify_unity.go index e347f047..3bcf07b2 100644 --- a/server/websocket/internal/logic/ws_render_cancel_notify_unity.go +++ b/server/websocket/internal/logic/ws_render_cancel_notify_unity.go @@ -37,12 +37,10 @@ func isCancelRenderPanic(err any) bool { // 发送取消上下文消息给unity func sendCancelRenderMsgToUnity(wid string, deadlineTime int64) { - h := md5.New() - h.Write([]byte(fmt.Sprintf("%s_%d", wid, deadlineTime))) data := cancelUnityCtlChanItem{ Wid: wid, DeadlineTime: deadlineTime, - Sign: hex.EncodeToString(h.Sum(nil)), + Sign: signMessage(wid, deadlineTime), } select { case cancelUnityCtlChan <- data: @@ -63,6 +61,13 @@ func DialUdp(ctx context.Context, config config.Config) error { return nil } +// 签名消息 +func signMessage(wid string, deadlineTime int64) string { + h := md5.New() + h.Write([]byte(fmt.Sprintf("%s_fusen_control_unity_%d", wid, deadlineTime))) + return hex.EncodeToString(h.Sum(nil)) +} + // 消费数据 func ConsumeCancelUnityChanMessage(ctx context.Context, conn *net.UDPConn) { defer func() {