如何让.NET Core守护进程自动接收/var/log/syslog的新记录？

完全可行，无需周期性执行tail命令并比对记录。你可以在.NET Core中实现类似tail -F的逻辑，实时捕获syslog的新增内容，同时处理日志轮转（logrotate）的场景。以下是具体实现方案：

核心思路 #

通过跟踪文件的inode编号和当前读取位置，实现：

1. 持续读取文件新增内容
2. 当syslog被logrotate替换时（inode变化），自动切换到新文件从头读取

实现代码 #

创建一个后台服务类（继承BackgroundService），在守护进程中持续监控：

using System;
using System.IO;
using System.Threading;
using System.Threading.Tasks;

public class SyslogMonitor : BackgroundService
{
    private readonly string _syslogPath = "/var/log/syslog";
    private long _currentReadPosition = 0;
    private ulong _lastFileInode = 0;

    protected override async Task ExecuteAsync(CancellationToken stoppingToken)
    {
        while (!stoppingToken.IsCancellationRequested)
        {
            try
            {
                var fileInfo = new FileInfo(_syslogPath);
                var currentInode = GetFileInode(fileInfo);

                // 检测日志轮转：inode变化表示文件被替换
                if (currentInode != _lastFileInode)
                {
                    _currentReadPosition = 0;
                    _lastFileInode = currentInode;
                }

                // 读取新增内容
                if (fileInfo.Length > _currentReadPosition)
                {
                    using var stream = new FileStream(
                        _syslogPath, 
                        FileMode.Open, 
                        FileAccess.Read, 
                        FileShare.ReadWrite); // 允许其他进程写入文件

                    stream.Seek(_currentReadPosition, SeekOrigin.Begin);
                    using var reader = new StreamReader(stream);

                    string line;
                    while ((line = reader.ReadLine()) != null)
                    {
                        // 处理每条新日志记录，替换为你的业务逻辑
                        HandleSyslogEntry(line);
                    }

                    _currentReadPosition = stream.Position;
                }

                // 短休眠降低CPU占用，可根据需求调整间隔
                await Task.Delay(100, stoppingToken);
            }
            catch (Exception ex)
            {
                // 处理异常（如文件临时不可访问），可添加日志记录
                await Task.Delay(1000, stoppingToken);
            }
        }
    }

    // 获取Linux文件的inode编号
    private ulong GetFileInode(FileInfo fileInfo)
    {
        var linuxFsInfo = fileInfo as System.IO.FileSystemInfo;
        var inode = linuxFsInfo.GetType().GetProperty("Inode")?.GetValue(linuxFsInfo) as ulong?;
        return inode ?? 0;
    }

    // 自定义日志处理逻辑
    private void HandleSyslogEntry(string line)
    {
        // 示例：打印新日志，实际可替换为解析、存储或通知逻辑
        Console.WriteLine($"[Syslog] {line}");
    }
}

注册后台服务 #

在Program.cs中将该服务注册到依赖注入容器：

var builder = WebApplication.CreateBuilder(args);

// 注册Syslog监控服务
builder.Services.AddHostedService<SyslogMonitor>();

var app = builder.Build();
app.Run();

关键注意事项 #

• 权限配置：确保运行应用的用户对/var/log/syslog有读取权限，可将用户加入adm组：

  usermod -aG adm your-service-user
  

• 日志轮转处理：通过检测inode变化，自动适配logrotate对syslog的切割替换，无需额外配置
• CPU占用优化：通过Task.Delay控制轮询间隔，100ms的间隔既能保证实时性，又不会造成过高CPU负载

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