# .NET Framework中使用命名管道进行进程间通信

news/2024/4/19 2:18:28

.NET Framework中使用命名管道进行进程间通信

在.NET应用程序中,进程间通信(IPC)是一项常见需求。命名管道提供了一种高效、可靠的方式来在独立运行的进程之间传输数据。本文将展示如何在.NET Framework环境下创建一个WinForms管道客户端应用程序和一个控制台管道服务器应用程序。

WinForms 管道客户端(PipeClientForm.cs)

WinForms应用程序将作为管道的客户端,接收来自服务器的数据,并更新其UI。

初始化项目和控件

首先,在Visual Studio中创建一个新的WinForms应用程序。在主窗体上,我们添加一个ProgressBar和一个Label控件,用于显示从管道接收到的数据。

实现管道连接逻辑

我们使用NamedPipeClientStream来连接到命名管道服务器。由于.NET Framework 4.5.2不支持ConnectAsync方法,我们将在后台任务中使用同步的Connect方法。

private void ConnectToPipeServer()
{reconnectTimer.Stop();if (pipeClient != null && pipeClient.IsConnected){return;}Task.Run(() =>{try{pipeClient = new NamedPipeClientStream(".", "TestPipe", PipeDirection.In);pipeClient.Connect(10000); // 10秒超时reader = new StreamReader(pipeClient);BeginListening();}catch (Exception ex){BeginInvoke(new Action(() => MessageBox.Show($"Error connecting to pipe: {ex.Message}")));reconnectTimer.Start();}});
}

读取和处理数据

使用StreamReader读取从管道接收到的数据。我们假设数据是JSON格式的,包含进度和描述字段。

private void BeginListening()
{try{while (!reader.EndOfStream){var message = await reader.ReadLineAsync();UpdateUI(message);}}catch (Exception ex){BeginInvoke(new Action(() => MessageBox.Show($"Error reading from pipe: {ex.Message}")));reconnectTimer.Start();}
}

实现重连机制

如果连接失败,我们希望客户端能够自动重试。我们使用System.Windows.Forms.Timer来实现这一点。

控制台应用程序作为管道服务器

在另一个项目中,我们创建一个控制台应用程序来作为管道的服务器。

发送数据

服务器使用NamedPipeServerStream发送数据。我们将数据格式化为JSON字符串。

private static async Task SendMessageAsync(NamedPipeServerStream pipeStream, PipeMessage message)
{var jsonString = JsonConvert.SerializeObject(message);byte[] buffer = Encoding.UTF8.GetBytes(jsonString + "
");await pipeStream.WriteAsync(buffer, 0, buffer.Length);
}

运行和测试

启动服务器应用程序并等待客户端连接。接着,运行WinForms客户端应用程序。客户端应该能够连接到服务器,并开始接收数据。

总结

本文展示了如何在.NET Framework中使用命名管道进行IPC。通过命名管道,我们能够在独立的进程之间高效地传输数据,这对于需要快速、轻量级IPC的.NET应用程序来说是理想的选择。


http://www.ppmy.cn/news/1289229.html

相关文章

[每周一更]-(第43期):Golang版本的升级历程

从1.13接触go语言开始更新我们公司内第一个Go项目,直至现在go版本已经发展到1.20(20230428),我们从go发版开始认识go语言,有利于我们更深入 了解这门语言,洞悉一些深层方式,加深我们学习的动力&…

前端需要学GraphQL 吗?

什么是GraphQL? GraphQL 是 Facebook 开发的一个数据查询语言,可以让前端开发者更具体地指定他们需要什么数据,从而使数据获取更加高效。GraphQL 是一种数据查询和操作语言,它主要被设计用来作为 API 的请求语言。与传统的 RESTf…

python基础-01

文章目录 前言一、python中的注释二、变量的数据类型1.Number(数字)2.Boolean(布尔类型)—— True 和 False3.String(字符串)4.List(列表)5.Tuple(元组)6.Dic…

LINUX基础第六章:逻辑卷的使用、扩容和磁盘配额

目录 一.逻辑卷的使用及扩容 1、概念优点及注意事项 2.使用命令及基本格式 二.LVM实验操作 建立磁盘 建立分区 设置物理卷 设置卷组 设置逻辑卷 挂载 总结 扩展 三.扩容 扩容——vg 扩逻辑卷 同步文件系统 四.缩容 解挂载 ​编辑检测文件系统完整性 缩减文…

工程(十六)——自己数据集跑Fast_livo

一、基础环境 Ubuntu20.04 ROS noetic PCL 1.8 Eigen 3.3.4 Sophus git clone https://github.com/strasdat/Sophus.git cd Sophus git checkout a621ff mkdir build && cd build && cmake .. make sudo make install 下面两个直接把包下载下来一起编译…

PowerShell——多任务后台作业

PowerShell——多任务后台作业 实验环境:操作系统为Windows8(或之后)或者Windows Server2012(或之后)运行PowerShell v3或更新版本的计算机 任务: 创建一个后台作业获取计算机上系统事件日志中最近的26条错误记录,之后将记录导出…

Factory Method工厂模式(对象创建)

Factory Method(对象创建) 链接:工厂模式实例代码 解析 目的 在软件系统中,经常面临着创建对象的工作;由于需求的变化,需要创建的对象的具体类型经常变化。 如何应对这种变化?如何绕过常规的…

TCP_可靠数据传输原理

引言 在网络通信中,TCP是确保数据可靠传输的关键协议。但在我们深入研究TCP拥塞控制技术之前,让我们先探索可靠数据传输的原理,特别是TCP头部中一些重要字段的作用。 网络层提供了点对点的通信服务,努力交付数据报,但…

【Matlab】ELM极限学习机时序预测算法(附代码)

资源下载: https://download.csdn.net/download/vvoennvv/88681649 一,概述 ELM(Extreme Learning Machine)是一种单层前馈神经网络结构,与传统神经网络不同的是,ELM的隐层神经元权重以及偏置都是随机产生的…

Python爬虫---selenium基本使用(支持无界面浏览器PhantomJS和Chrome handless)

为什么使用selenium? 使用urllib.request.urlopen()模拟浏览器有时候获取不到数据,所以使用selenium (1) selenium是一个用于web应用程序测试的工具 (2) selenium 测试直接运行在浏览器中,就像真正的用户在操作一样 (3) 支持通过各种driver (FirfoxDri…

MySQL线上慢SQL问题分析处理小记

相同数据量表结构,线上执行12s 本地执行0.1s过程分析 1. 慢SQL信息 SELECT t1.id,t2.idFROM t_platform_target_standard_target_index t1LEFT JOIN t_platform_target_standard t2 ON t1.target_number t2.target_numberWHERE t1.delete_flag 0 AND t2.user_num …

TypeScript 的基础语法

书接上上文:关于vue3的知识点 和 上文 :TypeScript的安装与报错 我们来接着看TypeScript 的基础语法 TypeScript 语法 1. 类型注解 类型注解是 变量后面约定类型的语法,用来约定类型,明确提示 // 约定变量 age 的类型为 numbe…

【Redis-10】Redis集群的实现原理和实践

Redis集群是Redis提供的分布式数据库方案,通过分片来进行数据共享,实现复制和故障转移的功能。 1. Redis集群节点 一个Redis集群由多个节点组成,多个节点可以通过命令实现连接,由独立状态转为集群状态,命令是cluster …

SQLSERVER排查CPU占用高

操作系统是Windows2008R2 ,数据库是SQL2008R2 64位 64G内存,16核CPU 硬件配置还是比较高的,他说服务器运行的是金蝶K3软件,数据库实例里有多个数据库 现象 他说是这几天才出现的,而且在每天的某一个时间段才会出现CPU占用高的情况 内存占用不太高,只占用了30个G CPU…

Node.js+Express 路由配置,实现接口分类管理

首先创建一个路由目录及文件 routes/user.js代码 const express require(express); const router express.Router(); // 使用express提供的router对象 const db require(../dbserver/mysql);router.get(/api/user, (req, res) > {const sqlStr SELECT * FROM sys_user;…

Spark导入报错:object security is not a member of package org.apache.kafka.common

引言 build spark里自带的示例项目时报了这样一个错:object kafka is not a member of package org.apache,排查后发现是因为添加的jar依赖里没有kafka这一项,去Maven下载了对应版本的Kafka jar包后放置在examples\jars底下却仍然报错object …

PostgreSQL16.1(Windows版本)

1、卸载原有的PostgreSQL   点击Next即可。  点击OK即可。 卸载完成。 2、安装 (1) 前两部直接Next,第二部可以换成自己想要安装的路径。 (2) 直接点击Next。…

HarmonyOS资源分类与访问

资源分类与访问 应用开发过程中,经常需要用到颜色、字体、间距、图片等资源,在不同的设备或配置中,这些资源的值可能不同。 应用资源:借助资源文件能力,开发者在应用中自定义资源,自行管理这些资源在不同…

使用 Hyper-V 创建虚拟机

使用 Hyper-V 创建虚拟机 官网教程修改存储目录Hyper-V管理器创建虚拟机启动虚拟机Win10安装教程Press any key to boot from CD or DVD...... 如何使用Windows自带的虚拟机工具来创建虚拟机, 快速创建虚拟机进行学习探讨,如果有环境问题可以立即创建一个…

PyQt5-控件之QDialog(UI-业务分离搭建自定义xDialog)

1.继承QtWidgets.QWidget自定义对话框 继承于QtWidgets.QWidget自定义一个对话框类:SelectingDlg class SelectingDlg(QtWidgets.QWidget): def __init__(self): super(SelectingDlg, self).__init__() self.initUI() def initUI(self):s…