回复心跳 probeId

This commit is contained in:
milimoe 2026-04-27 21:59:08 +08:00
parent adf70b42c2
commit bcc597b525
Signed by: milimoe
GPG Key ID: 9554D37E4B8991D0

View File

@ -75,7 +75,7 @@ namespace Milimoe.FunGame.Server.Model
if (type == SocketMessageType.HeartBeat) if (type == SocketMessageType.HeartBeat)
{ {
return await HeartBeat(); return await HeartBeat(obj);
} }
if (type == SocketMessageType.EndGame) if (type == SocketMessageType.EndGame)
@ -139,9 +139,10 @@ namespace Milimoe.FunGame.Server.Model
return await Send(type, msg); return await Send(type, msg);
} }
public async Task<bool> HeartBeat() public async Task<bool> HeartBeat(SocketObject obj)
{ {
bool result = await Send(SocketMessageType.HeartBeat); string probeId = obj.GetParam<string>(0) ?? "";
bool result = await Send(SocketMessageType.HeartBeat, probeId);
if (!result) if (!result)
{ {
ServerHelper.WriteLine("[ " + GetClientName() + " ] " + nameof(HeartBeat) + ": " + result, InvokeMessageType.Error); ServerHelper.WriteLine("[ " + GetClientName() + " ] " + nameof(HeartBeat) + ": " + result, InvokeMessageType.Error);
@ -346,7 +347,7 @@ namespace Milimoe.FunGame.Server.Model
case SocketMessageType.Chat: case SocketMessageType.Chat:
return true; return true;
} }
if (objs.Length > 0 && objs[0] is string str && str != "") if (type != SocketMessageType.HeartBeat && objs.Length > 0 && objs[0] is string str && str != "")
{ {
ServerHelper.WriteLine("[" + SocketSet.GetTypeString(type) + "] " + GetClientName() + " <- " + str, InvokeMessageType.Core); ServerHelper.WriteLine("[" + SocketSet.GetTypeString(type) + "] " + GetClientName() + " <- " + str, InvokeMessageType.Core);
} }