Austin/BililiveRecorder
1
0
Fork 0
mirror of https://github.com/BililiveRecorder/BililiveRecorder.git synced 2024-11-16 03:32:20 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

Core: optimize danmaku server reconnect

Browse Source
This commit is contained in:
genteure 2022-04-30 14:04:57 +08:00
parent 10adc77f9e
commit 5dcf0d28ff
1 changed files with 9 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
BililiveRecorder.Core/Room.cs
View File

@ -47,6 +47,8 @@ namespace BililiveRecorder.Core
private IRecordTask? recordTask;
private DateTimeOffset recordTaskStartTime;
private DateTimeOffset danmakuClientConnectTime;
private static readonly TimeSpan danmakuClientReconnectNoDelay = TimeSpan.FromMinutes(1);
public Room(IServiceScope scope, RoomConfig roomConfig, int initDelayFactor, ILogger logger, IDanmakuClient danmakuClient, IApiClient apiClient, IBasicDanmakuWriter basicDanmakuWriter, IRecordTaskFactory recordTaskFactory)
{
@ -489,13 +491,19 @@ namespace BililiveRecorder.Core
if (e.Connected)
{
this.DanmakuConnected = true;
this.danmakuClientConnectTime = DateTimeOffset.UtcNow;
this.logger.Information("弹幕服务器已连接");
}
else
{
this.DanmakuConnected = false;
this.logger.Information("与弹幕服务器的连接被断开");
this.StartDamakuConnection(delay: true);
// 如果连接弹幕服务器的时间在至少 1 分钟之前，重连时不需要等待
// 针对偶尔的网络波动的优化，如果偶尔断开了尽快重连，减少漏录的弹幕量
this.StartDamakuConnection(delay: !((DateTimeOffset.UtcNow - this.danmakuClientConnectTime) > danmakuClientReconnectNoDelay));
this.danmakuClientConnectTime = DateTimeOffset.MaxValue;
}
}