添加SQL服务器心跳查询机制

This commit is contained in:
Mili 2023-03-14 00:08:34 +08:00
parent acf9a545c9
commit f7382b7d04

View File

@ -367,6 +367,10 @@ namespace Milimoe.FunGame.Server.Model
{ {
CreateStreamReader(); CreateStreamReader();
}); });
Task PeriodicalQuerier = Task.Factory.StartNew(() =>
{
CreatePeriodicalQuerier();
});
} }
public void SetTaskAndClientName(Task t, string ClientName) public void SetTaskAndClientName(Task t, string ClientName)
@ -461,6 +465,18 @@ namespace Milimoe.FunGame.Server.Model
} }
} }
private void CreatePeriodicalQuerier()
{
Thread.Sleep(100);
ServerHelper.WriteLine("Creating: PeriodicalQuerier -> " + SocketHelper.MakeClientName(ClientName, User) + " ...OK");
while (Running)
{
// 每两小时触发一次SQL服务器的心跳查询防止SQL服务器掉线
Thread.Sleep(2 * 1000 * 3600);
SQLHelper.ExecuteDataSet(UserQuery.Select_DuplicateUsername(UserName), out _);
}
}
private void Close() private void Close()
{ {
try try