在Windows平台上，不同进程之间如果需要交换数据，又不想引入网络协议或第三方中间件，命名管道（NamedPipe）是一种非常轻量且稳定的选择。C#在System.IO.Pipes命名空间中对命名管道做了完整封装，开发者可以用很少的代码完成本地进程间通信。本文围绕NamedPipeServerStream和NamedPipeClientStream，详细说明如何建立连接、收发数据以及处理常见异常。
一、命名管道的基本概念
命名管道是Windows操作系统提供的一种进程间通信机制，它在内核中创建一个以名字标识的管道对象，允许同一台机器上的不同进程通过这个名字进行读写。与匿名管道只能用于父子进程不同，命名管道可以被任意本地进程按名称打开，因此更适合构建独立的服务端和客户端程序。
在C#中，命名管道分为服务端流和客户端流。服务端使用NamedPipeServerStream监听指定名称的管道，客户端使用NamedPipeClientStream连接该名称。两者都继承自PipeStream，因此读写方式和普通的Stream一致，可以使用StreamReader、StreamWriter或者直接操作字节数组。
二、服务端实现
服务端的核心任务是创建NamedPipeServerStream实例，并等待客户端连接。以下代码展示了一个支持双向通信、以字节模式运行的简单服务端。
using System;
using System.IO;
using System.IO.Pipes;
using System.Text;
class PipeServer
{
static void Main()
{
// 创建命名管道服务端，管道名为 testpipe
// PipeDirection.InOut 表示双向通信
// PipeTransmissionMode.Byte 表示字节流模式
using (NamedPipeServerStream server = new NamedPipeServerStream(
"testpipe",
PipeDirection.InOut,
1,
PipeTransmissionMode.Byte,
PipeOptions.Asynchronous))
{
Console.WriteLine("等待客户端连接...");
server.WaitForConnection();
Console.WriteLine("客户端已连接");
// 读取客户端发送的数据
byte[] buffer = new byte[1024];
int bytesRead = server.Read(buffer, 0, buffer.Length);
string received = Encoding.UTF8.GetString(buffer, 0, bytesRead);
Console.WriteLine("收到消息: " + received);
// 向客户端回送数据
string response = "服务端已收到: " + received;
byte[] responseBytes = Encoding.UTF8.GetBytes(response);
server.Write(responseBytes, 0, responseBytes.Length);
}
}
}
上面的代码使用using语句确保管道资源被释放。WaitForConnection方法会阻塞当前线程，直到有客户端连入；如果在UI线程中调用，应改为异步的WaitForConnectionAsync以避免界面卡顿。PipeTransmissionMode.Byte适合传输连续字节流，而PipeTransmissionMode.Message则会在每次写操作时作为完整消息边界，读取时可以判断IsMessageComplete。
对于需要并发处理多个客户端的场景，可以在循环中不断创建新的NamedPipeServerStream实例，每个实例处理一个连接，或者使用异步模型配合Task.Run。需要注意的是，同一名称的管道在服务端未释放前，客户端无法再次以相同名称创建新连接，因此要及时关闭或释放旧实例。
三、客户端实现
客户端相对简单，只需用相同的管道名连接本机服务端即可。下面示例展示了如何发送消息并读取回应。
using System;
using System.IO;
using System.IO.Pipes;
using System.Text;
using System.Threading.Tasks;
class PipeClient
{
static async Task Main()
{
using (NamedPipeClientStream client = new NamedPipeClientStream(
".",
"testpipe",
PipeDirection.InOut,
PipeOptions.Asynchronous))
{
// 连接到本机服务端，超时时间设为 5 秒
await client.ConnectAsync(5000);
Console.WriteLine("已连接到服务端");
string message = "你好，命名管道";
byte[] sendBytes = Encoding.UTF8.GetBytes(message);
await client.WriteAsync(sendBytes, 0, sendBytes.Length);
byte[] buffer = new byte[1024];
int bytesRead = await client.ReadAsync(buffer, 0, buffer.Length);
string response = Encoding.UTF8.GetString(buffer, 0, bytesRead);
Console.WriteLine("服务端回应: " + response);
}
}
}
客户端构造函数的第一个参数表示服务器名称，使用小数点代表本机。ConnectAsync可以设置等待超时，避免服务端未启动时程序无限期挂起。在读写时同样推荐使用异步方法，这样在控制台程序或后台服务中都不会阻塞主逻辑。
如果服务端采用的是消息模式，客户端也应以相同模式连接，否则可能出现读取到的数据被拆分或合并的情况。在实际项目中，建议双方约定好消息格式，例如在JSON前加上长度前缀，或者统一使用Message模式并由接收方循环读取直到IsMessageComplete为true。
四、消息模式与字节模式的区别
字节模式把管道当作不间断的字节流，多次写入可能被接收方一次读完，一次写入也可能被分多次读，这要求应用层自己界定消息边界。消息模式则由系统保证每次Write对应接收端的一次完整消息，适合命令式交互。
| 对比项 | 字节模式 | 消息模式 |
|---|---|---|
| 边界保证 | 无 | 有 |
| 适用场景 | 大文件、连续日志 | 短指令、请求响应 |
| 读取判断 | 依赖长度协议 | 可查IsMessageComplete |
上表列出了两种传输模式的主要差异。在本地进程通信中，如果消息都很短且要求明确边界，消息模式能减少解析复杂度；若需要高频传输大量数据，字节模式开销更小。
五、常见异常与处理建议
使用命名管道时，TimeoutException会在客户端连接超时时抛出，应捕获后提示服务未启动。IOException可能出现在管道被对端断开后继续读写，此时需要重建连接。另外，如果服务端以不同方向（如仅In）创建管道，而客户端尝试Out操作，也会触发异常。
建议在生产代码中为管道通信封装独立的服务类，统一处理连接失败、断线重连以及消息编解码，避免业务逻辑和底层API耦合过紧。
通过合理选择传输模式、使用异步接口并加上异常处理，C#中的NamedPipe可以非常稳定地承担本地进程间通信任务，且无需开放任何网络端口，安全性较高。