C# 基于命名管道(Named Pipes) 的进程间通信(IPC)
yuyutoo 2025-06-10 03:12 2 浏览 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<string> Requestitems = request.Split('|').ToList();
if (Requestitems.Count == 3 )
{
string strStart=Requestitems[1];
string strEnd=Requestitems[2];
List<string> EDBCodes = Requestitems[0].Split(';').ToList();
foreach (string strCode in EDBCodes)
{
strContent = strContent + strCode + strStart + strEnd + "|";
}
}
return #34;数据来自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;
}
}
}
}
}
返回的结果
相关推荐
- MyBatis的SQL执行流程不清楚?看完这一篇就够了
-
推荐学习真香警告!Alibaba珍藏版mybatis手写文档,刷起来...
- SpringBoot开发必备!49个内置工具类,让你的代码效率翻倍!
-
作为一名Java开发者,你是否经常为字符串处理、文件操作、数据验证等重复性代码头疼?SpringBoot的武器库里藏着...
- C# 基于命名管道(Named Pipes) 的进程间通信(IPC)
-
基于命名管道(NamedPipes)的进程间通信(IPC),用于在同一台机器不同进程之间进行高效、可靠的数据传输,是一种基于消息或流的通信机制。管道有一个唯一的名称,客户端和服务器端通过名称连接到...
- 十年之重修MyBatis原理(mybatis方法重载)
-
弱小和无知并不是生存的障碍,傲慢才是。--------面试者...
- C#串口通信(c#串口通信界面)
-
串口通信(SerialCommunications)是指外设和计算机间通过数据信号线、地线等按位(bit)进行传输数据的一种通信方式,属于串行通信方式,能够实现远距离通信,长度可达1200米。尽管比...
- C#中使用命名管道进行进程通信的实例
-
1新建解决方案NamedPipeExample...
- 继GitHub之后 OpenAI为ChatGPT推出OneDrive和SharePoint连接器
-
上周,OpenAI宣布推出ChatGPT的GitHub连接器,允许用户对其源代码库进行深入研究。将GitHub与ChatGPT连接后,用户可以提出问题,深度研究代理将读取和搜索存储库的...
- Power BI:如何在SharePoint中嵌入Power BI报告?
-
问题描述:今天业务同事来询问如何才能将自己开发的PowerBI报告嵌入团队使用的SharePoint页面中,以更直观地和团队成员分享可视化报告。(SharePoint是微软推出的可以用来存储、整理、...
- O365(世纪互联)SharePoint 之调查列表简单介绍
-
前言SharePoint中为了提供了很多开箱即用的应用程序,比如调查列表就是其中之一,同样,在O365版本里(国际版和世纪互联版本均可),也有这样的调查列表可以供我们使用,而使用起来非常方便和快速,就...
- 制作Excel电子表格必备的:Excel 2021 mac中文版
-
MicrosoftExcel2021forMac是一款运行在Mac平台上的办公软件,OfficeExcel2021forMac中文版是办公必不可少的软件,主要用于制作电子表格等,这里带...
- 微软SharePoint新特性:能以邮件方式向目标发送新闻内容
-
IT之家8月30日消息,微软今天发布新闻稿,宣布为SharePoint服务引入新特性,允许企业将新闻动态转换为电子邮件,并以时事通讯、安全公告、警告等主题发送给感兴趣的用户。微软在新闻稿中...
- 在Access中创建Sharepoint列表的链接表
-
在Access中提供了一个DoCmd.TransferSharePointList方法,一行代码就可以搞定。使用TransferSharePointList方法从SharePointFoun...
- BBC推荐:12月最值得一看的5部电影 Five films to watch in December
-
年终岁末,还有哪些精彩电影在等着我们呢?迪士尼的《欢乐满人间2》绝对是合家欢电影的首选,超级英雄迷们将能看到索尼动画《蜘蛛侠:平行宇宙》,福尔摩斯的粉丝们千万别错过《福尔摩斯与华生》。还有朱莉亚·罗伯...
- 基于锂离子电池的电池荷电状态 (SOC) 和运行健康状态 (SOH) 估计技术
-
简介基于锂离子(Li-ion)电池单元的电池组广泛用于各种应用,例如:混合动力汽车(HEV)、电动汽车(EV)、可供日后使用的再生能源储存以及用于各种目的(电网稳定性、调峰和再生能源时移等)的...
- 深入解析电池充电状态 (SOC) 和运行状态 (SOH) 估计技术
-
基于锂离子(Li-ion)电池单元的电池组广泛用于各种应用,例如:混合动力汽车(HEV)、电动汽车(EV)、可供日后使用的再生能源储存以及用于各种目的(电网稳定性、调峰和再生能源时移等)的电网...
你 发表评论:
欢迎- 一周热门
-
-
前端面试:iframe 的优缺点? iframe有那些缺点
-
带斜线的表头制作好了,如何填充内容?这几种方法你更喜欢哪个?
-
漫学笔记之PHP.ini常用的配置信息
-
推荐7个模板代码和其他游戏源码下载的网址
-
其实模版网站在开发工作中很重要,推荐几个参考站给大家
-
[干货] JAVA - JVM - 2 内存两分 [干货]+java+-+jvm+-+2+内存两分吗
-
正在学习使用python搭建自动化测试框架?这个系统包你可能会用到
-
织梦(Dedecms)建站教程 织梦建站详细步骤
-
【开源分享】2024PHP在线客服系统源码(搭建教程+终身使用)
-
2024PHP在线客服系统源码+完全开源 带详细搭建教程
-
- 最近发表
-
- MyBatis的SQL执行流程不清楚?看完这一篇就够了
- SpringBoot开发必备!49个内置工具类,让你的代码效率翻倍!
- C# 基于命名管道(Named Pipes) 的进程间通信(IPC)
- 十年之重修MyBatis原理(mybatis方法重载)
- C#串口通信(c#串口通信界面)
- C#中使用命名管道进行进程通信的实例
- 继GitHub之后 OpenAI为ChatGPT推出OneDrive和SharePoint连接器
- Power BI:如何在SharePoint中嵌入Power BI报告?
- O365(世纪互联)SharePoint 之调查列表简单介绍
- 制作Excel电子表格必备的:Excel 2021 mac中文版
- 标签列表
-
- mybatis plus (70)
- scheduledtask (71)
- css滚动条 (60)
- java学生成绩管理系统 (59)
- 结构体数组 (69)
- databasemetadata (64)
- javastatic (68)
- jsp实用教程 (53)
- fontawesome (57)
- widget开发 (57)
- vb net教程 (62)
- hibernate 教程 (63)
- case语句 (57)
- svn连接 (74)
- directoryindex (69)
- session timeout (58)
- textbox换行 (67)
- extension_dir (64)
- linearlayout (58)
- vba高级教程 (75)
- iframe用法 (58)
- sqlparameter (59)
- trim函数 (59)
- flex布局 (63)
- contextloaderlistener (56)