C# 创建命名管道服务器

通过创建 NamedPipeServerStream 的一个新实例，来创建服务器。NamedPipeServerStream 派生自基类 PipeStream，PipeStream 派生自 Stream 基类，因此可以使用流的所有功能，例如，可以创建CryptoStream 或 GZipStream，把加密或压缩的数据写入命名管道。构造函数需要管道的名称，通过管道通信的多个进程可以使用该管道。.

用于下面代码片段的第二个参数定义了管道的方向。服务器流用于读取，因此将方向设置为 PipeDirection.In。命名管道也可以是双向的，用于读写，此时使用PipeDirection.InOut。匿名管道只能是单向的。接下来，调用WaitForConnection()方法，命名管道等待写入方的连接。然后，在一个循环中(直到收到消息“bve”)，管道服务器把消息读入缓冲区数组，把消息写到控制台：

private static void PipesReader(string pipeName)
{
  try
  {
    using (var pipeReader =
      new NamedPipeServerStream(pipeName, PipeDirection.In))
    {
      pipeReader.WaitForConnection();
      Console.WriteLine ("reader connected"); 
      const int BUFFERSIZE = 256; 
      bool completed = false; 
      while (!completed)
      {
        byte[] buffer = new byte[BUFFERSIZE];
        int nRead = pipeReader.Read(buffer, 0, BUFFERSIZE);
        string line = Encoding.UTF8.GetString(buffer, 0, nRead); 
        Console.WriteLine(line);
          if (line == "bye") completed = true;
        }
      }
      Console.WriteLine("completed reading"); 
      Console.ReadLine();
    }
    catch (Exception ex)
    {
      Console.WriteLine(ex.Message);
    }
  }
}

以下是可以用命名管道配置的其他一些选项:

可以把枚举 PipeTransmissionMode 设置为 Byte 或 Message。设置为Byte，就发送一个连续的流，设置为 Message，就可以检索每条消息。
使用管道选项，可以指定 WriteThrough 立即写入管道，而不缓存。
可以为输入和输出配置缓冲区大小。
配置管道安全性，指定谁允许读写管道。
可以配置管道句柄的可继承性，这对与子进程进行通信是很重要的。

因为 NamedPipeServerStream 是一个流，所以可以使用 StreamReader，而不是读取字节数组，该方法简化了代码：

var pipeReader = new NamedPipeServerStream(pipeName, PipeDirection.In); 
using (var reader = new StreamReader(pipeReader))
{
  pipeReader.WaitForConnection();
  Console.WriteLine("reader connected"); 
  bool completed = false; 
  while (!completed)
  {
    string line = reader.ReadLine(); 
    Console.WriteLine(line);
    if (line == "bye") completed = true; 
  }
}

董川民