C#使用命名管道Pipe实现进程通信实例

淡淡的烟草味﹌ 2022-12-11 07:45 383阅读 0赞

## **1.新建解决方案NamedPipeExample** ##

1.  **创建项目：Client和Server，两者的输出类型均为“Windows 应用程序”。整个程序的结构如下图所示。**  
    ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3MTkyNTcx_size_16_color_FFFFFF_t_70_pic_center]  
    **此Form1为Client的窗体，如下图所示。**  
    ![为][20200929112648600.png_pic_center]  
    **前台代码，如下。**

using System;
    using System.Collections.Generic;
    using System.ComponentModel;
    using System.Data;
    using System.Drawing;
    using System.Linq;
    using System.Text;
    using System.Threading.Tasks;
    using System.Windows.Forms;
    
    using System.IO;
    using System.IO.Pipes;
    using System.Security.Principal;
    
    namespace Client
    { 
        public partial class Form1 : Form
        { 
            NamedPipeClientStream pipeClient =
                new NamedPipeClientStream("localhost", "testpipe", PipeDirection.InOut, PipeOptions.Asynchronous, TokenImpersonationLevel.None);
            StreamWriter sw = null;
            public Form1()
            { 
                InitializeComponent();
            }
    
            private void Form1_Load(object sender, EventArgs e)
            { 
                try
                { 
                    pipeClient.Connect(5000);
                    sw = new StreamWriter(pipeClient);
                    sw.AutoFlush = true;
                }
                catch (Exception ex)
                { 
                    MessageBox.Show("连接建立失败，请确保服务端程序已经被打开。");
                    this.Close();
                }
            }
    
            private void btnSend_Click(object sender, EventArgs e)
            { 
                if (sw != null)
                { 
                    sw.WriteLine(this.txtMessage.Text);
                }
                else
                { 
                    MessageBox.Show("未建立连接，不能发送消息。");
                }
            }
        }
    }

**此Form1为Server的窗体，如下**  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3MTkyNTcx_size_16_color_FFFFFF_t_70_pic_center 1]  
**后台代码，如下。**

using System;
    using System.Collections.Generic;
    using System.ComponentModel;
    using System.Data;
    using System.Drawing;
    using System.IO;
    using System.IO.Pipes;
    using System.Linq;
    using System.Text;
    using System.Threading;
    using System.Threading.Tasks;
    using System.Windows.Forms;
    
    namespace Server
    { 
        public partial class Form1 : Form
        { 
            NamedPipeServerStream pipeServer =
                new NamedPipeServerStream("testpipe", PipeDirection.InOut, 1, PipeTransmissionMode.Message, PipeOptions.Asynchronous);
            public Form1()
            { 
                InitializeComponent();
            }
    
            private void textBox1_TextChanged(object sender, EventArgs e)
            { 
    
            }
    
            private void Form1_Load(object sender, EventArgs e)
            { 
                ThreadPool.QueueUserWorkItem(delegate
                { 
                    pipeServer.BeginWaitForConnection((o) =>
                    { 
                        NamedPipeServerStream pServer = (NamedPipeServerStream)o.AsyncState;
                        pServer.EndWaitForConnection(o);
                        StreamReader sr = new StreamReader(pServer);
                        while (true)
                        { 
                            this.Invoke((MethodInvoker)delegate {  lsvMessage.Text = sr.ReadLine(); });
    
                        }
                    }, pipeServer);
                });
            }
    
            private void maskedTextBox1_MaskInputRejected(object sender, MaskInputRejectedEventArgs e)
            { 
    
            }
        }
    }

**依次运行Server再运行Client**

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3MTkyNTcx_size_16_color_FFFFFF_t_70_pic_center]: /images/20221123/36899b4fe9b64473ab1704de35862d5f.png
[20200929112648600.png_pic_center]: /images/20221123/76cb89486d3b46d285bdfc6df0d82c08.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3MTkyNTcx_size_16_color_FFFFFF_t_70_pic_center 1]: /images/20221123/4c26d5db2fee473c947c02e7dccfe77d.png