百度360必应搜狗淘宝本站头条
当前位置:网站首页 > 技术文章 > 正文

C# 基于命名管道(Named Pipes) 的进程间通信(IPC)

cac55 2025-03-24 14:17 18 浏览 0 评论

基于命名管道(Named Pipes) 的进程间通信(IPC),用于在同一台机器不同进程之间进行高效、可靠的数据传输,是一种基于消息或流的通信机制。管道有一个唯一的名称,客户端和服务器端通过名称连接到同一个管道,支持客户端和服务器端同时发送和接收数据。

以下,是一个C#的实例:


服务器端:

using System;
using System.Collections.Generic;
using System.IO;
using System.IO.Pipes;
using System.Linq;
using System.Threading;
using System.Web;

namespace NamedPipeServerForWindEDB
{
    class Program
    {
        private static bool _isRunning = true;

        static void Main(string[] args)
        {
            Console.WriteLine("与财务分析最终版配称套件,用于更新EDB数据,相应进程已经启动...");

            while (_isRunning)
            {
                using (var pipeServer = new NamedPipeServerStream("WindDataPipe", PipeDirection.InOut, NamedPipeServerStream.MaxAllowedServerInstances, PipeTransmissionMode.Message, PipeOptions.Asynchronous))
                {
                    try
                    {
                        Console.WriteLine("等待主程序连接...");
                        pipeServer.WaitForConnection();
                        Console.WriteLine("主程序已连接。");

                        using (var reader = new StreamReader(pipeServer))
                        using (var writer = new StreamWriter(pipeServer))
                        {
                            string command = reader.ReadLine();

                            Console.WriteLine("收到指令: " + command);

                            if (command == "SHUTDOWN")
                            {
                                _isRunning = false;
                                writer.WriteLine("Shutdowning...");
                                writer.Flush();
                              
                            }
                            else
                            {
                                string data = GetDataFromWind(command);
                                writer.WriteLine(data);
                                writer.Flush();
                                Console.WriteLine("数据已返回。");
                            }
                        }
                    }
                    catch (Exception ex)
                    {
                        Console.WriteLine("发生错误: " + ex.Message);
                    }
                    finally
                    {
                        if (pipeServer.IsConnected)
                        {
                            pipeServer.Disconnect();
                            Console.WriteLine("断开当前连接。");
                        }
                    }
                }
            }

            Console.WriteLine("子进程已关闭。");
        }

        // 模拟调用Wind API获取数据
        static string GetDataFromWind(string request)
        {
            // 这里替换为实际的Wind API调用逻辑
            Thread.Sleep(1000); // 模拟耗时操作


            string strContent = "";

            List Requestitems = request.Split('|').ToList();

            if (Requestitems.Count == 3 )
            {
                string strStart=Requestitems[1];
                string strEnd=Requestitems[2];

                List EDBCodes = Requestitems[0].Split(';').ToList();


                foreach (string strCode in EDBCodes)                
                {
                    strContent = strContent + strCode + strStart + strEnd + "|";
                } 
            }
            return $"数据来自Wind API,请求内容: {strContent}";
        }

    }
}




客户端:

using System;
using System.Diagnostics;
using System.IO.Pipes;
using System.Windows.Forms;

namespace WinFormsApp1
{
    public partial class Form1 : Form
    {
        private Process subProcess = new Process(); // 子进程对象
        private bool isSubProcessRunning = false; // 标记子进程是否已启动

        public Form1()
        {
            InitializeComponent();
        }

        // 启动子进程按钮点击事件
        private void button1_Click(object sender, EventArgs e)
        {

            if (!isSubProcessRunning)
            {
                // 启动.NET 4.8子进程
                subProcess = StartSubProcess();
                isSubProcessRunning = true;
            }

            // 发送请求
            SendRequest("windEDBCode1;windEDBCode2;windEDBCode3|2023-01-01|2024-01-01");
        }

        // 启动子进程
        private Process StartSubProcess()
        {
            ProcessStartInfo startInfo = new ProcessStartInfo
            {
                FileName = @"D:\我的云文档\C#程序开发\NamedPipeServerForWindEDB\bin\Debug\NamedPipeServerForWindEDB.exe", // 替换为子进程的路径
                UseShellExecute = false,
                CreateNoWindow = true
            };

            Process subProcess = new Process { StartInfo = startInfo };
            subProcess.Start();
            return subProcess;
        }

        private void SendRequest(string request)
        {
            try
            {
                using (var pipeClient = new NamedPipeClientStream(".", "WindDataPipe", PipeDirection.InOut, PipeOptions.Asynchronous))
                {
                    pipeClient.Connect(5000); // 设置连接超时

                    using (var writer = new StreamWriter(pipeClient))
                    using (var reader = new StreamReader(pipeClient))
                    {
                        writer.WriteLine(request);
                        writer.Flush();

                        string data = reader?.ReadLine()??""; // 等待服务器端返回数据

                        this.Invoke((MethodInvoker)delegate
                        {

                            if (data.Contains("Shutdowning..."))
                            {
                                //  忽略
                            }
                            else
                            {
                                MessageBox.Show("收到数据: " + data);
                            }
                            
                        });
                    }
                }
            }
            catch (TimeoutException)
            {
                MessageBox.Show("连接子进程超时,请检查子进程是否已启动。");
            }
            catch (Exception)
            {
              
            }
        }

        // 窗体关闭事件
        private void Form1_FormClosing(object sender, FormClosingEventArgs e)
        {
            // 检查子进程是否正在运行
            if (isSubProcessRunning && subProcess != null && !subProcess.HasExited)
            {
                try
                {
                    // 发送关闭指令
                    SendRequest("SHUTDOWN");

                    // 等待子进程退出
                    if (!subProcess.WaitForExit(5000)) // 设置超时时间(例如5秒)
                    {
                        MessageBox.Show("子进程未正常退出,已强制终止。");
                        subProcess.Kill(); // 强制终止子进程
                    }
                }
                catch (Exception)
                {
                   
                }
                finally
                {
                    // 标记子进程已关闭
                    isSubProcessRunning = false;
                }
            }        
           
        }
    }
}

返回的结果


相关推荐

上网行为管理有什么用,行为审计软件解决方案?

上网行为管理有什么用,行为审计软件解决方案?我们生活在互联网的时代,网络是比较复杂的,有时候经常会出现一些网络违规现象,这时候就可以进行上网行为管理了,现在有很多的公司都会进行上网行为管理,因为这样可...

上网行为管理软件如何监控员工访问网址信息

上网行为管理软件可以通过域之盾软件来监控员工访问的网址信息:主要方式↓1、网页日志记录上网行为管理软件可以通过网页日志记录功能,完整地记录员工在工作中访问的所有网站,包括访问时间、访问页面、访问方式等...

企业如何确保上网行为管理顺利进行?

企业的稳定长久发展离不开对员工的上网行为管理,因为员工的上网行为关乎到工作效率、生产效率、以及重要的数据信息安全问题。一旦有不规范的上网行为,便容易造成企业终端数据泄密事件,对企业造成重大的财产损失以...

员工上网行为监控如何实现?六个妙招!帮你轻松管理员工上网!

员工上网行为不仅关乎个人工作效率,更直接影响到企业的信息安全和整体运营。不当的上网行为,如访问非法网站、泄露公司机密、长时间闲聊等,都可能给企业带来不可估量的损失。因此,监控员工上网行为,不仅是为了提...

终端管理系统规范企业上网行为管理

企业内部经常会遇到不同的上网行为管理问题,如职员在上班时间炒股、打游戏、上网聊天等不正当的上网行为,用U盘、硬盘等移动设备随意拷贝资料,终端资产难以管理等,降低办公效率的同时,也增加了企业内部泄密风...

企业如何进行上网行为管理?_如何管理企业网络

企业如何进行上网行为管理?为了保障网络安全,提高员工工作效率,企业有必要部署上网行为管理。上网行为管理可对企业内部员工的上网行为进行全方位有效管理,保护Web访问安全,降低互联网使用风险,避免机密信息...

演员赵露思的官方微博注销的原因是什么?

根据多方权威媒体报道及平台验证,演员赵露思的微博账号已于2025年8月19日正式注销。目前搜索该账号显示“因用户自行申请关闭,现已无法查看”。这一结果源于她8月13日在直播中宣布的注销决定,当时她直言...

分手传闻仅4月,关晓彤的一张海边亲吻照,撕碎了鹿晗最后的体面

“原来八年真能被四个月的‘海边吻照’一键清空。”热搜上那张模糊的侧脸一贴,评论瞬间爆炸:关晓彤亲的是李昀锐,鹿晗的生日祝福还停留在去年。八年,够让一部剧从开播到大结局,也够让一对顶流情侣把微博背景换成...

计算机基础知识(五)(3)_计算机基础知识100道

四、如何使用计算机4、软件的通用使用方法计算机发展到现在,正常使用时均采用窗口式界面。我们的介绍不涉及苹果机。操作系统从DOS(DOS阶段有两类,一类是微软的,称为MS—DOS;另一类称为PC—DOS...

笔记本的这些基础知识,你再不知道,就真的被社会淘汰了!

请您在阅读前点击上面的“关注”二字,后续会为您提供更多有价值的电脑知识,感谢每一位朋友的支持!这篇文章依然是给大家讲讲关于笔记本电脑的基础知识,新手小白可一定要收藏起来,以后想看的时候可以找出来就看,...

电脑基础知识,引起电脑故障的原因

引起电脑出现故障的原因非常多,概括来说主要包括以下几个方面的问题。操作不当:操作不当是指误删除文件或非法关机等不当操作。操作不当通常会造成电脑程序无法运行或电脑无法启动,修复此类故障,只要将删除或损坏...

笔记本电脑新手使用教程,笔记本电脑使用技巧

学电脑能够快速入门是每个新手梦寐以求的事情,但是不是每个人都能快速入门的。但是如果定制好合理计划,循序渐进,就会收到非常好的效果。今天小编来跟大家说说笔记本电脑新手教程的详细介绍-装机吧,大家一起...

电脑基础知识:(二)电脑主机_电脑主机组成图解

你好!我是麦秋~前言现代生活随着互联网通讯的快速发展,通讯技术日趋完美,应用软件日益普及,电脑的使用与维护则成为人们日常生活中密不可分的、重要的生活内容。电脑恐怕是中老年人的短板,然而又是急需解决的问...

电脑基础知识:(六)电脑应用程序_电脑的应用程序是什么意思

你好!我是麦秋~应用软件是专为解决一些具体问题的软件,是体现电脑用途的部分,种类繁多,如:办公软件、游戏软件、杀毒软件等;自媒体平台上的西瓜、头条、抖音、剪映等,对于上述软件主要是操作和使用上的问题,...

键盘操作方法大全_键盘操作教程

【键盘操作方法大全】键盘可不仅仅能帮我们打字哦,还有很多快捷的操作你都知道吗?除了Ctrl+C、Ctrl+V以外,再多学几种吧,让你用起电脑来十指如飞~别再慢慢用鼠标点了,用开始键+Tab键切换程序让...

取消回复欢迎 发表评论: