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

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

cac55 2025-03-24 14:17 16 浏览 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;
                }
            }        
           
        }
    }
}

返回的结果


相关推荐

unetbootin中文版:能够将Linux系统装进U盘的U盘启动盘制作工具

unetbootin中文版是一款能够将Linux操作系统装进U盘或移动硬盘的U盘启动盘制作工具,制作好的U盘启动盘能够用于电脑的维护和系统还原等操作,使用起来非常地不错。该软件不会基于操作系统使用特定...

实用之选,实用之改:DELL 戴尔 灵越14CR-4528B 小改作业

昨天发布了一篇三脚架,今天有时间也写写早就准备写的DELL戴尔灵越14CR-4528B作业吧。话说上个笔记本还是2006年底买的华硕A6JE,电脑挺不错的,在家上上网也够用了,就是转轴设计缺陷,容...

教你如何制作一个启动U盘,从此电脑不用找专人做系统

在电脑使用中,老是遇到卡顿,蓝屏,重启等很多故障,大多都是因为自己日常使用习惯而造成的,很多用户在下载软件的时候不知不觉中都被安装许多乱七八糟的软件,当电脑乱七八糟的东西过多的时候我们就重新来装一个系...

8、Deepin操作系统启动盘(系统盘)制作

1、在Deepin官网https://www.deepin.org/zh/download/下载原版Deepin操作系统2、同时在Deepin官网https://www.deepin.org/zh/d...

电脑死机怎么办,电脑如何使用U盘重装系统

电脑死机是我们最常遇到的系统故障,遇到死机时通常重启就可以解决,不过系统损坏引起的死机就只能重装系统,那么电脑死机如何重装系统呢?下面来看看电脑死机怎么办如何使用U盘重装系统_小白一键重装系统官网。 ...

bootmgr is compressed无法启动系统

bootmgriscompressedPressCtrlAltDeltorestart,电脑启动后无法正常开机出现了这样的字样,就是说明你的C盘驱动被压缩解决方法:1、使用系统光盘或者...

新手教程!如何分辨BIOS启动列表(菜单)中的各种启动项

在BIOS启动菜单中识别各类启动项,是新手安装系统或调整启动顺序的必备技能。下面用最直观的方式,为你梳理常见启动项及其含义,帮助你快速上手:一、传统存储设备启动项1.Floppy(软盘驱动器)对应...

带回家的MINI客厅电脑,自学成才,分享U盘装系统教程

刚好老家新装修了房子,客厅买了个大电视,本来是想在客厅弄台主机,接电视玩,大屏幕玩的才爽,但是台式机箱太占地方了。网上逛了一圈,发现有专门的客厅电脑,就搞了一个,外形不错,放客厅很有档次,主要是主机太...

电脑基础知识:BIOS简介及其与Windows操作系统的关系

什么是BIOS?BIOS,全称BasicInputOutputSystem,即“基本输入输出系统”,是一段固化在电脑主板芯片上的底层固件程序。它类似于一款极简化的操作系统,负责电脑开机时的硬件初...

win 7 系统注册表文件丢失或损坏,求不重做系统的解决办法!

粉丝问题解答:win7系统注册表文件丢失或损坏,求不重做系统的解决办法!解决方法:你只需要有启动盘即可,不需要其他的。之所以要求启动盘,是因为下面要对系统文件进行还原覆盖,所以不能用原系统启动。用...

UEFI怎么装Win7 小编呕血解难点!

自从广开言路之后,小编就被你们害苦了,这不,一条评论又让小编彻夜难眠。另外某些小伙伴坐不上沙发后提出要上墙的需求,其实呢只要大家提出的问题具有普遍性、有难度、而且适合小编做微信内容的话,都有机会将你们...

固态攻坚战——ASUS 华硕k45v换固态、拆机清灰教程

作者:蘑菇爱上我现在固态白菜价固态对于电脑体验的提升还是很大的对于固态存储芯片的问题没什么好说的有钱mlc,没钱tlc,不需要考虑什么寿命的问题,我用了一年多的m600,写入才3TB品牌很重要,主控...

MBR启动报错?Win10不重装一样能好!

Win10一遇到启动故障,很多小伙伴可能就会抓瞎,这可怎么弄,我不会修复啊!其实大可不必惊慌,就像这种最常见的Winload启动错误,多半都是MBR分区表丢失造成的(UEFI分区模式的几乎没有这种故障...

从零开始:硬盘手动装系统全攻略

手动安装操作系统是计算机技术必备的基本技能。对于初学者来说,可能会感到有些挑战。但通过掌握硬盘手动装系统方法,你可以亲身体验整个安装过程,进而更好地理解操作系统的工作原理。本文将详细介绍硬盘手动装系统...

电脑开机后显示File:BCD错误0xc000000f

WIN7\WIN8\WIN101、一个win864位PE。这个64位PE的相关文件,路径在boot\BOOT.WIM实机测试,开机后显示File:\EFI\Microsoft\Boot\BCD,...

取消回复欢迎 发表评论: