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

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

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

返回的结果


相关推荐

无力吐槽的自动续费(你被自动续费困扰过吗?)

今天因为工作需要,需要在百度文库上下载一篇文章。没办法,确实需要也有必要,只能老老实实的按要求买了个VIP。过去在百度文库上有过类似经历,当时为了写论文买了一个月的VIP,后面也没有太注意,直到第二个...

百度文库推出“文源计划”创作者可一键认领文档

11月7日,百度文库发布了旨在保护创作者权益的“文源计划”。所谓“文源计划”,即为每一篇文档找到源头,让创作者享受更多的权益。据百度文库总经理李小婉介绍,文源计划分为三部分,分别是版权认证、版权扶持和...

有开放大学学号的同学,百度文库高校版可以用了。

还在网上找百度文库的下载方式,只要从身边的朋友在读开放大学的,那他(她)的学号就可以登陆到国家开放大学图书馆,还使用百度文库高校版来下载。与百度文库稍有不同,但足够使用了。现转国图链接如下:htt...

搜索资源方法推荐(搜索资源的方法)

今天msgbox就要教大家如何又快又准的搜到各类资源,第一点,排除干扰百度搜索出来啊经常前排展示它的产品以及百度文库,如何去除呢?很简单,后面输入空格减号百度文库,比如你搜高等数学百度文库很多,只要后...

一行代码搞定百度文库VIP功能(2021百度文库vip账号密码共享)

百度文库作为大家常用查资料找文档的平台,大多数文档我们都可以直接在百度文库找到,然而百度文库也有让人头痛的时候。好不容易找到一篇合适的文档,当你准备复制的时候他却提示你需要开通VIP才能复制~~~下载...

百度文库文档批量上传工具用户说明书

百度文库文档批量上传工具用户说明书1、软件主要功能1、批量上传文档到百度文库,支持上传到收费、VIP专享、优享以及共享。2、支持自动分类和自动获取标签3、支持多用户切换,一个账户传满可以切换到...

百度文库现在都看不到文档是否上传成功,要凉了吗?

打开知识店铺,百度文库文档里显示都是下载这一按键,上传的文档也看不到是否成功?咋情况,要取消了吗?没通过审核的也不让你删除,是几个意思,想通吃吗?现在百度上传文档也很费劲,有时弄了半天的资料上传审核过...

微信推广引流108式:利用百度文库长期分享软文引流

百度文库相对于百度知道、百度百科来说,操作上没那么多条条框框,规则上也相对好把握些。做一条百度知道所花费的精力一般都会比做一条百度文库的要多些,老马个人操作下来觉得百度文库更好把握。但见仁见智吧,今天...

职场“避雷”指南 百度文库推出标准化劳动合同范本

轰轰烈烈的毕业季结束了,众多应届生在经过了“职场海选”后,已正式成为职场生力军的一员。这一阶段,除了熟悉业务,签订劳动合同、了解职场福利也迅速被提上日程。而随着国人法律意识的增强,百度文库内《劳动合同...

《百度文库》:素材精选宝库(百度文库官网首页)

《百度文库》:独特功能助力选择高质量素材在当今信息爆炸的时代,如何高效地获取并利用有价值的素材成为了许多人面临的挑战。而《百度文库》作为百度公司推出的一款在线文档分享平台,凭借其丰富的资源、强大的功能...

深度整合和开放AI能力 百度文库和网盘推出内容操作系统「沧舟OS」

【TechWeb】4月25日消息,Create2025百度AI开发者大会上,百度文库和百度网盘推出全球首个内容操作系统——沧舟OS。基于沧舟OS,百度文库APP全新上线「GenFlow超能搭子」...

女子发现大二作业被百度文库要求付费下载,律师:平台侵权,应赔偿

近日,28岁的黎女士在百度百科搜索家乡的小地名时,发现了自己在大二完成的课题作业。她继续搜索,发现多个平台收录了该文,比如豆丁网和文档之家等,有的还设置了付费或积分下载。2月15日,九派新闻记者以用户...

2016杀入百度文库的新捷径,只有少数人才知道的喔

百度的产品在SEO优化中的分量真不用多说,其实很多人都像我一样一直在找捷径。但是我经常发现很多人都是在用死方法。比如发贴吧发帖而不知道去申请一个吧主,知道自问自答而不知道去申请一个合作资格。口碑和贴吧...

百度文库付费文档搜索方法(百度文库付费文档搜索方法有哪些)

一直以来,百度文库中无论是个人中心还是个人主页,都没有像淘宝一样的店内搜索功能,连最近新开的知识店铺也没有设计店内搜索功能,这无论是对上传用户还是下载用户都不方便,上传用户想要搜索自己的文档无法办到...

供读者免费使用!泰达图书馆机构版百度文库新年上新啦

在泰达图书馆读者使用百度文库数字资源不需要VIP,免-费-用!惊不惊喜?快来了解一下吧……新年伊始,为满足区域企业、高校、科研院所以及居民群众在教学、科研及学习过程中,对各类文献资源的需求,泰达图书馆...

取消回复欢迎 发表评论: