最近在做一個數據庫同步軟件.!!
程序 服務端為 一個winform + windows Service 二大模塊.!
由於程序功能的需求. 需要winform 與windows Service進程通訊. 因此使用了 命名管道 來實現功能需求.!
以此記下筆記 , 並付上一Demo
有關 NamedPipeServerStream 類 官方MSDN文檔說明
NamedPipeServerStream pipeServer = new NamedPipeServerStream("testpipe", PipeDirection.InOut, PipeTransmissionMode.Message, PipeOptions.Asynchronous);
void Form1_Load(object sender, EventArgs e)
{
ThreadPool.QueueUserWorkItem(delegate
{
pipeServer.BeginWaitForConnection((o) =>;
{
NamedPipeServerStream server = (NamedPipeServerStream)o.AsyncState;
server.EndWaitForConnection(o);
StreamReader sr = new StreamReader(server);
StreamWriter sw = new StreamWriter(server);
string result = null;
string clientName = server.GetImpersonationUserName();
while (true)
{
result = sr.ReadLine();
if (result == null || result == "bye")
break;
this.Invoke((MethodInvoker)delegate { lsbMsg.Items.Add(clientName+" : "+result); });
}
}, pipeServer);
});
}
有關 NamedPipeClientStream 類 官方MSDN文檔說明
View Code
1 NamedPipeClientStream pipeClient = new NamedPipeClientStream("192.168.1.100", "testpipe", PipeDirection.InOut, PipeOptions.Asynchronous, TokenImpersonationLevel.None); StreamWriter sw = null;
2 void Form2_Load(object sender, EventArgs e)
3 {
4 pipeClient.Connect();
5 sw = new StreamWriter(pipeClient);
6 sw.AutoFlush = true;
7 }
8 private void button1_Click_1(object sender, EventArgs e)
9 {
10 sw.WriteLine(textBox1.Text);
11 }
