命名管道跨进程通信实例1（转）

原文地址：/article/4672689.html

本文介绍命名管道使用实例，文中例子是几个客户端都通过一台服务器获得新生成的int类型id。

服务器端功能：当客户端请求一个新的id时，将现有id自增1，然后返回给客户端。

服务器端实现：在程序启动时，启动n个线程，在每个线程中都声明一个NamedPipeServerStream的实例，并循环的WaitForConnection()，将新的id写入到命名管道中，然后断开连接。在程序退出时释放NamedPipeServerStream实例

服务器端代码：

class Program
{
//命名管道名字
private const string PIPE_NAME = "testpipe";
//定义线程数，也是NamedPipeServerStream的允许最多的实例数
private const int MAX_THREAD_COUNT = 3;

private static volatile int _runingThreadCount = 0;
private static volatile int _newID = 0;

private static NamedPipeServerStream[] _serverStreams;

static void Main(string[] args)
{
_serverStreams = new NamedPipeServerStream[MAX_THREAD_COUNT];
//在进程退出时，释放所有NamedPipeServerStream实例
AppDomain.CurrentDomain.ProcessExit += new EventHandler(CurrentDomain_ProcessExit);
//启动线程
StartServers();
Console.Read();
}
/// <summary>
/// 进程退出时释放命名管道
/// </summary>
/// <param name="sender"></param>
/// <param name="e"></param>
static void CurrentDomain_ProcessExit(object sender, EventArgs e)
{
if (_serverStreams != null)
{
foreach (NamedPipeServerStream item in _serverStreams)
{
item.Dispose();
}
}
}
/// <summary>
/// 启动线程
/// </summary>
private static void StartServers()
{
for (int i = 0; i < MAX_THREAD_COUNT; i++)
{
Thread thread = new Thread(new ThreadStart(StartNewIDServer));
thread.Start();
}
}
/// <summary>
/// 启动一个NamedPipeServerStream实例
/// </summary>
private static void StartNewIDServer()
{
NamedPipeServerStream stream = null;
Console.WriteLine("start server in thread：" + Thread.CurrentThread.ManagedThreadId);

stream = _serverStreams[_runingThreadCount] = new NamedPipeServerStream(PIPE_NAME,
PipeDirection.InOut,
MAX_THREAD_COUNT,
PipeTransmissionMode.Message,
PipeOptions.None);
while (true)
{
stream.WaitForConnection();

int newID = ++_newID;
byte[] bytes = BitConverter.GetBytes(newID);
stream.Write(bytes,0,bytes.Length);
stream.Flush();
Console.WriteLine("threadNo:"+Thread.CurrentThread.ManagedThreadId+"\r");
stream.Disconnect();
}
}
}

客户端的功能是不断的发出获得新id的请求，并打印新id，在客户端可以配置服务端的服务器IP。

客户端代码：

class Program
{
private const string PIPE_NAME = "testpipe";
static void Main(string[] args)
{
Console.WriteLine("请输入任何字符回车开始执行程序...");
Console.Read();
do
{
//内网服务器IP，必须是局域网
string serverName = "127.0.0.1";
//声明NamedPipeClientStream实例
using (NamedPipeClientStream clientStream=new NamedPipeClientStream(
serverName,
PIPE_NAME
))
{
//连接服务器
clientStream.Connect(1000);
//设置为消息读取模式
clientStream.ReadMode = PipeTransmissionMode.Message;
do
{
byte[] bytes = new byte[4];
clientStream.Read(bytes,0,4);
int val = BitConverter.ToInt32(bytes,0);
Console.WriteLine("NewID=="+val+"\r");
} while (!clientStream.IsMessageComplete);
}
Thread.Sleep(1);
} while (true);
}
}

在sql server中就使用了命名管道在局域网内挂进程通讯。

在声明NamedPipeServerStream实例是可以指定其实例个数，如果实例数超过这个数，就会抛出“所有管道范例都在使用中”的IO异常。

本例不可以在实际项目中使用。

程序源码下载