基于C#实现与老旧POS系统文件通信的支付系统技术问询

针对你要开发的这套通过文件与老旧POS交互的支付系统，核心挑战在于第一时间抢占文件的独占访问权（毕竟POS会高频重试打开文件），同时要可靠完成监控、读取、删除全流程。下面是一套经过实践验证的实现方案：

一、实时监控目录：精准捕捉POS的文件创建事件 #

用C#的FileSystemWatcher是最直接的目录监控方案，但要针对POS的特性做配置：

• 明确指定POS的固定文件名作为过滤条件，避免无关文件干扰
• 只监听文件名和创建时间变化，减少不必要的事件触发
• 注意：POS可能存在文件写入延迟，所以事件触发后不要立刻操作，要留短暂缓冲或重试逻辑

// 初始化目录监控器
var paymentFolderWatcher = new FileSystemWatcher(@"C:\POS_Payment_WorkDir")
{
    Filter = "POS_PAYMENT_REQ.dat", // 替换为POS实际使用的固定文件名
    NotifyFilter = NotifyFilters.FileName | NotifyFilters.CreationTime,
    IncludeSubdirectories = false, // 不需要监控子目录
    EnableRaisingEvents = true
};

// 绑定文件创建事件处理方法
paymentFolderWatcher.Created += HandlePaymentFileCreated;

二、抢占式打开文件：阻止POS的重试访问 #

POS会在打开失败后不断重试，所以我们必须用完全独占的模式打开文件，确保一旦锁定，POS就无法再访问。这里封装一个带重试的方法，处理文件可能还在被POS写入的情况：

/// <summary>
/// 尝试以独占模式打开文件，阻止其他进程访问
/// </summary>
/// <param name="filePath">目标文件路径</param>
/// <param name="retryTimes">重试次数（应对文件未完全写入的情况）</param>
/// <returns>独占模式的文件流</returns>
private static FileStream GetExclusiveFileStream(string filePath, int retryTimes = 3)
{
    for (int i = 0; i < retryTimes; i++)
    {
        try
        {
            // FileShare.None 拒绝任何其他进程的读/写/删除访问
            return File.Open(filePath, FileMode.Open, FileAccess.ReadWrite, FileShare.None);
        }
        catch (IOException)
        {
            // 文件可能还在被POS写入，短暂等待后重试
            Thread.Sleep(100);
        }
    }
    throw new InvalidOperationException("无法获取文件的独占访问权限，POS可能正在占用");
}

三、读取支付请求与安全删除文件 #

拿到独占流后，就可以安全读取支付内容，处理完成后直接删除文件——因为我们持有独占锁，删除操作不会被POS干扰：

private static void HandlePaymentFileCreated(object sender, FileSystemEventArgs e)
{
    string requestFilePath = e.FullPath;
    FileStream exclusiveStream = null;

    try
    {
        // 获取独占文件流
        exclusiveStream = GetExclusiveFileStream(requestFilePath);

        // 读取支付请求内容（根据POS实际格式调整，比如二进制/XML/JSON）
        using var streamReader = new StreamReader(exclusiveStream);
        string paymentRequestContent = streamReader.ReadToEnd();

        // 调用你的支付业务逻辑处理请求
        ProcessPayment(paymentRequestContent);

        // 先关闭流才能执行删除操作
        exclusiveStream.Close();
        File.Delete(requestFilePath);

        Console.WriteLine($"支付请求处理完成，文件已删除: {requestFilePath}");
    }
    catch (Exception ex)
    {
        Console.WriteLine($"处理支付文件失败: {ex.Message}");
        exclusiveStream?.Close();
        // 可选：如果处理失败，可以保留文件等待人工介入，或者加入重试队列
    }
}

/// <summary>
/// 示例支付处理逻辑，替换为你的实际业务代码
/// </summary>
private static void ProcessPayment(string requestContent)
{
    // 解析请求参数、调用支付网关、记录交易日志等操作
    Console.WriteLine($"正在处理支付请求: {requestContent}");
}

四、生产环境必加的注意事项 #

• 权限配置：确保你的程序运行账户拥有目标目录的读、写、删除权限，避免因权限不足导致操作失败
• 线程安全：FileSystemWatcher的事件是在后台线程触发的，如果你的支付处理逻辑涉及共享资源（比如数据库连接、缓存），一定要加线程同步（比如lock）
• 日志记录：务必记录每一步操作的详细日志（文件创建时间、处理结果、异常堆栈），方便后续排查问题
• 异常兜底：针对磁盘空间不足、文件被意外删除、POS异常中断等极端情况，要做兜底处理（比如告警通知运维）

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