跨平台IPC的包装接口

跨平台IPC（Inter-Process Communication，进程间通信）是指不同操作系统或不同计算机之间进行进程间通信的方法。为了实现跨平台的IPC，可以使用一些包装接口来隐藏底层的细节，并提供统一的接口供开发者使用。

下面是一个简单的示例，展示如何使用C++实现一个跨平台的IPC包装接口。

// IPCWrapper.h 文件

#ifndef IPC_WRAPPER_H
#define IPC_WRAPPER_H

class IPCWrapper {
public:
    virtual bool sendMessage(const std::string& message) = 0;
    virtual std::string receiveMessage() = 0;
};

#endif


// IPCWrapper.cpp 文件

#include "IPCWrapper.h"

#ifdef _WIN32
#include <windows.h>

class WindowsIPCWrapper : public IPCWrapper {
private:
    HANDLE pipeHandle;
    
public:
    WindowsIPCWrapper() {
        // 初始化管道
        pipeHandle = CreateNamedPipe("\\\\.\\pipe\\IPC_PIPE", PIPE_ACCESS_DUPLEX, PIPE_TYPE_BYTE | PIPE_READMODE_BYTE | PIPE_WAIT, PIPE_UNLIMITED_INSTANCES, 0, 0, 0, nullptr);
        
        if (pipeHandle == INVALID_HANDLE_VALUE) {
            // 处理错误
        }
    }
    
    ~WindowsIPCWrapper() {
        // 关闭管道
        CloseHandle(pipeHandle);
    }
    
    bool sendMessage(const std::string& message) override {
        DWORD bytesWritten;
        bool success = WriteFile(pipeHandle, message.c_str(), message.length(), &bytesWritten, nullptr);
        return success;
    }
    
    std::string receiveMessage() override {
        char buffer[4096];
        DWORD bytesRead;
        bool success = ReadFile(pipeHandle, buffer, sizeof(buffer), &bytesRead, nullptr);
        
        if (success) {
            return std::string(buffer, bytesRead);
        } else {
            return "";
        }
    }
};

#else
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <unistd.h>

class UnixIPCWrapper : public IPCWrapper {
private:
    int pipeFileDescriptor;
    
public:
    UnixIPCWrapper() {
        // 初始化管道
        pipeFileDescriptor = open("/tmp/ipc_pipe", O_RDWR);
        
        if (pipeFileDescriptor == -1) {
            // 处理错误
        }
    }
    
    ~UnixIPCWrapper() {
        // 关闭管道
        close(pipeFileDescriptor);
    }
    
    bool sendMessage(const std::string& message) override {
        ssize_t bytesWritten = write(pipeFileDescriptor, message.c_str(), message.length());
        bool success = (bytesWritten != -1);
        return success;
    }
    
    std::string receiveMessage() override {
        char buffer[4096];
        ssize_t bytesRead = read(pipeFileDescriptor, buffer, sizeof(buffer));
        
        if (bytesRead > 0) {
            return std::string(buffer, bytesRead);
        } else {
            return "";
        }
    }
};

#endif


// 使用示例

#include "IPCWrapper.h"

int main() {
    IPCWrapper* ipcWrapper;
    
    #ifdef _WIN32
    ipcWrapper = new WindowsIPCWrapper();
    #else
    ipcWrapper = new UnixIPCWrapper();
    #endif
    
    // 使用IPCWrapper发送和接收消息
    ipcWrapper->sendMessage("Hello");
    std::string receivedMessage = ipcWrapper->receiveMessage();
    
    delete ipcWrapper;
    
    return 0;
}

该示例中，IPCWrapper是一个抽象基类，定义了sendMessage和receiveMessage两个纯虚函数，用于发送和接收消息。在Windows平台下，使用Windows API来实现IPC，而在其他平台下，使用UNIX系统调用来实现IPC。

在实际使用时，根据不同的平台，可以选择相应的具体实现类（WindowsIPCWrapper或UnixIPCWrapper）。这样，无论在哪个平台上运行，都可以通过IPCWrapper的统一接口来进行进程间通信，而不需要关心底层的实现细节。