如何在终止Actor系统前刷新日志？解决Serilog日志丢失问题

针对你遇到的Akka.NET终止时Serilog日志未完全处理、部分消息 fallback到默认日志的问题，临时的延迟或同步事件方案确实不够可靠——依赖固定等待时间很容易在高负载场景失效，而且代码也不够优雅。结合Akka.NET的生命周期管理和Serilog的特性，这里有几个更稳健的解决方案：

1. 利用CoordinatedShutdown添加日志刷新阶段 #

Akka.NET的CoordinatedShutdown是专门用来处理系统优雅关闭的工具，它允许你在系统终止的不同阶段插入自定义任务。我们可以在Actor系统真正终止前，添加一个专门的任务来确保Serilog的日志全部处理完成：

// 在Actor系统初始化时注册关闭任务
var shutdown = CoordinatedShutdown.Get(system);
shutdown.AddTask(CoordinatedShutdown.PhaseBeforeActorSystemTerminate, "FlushSerilogAndPendingLogs", async () =>
{
    // 先获取Akka的Serilog Logger实例
    if (system.Log is SerilogLogger serilogLogger)
    {
        // 先触发Serilog的刷新
        Log.CloseAndFlush();
        
        // 额外等待Akka内部日志队列排空（可根据实际情况调整超时时间）
        await Task.Delay(TimeSpan.FromSeconds(2));
    }
    return Task.CompletedTask;
});

// 之后关闭系统时，改用CoordinatedShutdown的终止方法，而不是直接调用Terminate()
await shutdown.Run(CoordinatedShutdown.ClrExitReason.Instance);

这种方式的优势是把日志清理纳入了Akka的官方关闭流程，比手动延迟更可控。

2. 自定义可等待的Serilog Akka Logger #

如果默认的SerilogLogger没有暴露等待待处理日志完成的接口，我们可以封装一个自定义Logger，跟踪所有待处理的日志任务，在关闭时等待它们全部完成：

public class WaitableSerilogLogger : SerilogLogger
{
    private int _pendingLogsCount;
    private readonly SemaphoreSlim _pendingLogsSignal = new SemaphoreSlim(0);

    public WaitableSerilogLogger(ILogger logger, LogLevelFilter logLevelFilter) 
        : base(logger, logLevelFilter)
    {
    }

    protected override void Log(LogEvent logEvent)
    {
        Interlocked.Increment(ref _pendingLogsCount);
        try
        {
            base.Log(logEvent);
        }
        finally
        {
            Interlocked.Decrement(ref _pendingLogsCount);
            _pendingLogsSignal.Release();
        }
    }

    public async Task WaitForAllLogsProcessedAsync(TimeSpan timeout)
    {
        // 循环等待直到待处理日志数为0，或者超时
        while (_pendingLogsCount > 0)
        {
            if (!await _pendingLogsSignal.WaitAsync(timeout))
            {
                // 超时后可以选择记录警告或者直接退出
                Log.Warning("Serilog日志刷新超时，仍有未处理的日志");
                break;
            }
        }
    }
}

然后在Akka配置中替换默认的SerilogLogger：

akka {
  loggers = ["YourNamespace.WaitableSerilogLogger, YourAssembly"]
  # 其他Serilog配置...
}

最后在关闭系统前调用等待方法：

var waitableLogger = system.Log as WaitableSerilogLogger;
if (waitableLogger != null)
{
    await waitableLogger.WaitForAllLogsProcessedAsync(TimeSpan.FromSeconds(5));
}
// 再触发Serilog刷新和系统终止
Log.CloseAndFlush();
await CoordinatedShutdown.Get(system).Run(CoordinatedShutdown.ClrExitReason.Instance);

3. 调整Akka日志的调度器配置 #

另外，你可以检查Akka的日志调度器设置，确保日志处理的线程池有足够的资源在关闭前完成任务。比如在HOCON配置中增加日志调度器的线程数：

akka {
  logger-dispatcher {
    type = Dispatcher
    executor = "thread-pool-executor"
    thread-pool-executor {
      core-pool-size-min = 2
      core-pool-size-max = 4
    }
  }
}

这样可以减少日志处理的积压，让关闭时的日志能更快被处理完。

这些方案都比临时的延迟或同步事件更可靠，能确保日志在系统终止前被完全处理，不会出现消息丢失或 fallback到默认日志的情况。

内容的提问来源于stack exchange，提问作者user247702