C#使用SendMessage实现进程间通信的示例代码

本文主要是介绍C#使用SendMessage实现进程间通信的示例代码，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

《C#使用SendMessage实现进程间通信的示例代码》在软件开发中,进程间通信（IPC）是关键技术之一,C#通过调用WindowsAPI的SendMessage函数实现这一功能,本文将通过实例介绍...

第一章：SendMessage的底层原理揭秘

核心思想：窗口句柄作为进程通信的"身份证"

// 窗口句柄（HWND）的本质：进程身份的唯一标识符
public class WindowHandleManager
{
    [DllImport("user32.dll", SetLastError = true)]
    private static extern IntPtr Findwindow(string lpClassName, string lpWindowName);

    /// <summary>
    /// 获取目标进程的主窗口句柄
    /// </summary>
    /// <param name="processName">进程名称（不含.exe后缀）</param>
    /// <returns>窗口句柄</returns>
    public static IntPtr GetWindowHandle(string processName)
    {
        // 查找同名进程
        Process[] processes = Process.GetProcessesByName(processName);
        if (processes.Length == 0)
            throw new Exception($"未找到进程 {processName}");

        // 获取主窗口句柄
        IntPtr hWnd = processes[0].MainWindowHandle;
        if (hWnd == IntPtr.Zero)
            throw new Exception("未找到窗口句柄");

        return hWnd;
    }
}

灵魂拷问：

为什么必须通过窗口句柄通信？

Windows 系统为每个窗口分配唯一句柄，如同进程的“身份证号”，是跨进程通信的唯一身份验证方式。

第二章：构建跨进程通信桥梁

目标：发送端与接收端的完整握手流程

2.1 定义通信协议

// 自定义消息结构体（必须与C++定义完全一致）
[StructLayout(LayoutKind.Sequential)]
public struct COPYDATASTRUCT
{
    public IntPtr dwData;    // 自定义标识符（如类型ID）
    publicChina编程 int cbData;       // 数据长度（字节数）
    public IntPtr lpData;    // 数据指针
}

// 消息常量定义
public static class WindowMessages
{
    public const uint WM_COPYDATA = 0x004A;  // 标准消息ID
    public const uint CUSTOM_MSG_BASE = 0x8000; // 自定义消息起始点
}

设计哲学：

使用WM_COPYDATA标准消息确保跨语言兼容性
dwData字段可扩展为消息类型标识符（如0x0001表示文本，0x0002表示二进制）

2.2 接收端实现

// 接收端窗体类
public class MessageReceiver : Form
{
    protected override void WndProc(ref Message m)
    {
        // 拦截自定义消息
        if (m.Msg == (int)WindowMessages.WM_COPYDATA)
        {
            try
            {
                // 解析消息结构体
                var cds = (COPYDATASTRUCT)Marshal.PtrToStructure(
                    m.LParam,
                    typeof(COPYDATASTRUCT)
                );

                // 将指针转换为字符串
                string receivedData = Marshal.PtrToStringAnsi(cds.lpData);
                
                // 处理数据（示例：显示消息）
                MessageBox.Show($"收到数据: {receivedData}");
            }
            catch (Exception ex)
            {
                Console.WriteLine($"消息处理异常: {ex.Message}");
            }
        }

        base.WndProc(ref m);
    }

    public static void Main()
    {
        Application.Run(new MessageReceiver());
        Console.WriteLine("接收端启动，等待消息...");
    }
}

高级技巧：

使用try-catch包裹消息处理防止程序崩溃
添加日志记录便于调试
使用GCHandle管理内存生命周期（详见下文）

2.3 发送端实现

public class ProcessCommunicator
{
    [DllImport("user32.dll", SetLastError = true)]
    private static extern IntPtr SendMessage(
        IntPtr hWnd, 
        uint Msg, 
        IntPtr wparam, 
        ref COPYDATASTRUCT lParam
    );

    /// <summary>
    /// 向指定进程发送数据
    /// </summary>
    /// <param name="targetProcessName">目标进程名</param>
    /// <param name="data">要发送的数据</param>
    public static void SendDataToProcess(string targetProcessName, string data)
    {
        // 1. 获取目标进程句柄
        IntPtr hWnd = WindowHandleManager.GetWindowHandle(targetProcessName);

        // 2. 将字符串转换为字节数组
        byte[] bytes = Encoding.UTF8.GetBytes(data);
        
        // 3. 固定内存地址（防止GC回收）
        GCHandle handle = GCHandle.Alloc(bytes, GCHandleType.Pinned);
        try
        {
            // 4. 构造消息结构体
            COPYDATASTRUCT cds = new COPYDATASTRUCT
            {
                dwData = IntPtr.Zero,        // 自定义标识符
                cbData = bytes.Length,       // 数据长度
                lpData = handle.AddrOfPinnedObject() // 数据指针
            };

            // 5. 发送消息
            IntPtr result = SendMessage(
                hWnd, 
                WindowMessages.WM_COPYDATA, 
                IntPtr.Zero, 
                ref cds
编程China编程            );

            // 6. 错误处理
            if (result == IntPtr.Zero)
            {
                int errorCode = Marshal.GetLastWin32Error();
                throw new Exception($"发送失败，错误码：{errorCode}");
            }
        }
        finally
        {
            // 7. 释放内存
            handle.Free();
        }
    }
}

性能优化：

使用GCHandle.Alloc固定内存地址防止GC干扰
批量发送时复用内存缓冲区
添加发送频率限制（如每秒不超过100次）

第三章：突破SendMessage的性能瓶颈

让进程通信速度提升10倍的关键技巧

3.1 异步通信模式

// 异步发送任务（避免阻塞主线程）
public static async Task SendDataAsync(
    string targetProcessName, 
    string data,
    CancellationToken cancellationToken)
{
    await Task.Run(() =>
    {
        try
        {
            SendDataToProcess(targetProcessName, data);
        }
        catch (Exception ex)
        {
            Console.WriteLine($"异步发送异常: {ex.Message}");
        }
    }, cancellationToken);
}

设计原则：

使用Task.Run隔离耗时操作
添加取消令牌支持中断机制
使用ValueTask优化小数据场景

3.2 高吞吐量优化

// 批量发送优化器
public class BATchMessageOptimizer
{
    private readonly Queue<string> _messageQueue = new Queue<string>();
    private readonly object _lock = new object();
    private Timer _timer;

    public BatchMessageOptimizer(int intervalMs)
    {
        _timer = new Timer(SendBatch, null, Timeout.Infinite, Timeout.Infinite);
        _timer.Change(intervalMs, intervalMs);
    }

    public void Enqueue(string message)
    {
        lock (_lock)
        {
            _messageQueue.Enqueue(message);
        }
    }

    private void SendBatch(object state)
    {
        List<string> batch;
        lock (_lock)
        {
            batch = _messageQueue.ToList();
            _messageQueue.Clear();
        }

        foreach (var msg in batch)
        {
            ProcessCommunicator.SendDataToProcess("Receiver", msg);
        }
    }
}

性能对比：

模式	吞吐量（条/秒）	适用场景
单条发送	50	实时性要求高
批量发送	500+	大批量数据传输

第四章：解决SendMessage的致命缺陷

从理论到实践的全面加固

4.1 窗口句柄失效问题

// 带重试机制的句柄获取
public static IntPtr GetWindowHandleWithRetry(
    string processName, 
    int maxRetries = 5, 
    int retryIntervalMs = 1000)
{
    for (int i = 0; i < maxRetries; i++)
    {
        try
        {
            retpythonurn WindowHandleManager.GetWindowHandle(processName);
        }
        catch (Exception ex)
        {
            Console.WriteLine($"第{i + 1}次尝试失败: {ex.Message}");
            Thread.Sleep(retryIntervalMs);
        }
    }
    throw new Exception("多次尝试获取句柄失败");
}

防御策略：

设置最大重试次数防止单点故障
添加指数退避算法（每次重试间隔翻倍）
集成健康检查接口

4.2 内存泄漏预防

// 使用对象池复用COPYDATASTRUCT
public class CopyDataPool
{
    private readonly ObjectPool<COPYDATASTRUCT> _pool;

    public CopyDataPool(int initialSize)
    {
        _pool = new ObjectPool<COPYDATASTRUCT>(() => new COPYDATASTRUCT(), initialSize);
    }

    public COPYDATASTRUCT Get()
    {
        return _pool.Get();
    }

    public void Return(COPYDATASTRUCT item)
    {
        // 重置字段
        item.dwData = IntPtr.Zero;
        item.cbData = 0;
        item.lpData = IntPtr.Zero;
        _pool.Return(item);
    }
}

内存管理守则：

对象池减少GC压力
显式重置结构体字段
使用弱引用跟踪未释放资源

第五章：扩展应用场景

让SendMessage发挥最大价值

5.1 传输复杂数据结构

// 自定义数据序列化
[StructLayout(LayoutKind.Sequential)]
public struct UserMessage
{
    [MarshalAs(UnmanagedType.ByValTStr, SizeConst = 256)]
    public string Username;
    public int Score;
    public DateTime Timestamp;
}

// 发送复杂结构
public static void SendUserMessage(IntPtr hWnd, UserMessage message)
{
    int size = Marshal.SizeOf(message);
    byte[] buffer = new byte[size];
    
    GCHandle handle = GCHandle.Alloc(buffer, GCHandleType.Pinned);
    try
    {
        IntPtr pBuffer = handle.AddrOfChina编程PinnedObject();
        Marshal.StructureToPtr(message, pBuffer, false);

        COPYDATASTRUCT cds = new COPYDATASTRUCT
        {
            dwData = (IntPtr)1, // 自定义消息类型
            cbData = size,
            lpData = pBuffer
        };

        SendMessage(hWnd, WindowMessages.WM_COPYDATA, IntPtr.Zero, ref cds);
    }
    finally
    {
        handle.Free();
    }
}

设计考量：

使用StructLayout控制内存布局
添加版本号字段支持协议升级
使用二进制序列化提升效率

5.2 实现双向通信

// 双向通信示例
public class BidirectionalCommunicator
{
    private IntPtr _serverHandle;
    private int _messageId = WindowMessages.CUSTOM_MSG_BASE + 1;

    public void Connect(string serverProcessName)
    {
        _serverHandle = WindowHandleManager.GetWindowHandle(serverProcessName);
    }

    public void SendRequest(string request)
    {
        // 构造请求
        byte[] requestBytes = Encoding.UTF8.GetBytes(request);
        GCHandle requestHandle = GCHandle.Alloc(requestBytes, GCHandleType.Pinned);
        
        // 注册回调
        IntPtr callbackPtr = Marshal.GetFunctionPointerForDelegate(
            new MessageCallback(OnResponseReceived)
        );
        
        // 发送请求
        COPYDATASTRUCT cds = new COPYDATASTRUCT
        {
            dwData = (IntPtr)_messageId,
            cbData = requestBytes.Length,
            lpData = requestHandle.AddrOfPinnedObject()
        };

        IntPtr result = SendMessage(
            _serverHandle, 
            WindowMessages.WM_COPYDATA, 
            callbackPtr, 
            ref cds
        );
        
        requestHandle.Free();
    }

    private void OnResponseReceived(IntPtr hWnd, uint msg, IntPtr wParam, IntPtr lParam)
    {
        // 处理响应...
    }

    // 服务器端需要实现对应的回调处理
}

双向通信架构：