进程间通信之命名管道 .net示例

众所周知，命名管道是进程间通信常用的一种方法，他可以在同一台计算机的不同进程之间，或在跨越一个网络的不同计算机的不同进程之间，支持可靠的、单向或双向的数据通信。

其实命名管道通信很类似于客户机/服务器数据通信这种模式，需要建立一个server端，client端。

下面我分别就server，client来给个小例子。

这个例子类似于显示机器电量信息那个工具条。不过这里只是给个实例。当我们手动拖动一个滑动条，这个滑动条的数据信息通过管道与客户端的进度条通信，产生更新。

首先建立server端：

public partial class Form1 : Form { private NamedPipeServerStream pipe; public Form1() { InitializeComponent(); } private void FinishConnection(IAsyncResult ar) { pipe.WaitForConnection(); } private void timer1_Tick(object sender, EventArgs e) { if (pipe.CanWrite) { try { pipe.WriteByte((byte)this.hScrollBar1.Value); } catch (ObjectDisposedException ex) { labelMsg.Text = ex.Message; } catch (InvalidOperationException ex) { labelMsg.Text = ex.Message; } } else { labelMsg.Text="Cannot write pipe"; } } private void button1_Click(object sender, EventArgs e) { pipe = new NamedPipeServerStream("mypipe", PipeDirection.Out, 1, PipeTransmissionMode.Byte, PipeOptions.Asynchronous); pipe.BeginWaitForConnection(new AsyncCallback(FinishConnection), null); } private void button2_Click(object sender, EventArgs e) { pipe.WriteByte((byte)5); } private void hScrollBar1_ValueChanged(object sender, EventArgs e) { if (pipe.IsConnected && pipe.CanWrite) { try { pipe.WriteByte((byte)this.hScrollBar1.Value); } catch (ObjectDisposedException ex) { labelMsg.Text = ex.Message; } catch (InvalidOperationException ex) { labelMsg.Text = ex.Message; } } else { labelMsg.Text = "Cannot write pipe"; } } } 

建立client端：

public partial class Form1 : Form { NamedPipeClientStream pipe; public Form1() { InitializeComponent(); } private void timer1_Tick(object sender, EventArgs e) { if (pipe.IsConnected && pipe.CanRead) { try { int byteData = pipe.ReadByte(); progressBar1.Value = byteData; } catch (ObjectDisposedException ex) { labelMsg.Text = "pipe error"; } catch (InvalidOperationException ex) { labelMsg.Text = "pipe server not setup"; } } else { labelMsg.Text = "pipe has no data"; } } private void button1_Click(object sender, EventArgs e) { pipe = new NamedPipeClientStream("ibm-PC", "mypipe", PipeDirection.In); pipe.Connect(); timer1.Start(); } private void button2_Click(object sender, EventArgs e) { int byteData = pipe.ReadByte(); this.textBox1.Text += byteData; } }