WinAPI邮槽问题：ReadFile无法读取数据且进程冻结

阿华AIGC实验室

2026-5-7

问题排查与解决方案

看起来你遇到了邮槽通信的死锁问题，还有几个邮槽使用的误区，我帮你梳理一下核心问题和修正方案：

核心问题分析

1. 互斥量使用导致的死锁

你的第二个进程在持有互斥量的状态下调用ReadFile，而因为你设置了MAILSLOT_WAIT_FOREVER，ReadFile会无限等待直到有数据到来。这时候第一个进程被卡在WaitForSingleObject(m, INFINITE)——它需要互斥量来写入数据，但互斥量被第二个进程拿着，而第二个进程又在等第一个进程发数据，形成了完美的死锁循环。

2. 邮槽命名格式错误

邮槽是Windows内核对象，不是磁盘上的文件，命名格式应该是\\.\mailslot\[自定义槽名]，不需要带真实的磁盘路径（比如c:\\Users\\...）。你现在的命名会导致邮槽创建/打开失败，只不过因为死锁问题先暴露了出来。

3. 消息传输模型不匹配

邮槽以独立消息为单位传输，客户端每次WriteFile会发送一个完整消息。你现在拆分两次发送a和b，服务器分两次读取，这种拆分很容易导致同步问题，更合理的做法是把数据打包成一个结构体一次性发送。

修正后的代码实现

首先定义一个共用的结构体（两个进程都要包含，最好放在头文件里）：

struct CalculationData {
    double a;
    double b;
};

第一个进程（客户端：输入并发送数据）

#include <iostream>
#include <windows.h>
using namespace std;

struct CalculationData {
    double a;
    double b;
};

int main() {
    // 创建互斥量
    HANDLE hMutex = CreateMutex(NULL, FALSE, L"MyMutex");
    if (hMutex == NULL) {
        cout << "CreateMutex failed! Error code: " << GetLastError() << endl;
        return -1;
    }

    // 启动第二个进程（注意替换成你的第二个进程实际路径）
    STARTUPINFO si;
    PROCESS_INFORMATION pi;
    ZeroMemory(&si, sizeof(si));
    si.cb = sizeof(si);
    ZeroMemory(&pi, sizeof(pi));

    if (!CreateProcess(L"c:\\Users\\user\\Desktop\\Lab3\\Process2\\Debug\\Process2.exe",
                      NULL, NULL, NULL, FALSE, 0, NULL, NULL, &si, &pi)) {
        cout << "Failed to start process! Error code: " << GetLastError() << endl;
        CloseHandle(hMutex);
        return -1;
    }

    // 打开邮槽（客户端模式）
    HANDLE hMailslot = CreateFile(L"\\\\.\\mailslot\\MyCalculationSlot",
                                 GENERIC_WRITE,
                                 FILE_SHARE_READ,
                                 NULL,
                                 OPEN_EXISTING,
                                 FILE_ATTRIBUTE_NORMAL,
                                 NULL);
    if (hMailslot == INVALID_HANDLE_VALUE) {
        cout << "Failed to open mailslot! Error code: " << GetLastError() << endl;
        CloseHandle(pi.hProcess);
        CloseHandle(pi.hThread);
        CloseHandle(hMutex);
        return -1;
    }

    while (true) {
        CalculationData inputData;
        // 先获取用户输入（不持有互斥量，避免长时间占用锁）
        cout << "Please enter A and B values:\n";
        cout << "A = ";
        cin >> inputData.a;
        cout << "B = ";
        cin >> inputData.b;

        // 退出条件：输入A和B都为0时结束
        if (inputData.a == 0 && inputData.b == 0) {
            cout << "Exiting..." << endl;
            break;
        }

        // 获取互斥量，发送数据
        WaitForSingleObject(hMutex, INFINITE);
        DWORD bytesWritten;
        if (!WriteFile(hMailslot, &inputData, sizeof(CalculationData), &bytesWritten, NULL)) {
            cout << "WriteFile failed! Error code: " << GetLastError() << endl;
        }
        ReleaseMutex(hMutex);
    }

    // 清理资源
    CloseHandle(hMailslot);
    CloseHandle(pi.hProcess);
    CloseHandle(pi.hThread);
    CloseHandle(hMutex);
    return 0;
}

第二个进程（服务器：读取并处理数据）

#include <iostream>
#include <windows.h>
using namespace std;

struct CalculationData {
    double a;
    double b;
};

int main() {
    // 打开互斥量（只需要同步权限即可，不需要全权限）
    HANDLE hMutex = OpenMutex(SYNCHRONIZE, FALSE, L"MyMutex");
    if (hMutex == NULL) {
        cout << "OpenMutex failed! Error code: " << GetLastError() << endl;
        return -1;
    }

    // 创建邮槽（服务器模式）
    HANDLE hMailslot = CreateMailslot(L"\\\\.\\mailslot\\MyCalculationSlot",
                                     0,
                                     MAILSLOT_WAIT_FOREVER,
                                     NULL);
    if (hMailslot == INVALID_HANDLE_VALUE) {
        cout << "CreateMailslot failed! Error code: " << GetLastError() << endl;
        CloseHandle(hMutex);
        return -1;
    }

    CalculationData receivedData;
    DWORD bytesRead;
    while (true) {
        // 先读取邮槽数据（不持有互斥量，避免死锁）
        if (!ReadFile(hMailslot, &receivedData, sizeof(CalculationData), &bytesRead, NULL)) {
            cout << "ReadFile failed! Error code: " << GetLastError() << endl;
            break;
        }

        // 退出条件判断
        if (receivedData.a == 0 && receivedData.b == 0) {
            cout << "Client exited. Closing..." << endl;
            break;
        }

        // 获取互斥量处理数据（如果需要同步计算结果，这里只是打印）
        WaitForSingleObject(hMutex, INFINITE);
        cout << "I have read values: A = " << receivedData.a << ", B = " << receivedData.b << endl;
        // 这里可以添加你的计算逻辑，比如 double c = receivedData.a + receivedData.b;
        ReleaseMutex(hMutex);
    }

    // 清理资源
    CloseHandle(hMailslot);
    CloseHandle(hMutex);
    return 0;
}