通过创建 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; }
}