如何在.NET中实现Oplock（机会锁）并处理锁中断通知场景？

结论先行 #

.NET 官方没有提供封装好的 Oplock（机会锁）专用API，但完全可以通过 P/Invoke 调用Windows原生文件API，配合NativeOverlapped结构实现你描述的场景，不需要额外依赖。

实现核心逻辑 #

对应你提出的三个场景，实现逻辑如下：

• 应用1调用原生CreateFile接口打开文件，指定FileShare.Read共享模式，同时发送FSCTL_REQUEST_OPLOCK控制码申请读缓存级别的机会锁，绑定NativeOverlapped的事件句柄等待锁中断通知
• 应用2以FileAccess.Write权限打开文件时，操作系统会自动触发应用1持有的Oplock中断
• 应用1收到事件通知后，关闭自身持有的文件句柄解除锁定，操作系统会自动放行应用2的写入请求

可直接参考的最小实现示例 #

基础依赖与P/Invoke定义 #

using System.Runtime.InteropServices;
using Microsoft.Win32.SafeHandles;
using System.Threading;
using System.IO;

// 常量定义
internal const uint FSCTL_REQUEST_OPLOCK = 0x000900E4;
internal const int OPLOCK_LEVEL_CACHE_READ = 1;
internal const int ERROR_IO_PENDING = 997;
internal const uint GENERIC_READ = 0x80000000;
internal const uint OPEN_EXISTING = 3;
internal const uint FILE_SHARE_READ = 0x00000001;
internal const uint FILE_FLAG_OVERLAPPED = 0x40000000;

// Oplock输入结构
[StructLayout(LayoutKind.Sequential)]
internal struct REQUEST_OPLOCK_INPUT_BUFFER
{
    public int StructureVersion;
    public int StructureLength;
    public int RequestedOplockLevel;
    public int Flags;
}

// 原生API声明
[DllImport("kernel32.dll", SetLastError = true, CharSet = CharSet.Unicode)]
internal static extern SafeFileHandle CreateFile(
    string lpFileName,
    uint dwDesiredAccess,
    uint dwShareMode,
    IntPtr lpSecurityAttributes,
    uint dwCreationDisposition,
    uint dwFlagsAndAttributes,
    IntPtr hTemplateFile);

[DllImport("kernel32.dll", SetLastError = true)]
internal static extern bool DeviceIoControl(
    SafeFileHandle hDevice,
    uint dwIoControlCode,
    ref REQUEST_OPLOCK_INPUT_BUFFER lpInBuffer,
    int nInBufferSize,
    IntPtr lpOutBuffer,
    int nOutBufferSize,
    out int lpBytesReturned,
    ref NativeOverlapped lpOverlapped);

应用1核心逻辑（持有Oplock监听写入请求） #

// 初始化异步等待事件
var oplockEvent = new ManualResetEvent(false);
var overlapped = new NativeOverlapped
{
    EventHandle = oplockEvent.SafeWaitHandle.DangerousGetHandle()
};

// 打开文件，指定异步标识和读写共享权限
var fileHandle = CreateFile(
    @"C:\测试目录\测试文件.txt",
    GENERIC_READ,
    FILE_SHARE_READ | FILE_SHARE_WRITE,
    IntPtr.Zero,
    OPEN_EXISTING,
    FILE_FLAG_OVERLAPPED,
    IntPtr.Zero);

if (fileHandle.IsInvalid)
    throw new IOException("文件打开失败");

// 构造Oplock申请参数
var oplockInput = new REQUEST_OPLOCK_INPUT_BUFFER
{
    StructureVersion = 1,
    StructureLength = Marshal.SizeOf<REQUEST_OPLOCK_INPUT_BUFFER>(),
    RequestedOplockLevel = OPLOCK_LEVEL_CACHE_READ,
    Flags = 0
};

// 发送Oplock申请请求
bool result = DeviceIoControl(
    fileHandle,
    FSCTL_REQUEST_OPLOCK,
    ref oplockInput,
    Marshal.SizeOf<REQUEST_OPLOCK_INPUT_BUFFER>(),
    IntPtr.Zero,
    0,
    out _,
    ref overlapped);

// 异步等待场景会返回IO_PENDING错误，属于正常情况
if (!result && Marshal.GetLastWin32Error() == ERROR_IO_PENDING)
{
    Console.WriteLine("Oplock申请成功，等待其他进程写入请求");
    // 阻塞等待锁中断通知
    oplockEvent.WaitOne();
    Console.WriteLine("检测到写入请求，正在释放文件锁");
    // 关闭句柄解除锁定，操作系统会自动放行写入请求
    fileHandle.Close();
    Console.WriteLine("锁定已解除");
}

应用2无需特殊处理 #

正常调用.NET文件写入接口即可触发Oplock中断：

File.WriteAllText(@"C:\测试目录\测试文件.txt", "写入测试内容");

注意事项 #

• 该实现仅适用于Windows平台，Oplock是Windows专属的文件锁机制，Linux/macOS下对应的是lease机制，实现逻辑不同
• 使用NativeOverlapped时需要确保绑定的事件句柄在异步等待完成前不会被GC回收，避免野指针问题
• 如果需要支持更复杂的锁等级（比如读写缓存、批量锁），仅需要修改RequestedOplockLevel参数即可

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