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

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

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

返回的结果


相关推荐

硬件大师AIDA64 5.60.3716更新下载:“认准”Win10

著名硬件测试工具AIDA64更新至5.60.3716Beta版,本次更新修复了Win10Build版本号检测错误问题,识别更准确。另外还添加了对ITEIT8738F传感器、ASRock主板、NVI...

互联网病毒木马与盗版软件流量产业链(一)

A.相关地下产业链整体深度分析可能很多用户都有这样的经历,就是不管打开什么网站,甚至根本就没有打开浏览器,都会跳出来一堆的弹窗广告。那么,这个用户要么是中的病毒木马,或者是使用了盗版软件。不管是...

穿越火线tenparty.dat文件损坏怎么办?

很多玩家在玩火线的时候经常会因弹出错误代码,而被退出游戏。下面就教大家一些常见错误代码的解决方案。方法/步骤1SX提示码提示说明:您的电脑出现1,xxx,0(xxx代表任意数字)提示码,存在游...

办公小技巧015:如何关闭Windows Defender安全中心

WindowsDefenderWindowsDefender是Widows中自带杀毒软件,可以检测及清除潜藏在操作系统里的间谍软件及广告软件。为电脑提供最高强度的安全防护,也被誉为Windows的...

Win7/8.1/10团灭:微软发现严重漏洞

据外媒报道称,微软已经停止为Windows7发布新的安全更新了,理由是IE存在严重漏洞。存在严重漏洞的IE按照微软的说法,这个远程代码执行漏洞存在于IE浏览器处理脚本引擎对象的内存中。该漏洞可能以一...

WinCC flexible 2008 SP4 的安装步骤及系统要求

1、软件安装过程安装注意事项(必须严格遵守):软件仅支持以下操作系统(必须是微软原版的操作系统,Ghost版系统不支持,如番茄花园、雨林木风、电脑城装机版等):WinCCflexible2008...

Windows三方杀毒防护软件可能问题以及使用建议

在处理ECSWindows相关案例中,我们遇到很多奇怪的操作系统问题,例如软件安装失败,无法激活操作系统,无法访问本地磁盘,网络访问受到影响,系统蓝屏,系统Hang等,排查发现这与客户安装的各类杀...

杀毒软件被指泄露个人隐私(杀毒软件查出来一定是毒吗)

最近的多篇报道显示,你使用的杀毒软件在监视着你,而不仅仅是你计算机上的文件。2014年的一项研究使用虚拟机监视了杀毒软件产品向企业发送了什么信息。他们发现,所有测试的杀毒软件都给电脑分配了一个唯一的识...

开源杀毒软件ClamAV在推出约20年后终于到达1.0版本

ClamAV是一个开源的反病毒引擎,用于检测木马、病毒、恶意软件和其他恶意威胁。与商业Windows反恶意软件程序相比,它的检测水平相当低,但开发工作已经持续了几十年。该工具可用于所有平台,尽管它主要...

【Excel函数使用】时分秒时间怎么转换成秒?(二)

本节主要分享的函数是IFERROR和NUMBERVALUE上回我们用MID和FIND函数已经将数值提取出来,但是一些错误的返回值显示“#VALUE!”,此时我们需要检验错误返回值,并将错误值返回指定值...

家电写文案,你看过吗?(家电文案 顶尖文案)

让家电说话,如此文案令人惊艳。文案,不止文案。这些年,文案君看过了太多的文案,也见证了很多惊艳文案的诞生。从一开始的文案由专职人员进行撰写,到现在的段子手泛滥,文字的力量总能在无形中打动消费者的心。但...

DELL T7600工作站安装系统详细图文教程

由于芯片组原因,T3600/T5600/T7600将采用主板上IntelC600SCUStorageController硬盘控制器或者随机附带PERCH310/H710P的阵列卡所以安装系...

10kV电机运行柜与短接柜起动故障的分析

10kV电机启动后,当电流下降至1.5倍额定电流及综保设定时间满足(如40s),短接柜切除热变电阻软启动器,此时电机投全压,起动过程结束。本文扼要介绍其工作原理,并对两起启动失败案例进行分析与探讨。1...

海峡两岸的较量,2000年以来,解放军海军,如何全面碾压?

在之前的文章中,作者和大家聊了一系列关于我国海峡两岸空军的力量对比。在90年代到21世纪初期,台湾省空军的优势非常明显。今天,我们聊聊海峡两岸海军力量的对比。不得不说,90年代—21世纪初期,台湾省海...

含显示器的3600元档,Intel+A卡,性价比是否在次提升?

前言之前的发帖很多小伙伴都觉得RX5808G的性价比很高。千元级别里面RX5808G对比GTX16504G,不管是参数上,还是在实际表现上,RX5808G确实表现要强一些。对于没有偏见的小伙伴...

取消回复欢迎 发表评论: