C# 实现进程间通信的几种方式(完善)
目录
引言
一、基本概念
二、常见的IPC方法
1. 管道(Pipes)
3. 消息队列(Message Queues)
4. 套接字(Sockets)
5. 信号量(Semaphores)
6. 文件映射(File Mapping)
7. 远程过程调用(RPC)
三、总结
引言
进程间通信(IPC)是指在操作系统中,不同进程之间交换数据和信息的机制。在C#中,IPC可以通过多种方式实现,包括文件共享、命名管道、套接字、消息队列、远程过程调用(RPC)等。每种方法都有其特定的应用场景和优缺点。
一、基本概念
-
进程(Process)
- 进程是操作系统中运行的程序实例。每个进程都有自己的内存空间、代码、数据和系统资源。进程之间相互独立,默认情况下无法直接访问彼此的内存空间。
-
进程间通信(IPC)
- IPC允许进程共享资源、同步操作、传递消息等,是进程协作的基础。
二、常见的IPC方法
1. 管道(Pipes)
管道是一种半双工的通信机制,可以在同一台机器上的两个进程之间传输数据。包括匿名管道和命名管道。
应用场景: 常用于本地进程间的简单通信。
技术关键点: 数据流传输,适合父子进程。
// 服务器端
using (var serverPipe = new NamedPipeServerStream("testpipe", PipeDirection.InOut))
{Console.WriteLine("Waiting for client connection...");serverPipe.WaitForConnection(); // 等待客户端连接using (var reader = new StreamReader(serverPipe))using (var writer = new StreamWriter(serverPipe)){writer.WriteLine("Hello from server"); // 向客户端发送消息writer.Flush();string message = reader.ReadLine(); // 读取客户端发送的消息Console.WriteLine("Received from client: " + message);}
}// 客户端
using (var clientPipe = new NamedPipeClientStream(".", "testpipe", PipeDirection.InOut))
{Console.WriteLine("Connecting to server...");clientPipe.Connect(); // 连接到服务器using (var reader = new StreamReader(clientPipe))using (var writer = new StreamWriter(clientPipe)){string message = reader.ReadLine(); // 读取服务器发送的消息Console.WriteLine("Received from server: " + message);writer.WriteLine("Hello from client"); // 向服务器发送消息writer.Flush();}
}
服务器端代码解释:
- 创建一个命名管道服务器。
- 等待客户端连接。
- 使用
StreamReader和StreamWriter进行数据读写。客户端代码解释:
- 创建一个命名管道客户端。
- 连接到服务器。
- 使用
StreamReader和StreamWriter进行数据读写。
2. 共享内存(Shared Memory)
共享内存允许两个或多个进程访问同一块内存区域,是最快的IPC形式。
应用场景: 高性能要求的场景。
技术关键点: 内存同步,数据一致性。
// 使用MemoryMappedFile创建共享内存
using (var mmf = MemoryMappedFile.CreateNew("MyMap", 1024))
{using (var accessor = mmf.CreateViewAccessor()){// 准备数据byte[] data = new byte[1024];// 写入数据到共享内存accessor.WriteArray(0, data, 0, data.Length);// 读取数据accessor.ReadArray(0, data, 0, data.Length);}
}
代码解释:
- 创建或打开一个共享内存对象。
- 使用视图访问器来读写内存数据。
3. 消息队列(Message Queues)
消息队列允许进程通过发送和接收消息来通信,支持异步操作。
应用场景: 分布式系统,异步消息传递。
技术关键点: 消息持久化,异步处理。
// 发送消息
using (var queue = new MessageQueue(@".\Private$\MyQueue"))
{queue.Send("Hello, World!"); // 发送一条消息到队列
}// 接收消息
using (var queue = new MessageQueue(@".\Private$\MyQueue"))
{queue.Formatter = new XmlMessageFormatter(new[] { typeof(string) });var message = queue.Receive(); // 接收消息string content = (string)message.Body; // 读取消息内容Console.WriteLine(content);
}
代码解释:
- 创建或打开一个消息队列。
- 使用
System.Messaging库发送和接收消息。
4. 套接字(Sockets)
套接字支持网络通信,可用于本地或远程进程间通信。
应用场景: 网络应用,实时通信。
技术关键点: 协议选择(TCP/UDP),数据传输稳定性。
// 服务器端
var listener = new TcpListener(IPAddress.Any, 5000);
listener.Start(); // 启动监听
Console.WriteLine("Waiting for connection...");
var client = listener.AcceptTcpClient(); // 接受客户端连接
using (var stream = client.GetStream())
using (var reader = new StreamReader(stream))
using (var writer = new StreamWriter(stream))
{writer.WriteLine("Hello from server"); // 发送消息给客户端writer.Flush();string message = reader.ReadLine(); // 读取客户端消息Console.WriteLine("Received from client: " + message);
}// 客户端
var client = new TcpClient();
client.Connect("localhost", 5000); // 连接到服务器
using (var stream = client.GetStream())
using (var reader = new StreamReader(stream))
using (var writer = new StreamWriter(stream))
{string message = reader.ReadLine(); // 读取服务器消息Console.WriteLine("Received from server: " + message);writer.WriteLine("Hello from client"); // 发送消息给服务器writer.Flush();
}
服务器端代码解释:
- 创建一个TCP监听器。
- 等待客户端连接。
- 使用
StreamReader和StreamWriter进行数据读写。客户端代码解释:
- 创建一个TCP客户端。
- 连接到服务器。
- 使用
StreamReader和StreamWriter进行数据读写。
5. 信号量(Semaphores)
用于同步多个进程对共享资源的访问。
应用场景: 并发控制,资源管理。
技术关键点: 并发访问控制,资源锁定。
// 使用Semaphore进行进程同步Semaphore semaphore = new Semaphore(initialCount: 1, maximumCount: 1, name: "MySemaphore");semaphore.WaitOne(); // 请求访问共享资源// 执行临界区中的代码semaphore.Release(); // 释放共享资源
代码解释:
- 创建或打开一个信号量对象。
- 控制对共享资源的访问。
6. 文件映射(File Mapping)
允许进程将文件内容映射到内存中,实现数据共享。
应用场景: 文件共享,数据缓存。
技术关键点: 文件访问同步,内存映射效率。
// 使用FileStream和MemoryMappedFile进行文件映射
using (FileStream fs = new FileStream("data.txt", FileMode.OpenOrCreate, FileAccess.ReadWrite))
{using (MemoryMappedFile mmf = MemoryMappedFile.CreateFromFile(fs, "MyMap", fs.Length, MemoryMappedFileAccess.ReadWrite, null, HandleInheritability.None, false)){using (var accessor = mmf.CreateViewAccessor()){accessor.Write(0, (byte)42); // 写入数据到映射文件Console.WriteLine(accessor.ReadByte(0)); // 读取数据}}
}
代码解释:
- 使用
FileStream打开一个文件。- 将文件内容映射到内存。
- 使用视图访问器来读写内存数据。
7. 远程过程调用(RPC)
允许进程调用远程函数,提供分布式计算支持。
应用场景: 分布式系统,服务调用。
技术关键点: 调用序列化,网络通信可靠性。
// 定义服务契约
[ServiceContract]
public interface IMyService
{[OperationContract]string SayHello(string name);
}// 实现服务
public class MyService : IMyService
{public string SayHello(string name){return $"Hello, {name}!";}
}// 配置和托管服务
var host = new ServiceHost(typeof(MyService), new Uri("http://localhost:8000/MyService"));
host.AddServiceEndpoint(typeof(IMyService), new BasicHttpBinding(), "");
host.Open();
Console.WriteLine("Service is running... Press [Enter] to exit.");
Console.ReadLine();
host.Close();// 客户端调用
var factory = new ChannelFactory<IMyService>(new BasicHttpBinding(), new EndpointAddress("http://localhost:8000/MyService"));
var proxy = factory.CreateChannel();
string result = proxy.SayHello("World"); // 调用远程服务
Console.WriteLine(result);
((IClientChannel)proxy).Close();
factory.Close();
服务器端实现步骤:
- 定义服务契约。
- 实现服务契约。
- 使用WCF托管服务。
客户端实现步骤:
- 创建服务契约的通道工厂。
- 调用远程方法。
三、总结
进程间通信是C#中实现不同进程之间数据交换和信息传递的重要机制。常见的IPC方法包括文件共享、命名管道、套接字、消息队列和远程过程调用。每种方法都有其特定的应用场景和优缺点。
- 文件共享: 简单易用,但性能较低,需要处理文件锁定和同步问题。
- 命名管道: 支持双向通信,适用于局域网内的进程间通信。
- 套接字: 支持跨网络通信,适用于TCP/IP或UDP协议的通信。
- 消息队列: 支持异步通信和解耦合,适用于分布式系统。
- 远程过程调用: 允许进程调用远程计算机上的函数或方法,适用于分布式应用。
通过合理选择和使用这些IPC方法,开发者可以实现高效、稳定且可扩展的进程间通信。了解每种方法的原理和应用场景,可以帮助开发者更好地设计和实现复杂的分布式系统。
相关文章:
C# 实现进程间通信的几种方式(完善)
目录 引言 一、基本概念 二、常见的IPC方法 1. 管道(Pipes) 2. 共享内存(Shared Memory) 3. 消息队列(Message Queues) 4. 套接字(Sockets) 5. 信号量(Semaphore…...
MySQL Workbench Data Import Wizard:list index out of range
MySQL Workbench的Data Import Wizard功能是用python实现的,MySQL Workbench自带了一个python,数据导入的时候出现错误提示 22:55:51 [ERR][ pymforms]: Unhandled exception in Python code: Traceback (most recent call last): File "D…...
微信支付宝小程序SEO优化的四大策略
在竞争激烈的小程序市场中,高搜索排名意味着更多的曝光机会和潜在用户。SEO即搜索引擎优化,对于小程序而言,主要指的是在微信小程序商店中提高搜索排名,从而增加曝光度和用户访问量。有助于小程序脱颖而出,提升品牌知名…...
AutoDIR: Automatic All-in-One Image Restoration with Latent Diffusion论文阅读笔记
AutoDIR: Automatic All-in-One Image Restoration with Latent Diffusion 论文阅读笔记 这是ECCV2024的论文,作者单位是是港中文和上海AI Lab 文章提出了一个叫AutoDIR的方法,包括两个关键阶段,一个是BIQA,基于vision-language…...
SQLite 数据库设计最佳实践
SQLite特点 SQLite是一款功能强大的 轻量级嵌入式数据库 ,具有以下显著特点: 体积小 :最低配置仅需几百KB内存,适用于资源受限环境。 高性能 :访问速度快,运行效率高于许多开源数据库。 高度可移植 :兼容多种硬件和软件平台。 零配置 :无需复杂设置,开箱即用。 自给自…...
【论文精读】ID-like Prompt Learning for Few-Shot Out-of-Distribution Detection
🌈 个人主页:十二月的猫-CSDN博客 🔥 系列专栏: 🏀论文精读_十二月的猫的博客-CSDN博客 💪🏻 十二月的寒冬阻挡不了春天的脚步,十二点的黑夜遮蔽不住黎明的曙光 注:下文…...
Android 10.0 根据包名禁用某个app的home事件
1.前言 在10.0的系统rom定制化开发中,在某些app中,需要禁用home事件,在普通的app中又无法 禁用home事件,所以就需要从系统中来根据包名禁用home事件了,接下来分析下 系统中处理home事件的相关流程 2.根据包名禁用某个app的home事件的核心类 frameworks/base/services/c…...
Rust 文档生成与发布
目录 第三节 文档生成与发布 1. 使用 RustDoc 生成项目文档 1.1 RustDoc 的基本使用 1.2 文档注释的格式与实践 1.3 生成文档的其他选项 1.4 在 CI/CD 中生成文档 2. 发布到 crates.io 的步骤与注意事项 2.1 创建 crates.io 账户 2.2 配置 Cargo.toml 2.3 生成发布版…...
【C++动态规划】有效括号的嵌套深度
本文涉及知识点 C动态规划 LeetCode1111. 有效括号的嵌套深度 有效括号字符串 定义:对于每个左括号,都能找到与之对应的右括号,反之亦然。详情参见题末「有效括号字符串」部分。 嵌套深度 depth 定义:即有效括号字符串嵌套的层…...
2024年优秀的天气预测API
准确、可操作的天气预报对于许多组织的成功至关重要。 事实上,在整个行业中,天气条件会直接影响日常运营,包括航运、按需、能源和供应链(仅举几例)。 以公用事业为例。根据麦肯锡的数据,在 1.4 年的时间里…...
Android和iOS有什么区别?
Android 和 iOS 有以下区别: 开发者与所属公司: Android:由谷歌公司开发以及开放手机联盟维护。它是基于 Linux 内核和其他开源软件的修改版本,代码开源程度较高,许多厂商都可以基于 Android 源代码进行深度定制和开发…...
NVR小程序接入平台/设备EasyNVR多个NVR同时管理多平台级联与上下级对接的高效应用
政务数据共享平台的建设正致力于消除“信息孤岛”现象,打破“数据烟囱”,实现国家、省、市及区县数据的全面对接与共享。省市平台的“级联对接”工作由多级平台共同构成,旨在满足跨部门、跨层级及跨省数据共享的需求,推动数据流通…...
Spring Cloud Sleuth(Micrometer Tracing +Zipkin)
分布式链路追踪 分布式链路追踪技术要解决的问题,分布式链路追踪(Distributed Tracing),就是将一次分布式请求还原成调用链路,进行日志记录,性能监控并将一次分布式请求的调用情况集中展示。比如各个服务节…...
人工智能:机遇与挑战
人工智能(AI)作为当今世界科技发展的前沿领域,正在以前所未有的速度和规模影响着我们的生活和工作方式。AI技术的应用前景广阔,从医疗健康到金融服务,从教育到交通,再到娱乐和家庭生活,AI正在逐…...
mac电脑设置crontab定时任务,以及遇到的问题解决办法
crontab常用命令 crontab -u user:用来设定某个用户的crontab服务; crontab file:file是命令文件的名字,表示将file做为crontab的任务列表文件并载入crontab。如果在命令行中没有指定这个文件,crontab命令将接受标准输入…...
Backtrader 数据篇 02
Backtrader 数据篇 本系列是使用Backtrader在量化领域的学习与实践,着重介绍Backtrader的使用。Backtrader 中几个核心组件: Cerebro:BackTrader的基石,所有的操作都是基于Cerebro的。Feed:将运行策略所需的基础数据…...
视频转场素材资源网站分享
视频剪辑者常常为找不到合适的转场素材而苦恼。合适的转场素材能让视频更流畅,给观众带来惊喜。下面就为大家介绍几个宝藏网站,提供丰富的转场剪辑素材,让你的视频瞬间高大上。 蛙学网 首先重磅推荐蛙学网,堪称视频素材界的“翘楚…...
二十二、MySQL 8.0 主从复制原理分析与实战
文章目录 一、复制(Replication)1、什么是复制2、复制的方式3、复制的数据同步类型3.1、异步复制3.2、半同步复制3.3、设计理念:复制状态机——几乎所有的分布式存储都是这么复制数据的 4、基于binlog位点同步的主从复制原理4.1、异步复制示例…...
基于OSS搭建在线教育视频课程分享网站
OSS对象存储服务是海量、安全、低成本、高持久的存储服务。适合于存储大规模非结构化数据,如图片、视频、备份文件和容器/虚拟机镜像等。 安装nginx wget https://nginx.org/download/nginx-1.20.2.tar.gz yum -y install zlib zlib-devel gcc-c pcre-devel open…...
CentOS 7 下升级 OpenSSL
升级openssh,下载:https://download.csdn.net/download/weimeilayer/89935114 上传到服务器,然后执行命令 rpm -Uvh *.rpm --nodeps --force安装依赖 yum -y install gcc perl make zlib-devel perl-CPAN下载安装包:https://github.com/ope…...
k8s从入门到放弃之Ingress七层负载
k8s从入门到放弃之Ingress七层负载 在Kubernetes(简称K8s)中,Ingress是一个API对象,它允许你定义如何从集群外部访问集群内部的服务。Ingress可以提供负载均衡、SSL终结和基于名称的虚拟主机等功能。通过Ingress,你可…...
Python:操作 Excel 折叠
💖亲爱的技术爱好者们,热烈欢迎来到 Kant2048 的博客!我是 Thomas Kant,很开心能在CSDN上与你们相遇~💖 本博客的精华专栏: 【自动化测试】 【测试经验】 【人工智能】 【Python】 Python 操作 Excel 系列 读取单元格数据按行写入设置行高和列宽自动调整行高和列宽水平…...
iPhone密码忘记了办?iPhoneUnlocker,iPhone解锁工具Aiseesoft iPhone Unlocker 高级注册版分享
平时用 iPhone 的时候,难免会碰到解锁的麻烦事。比如密码忘了、人脸识别 / 指纹识别突然不灵,或者买了二手 iPhone 却被原来的 iCloud 账号锁住,这时候就需要靠谱的解锁工具来帮忙了。Aiseesoft iPhone Unlocker 就是专门解决这些问题的软件&…...
【Zephyr 系列 10】实战项目:打造一个蓝牙传感器终端 + 网关系统(完整架构与全栈实现)
🧠关键词:Zephyr、BLE、终端、网关、广播、连接、传感器、数据采集、低功耗、系统集成 📌目标读者:希望基于 Zephyr 构建 BLE 系统架构、实现终端与网关协作、具备产品交付能力的开发者 📊篇幅字数:约 5200 字 ✨ 项目总览 在物联网实际项目中,**“终端 + 网关”**是…...
前端开发面试题总结-JavaScript篇(一)
文章目录 JavaScript高频问答一、作用域与闭包1.什么是闭包(Closure)?闭包有什么应用场景和潜在问题?2.解释 JavaScript 的作用域链(Scope Chain) 二、原型与继承3.原型链是什么?如何实现继承&a…...
蓝桥杯3498 01串的熵
问题描述 对于一个长度为 23333333的 01 串, 如果其信息熵为 11625907.5798, 且 0 出现次数比 1 少, 那么这个 01 串中 0 出现了多少次? #include<iostream> #include<cmath> using namespace std;int n 23333333;int main() {//枚举 0 出现的次数//因…...
代理篇12|深入理解 Vite中的Proxy接口代理配置
在前端开发中,常常会遇到 跨域请求接口 的情况。为了解决这个问题,Vite 和 Webpack 都提供了 proxy 代理功能,用于将本地开发请求转发到后端服务器。 什么是代理(proxy)? 代理是在开发过程中,前端项目通过开发服务器,将指定的请求“转发”到真实的后端服务器,从而绕…...
Web 架构之 CDN 加速原理与落地实践
文章目录 一、思维导图二、正文内容(一)CDN 基础概念1. 定义2. 组成部分 (二)CDN 加速原理1. 请求路由2. 内容缓存3. 内容更新 (三)CDN 落地实践1. 选择 CDN 服务商2. 配置 CDN3. 集成到 Web 架构 …...
服务器--宝塔命令
一、宝塔面板安装命令 ⚠️ 必须使用 root 用户 或 sudo 权限执行! sudo su - 1. CentOS 系统: yum install -y wget && wget -O install.sh http://download.bt.cn/install/install_6.0.sh && sh install.sh2. Ubuntu / Debian 系统…...
从面试角度回答Android中ContentProvider启动原理
Android中ContentProvider原理的面试角度解析,分为已启动和未启动两种场景: 一、ContentProvider已启动的情况 1. 核心流程 触发条件:当其他组件(如Activity、Service)通过ContentR…...
