淘宝网站建设教程视频,xin主题wordpress,网站可视化编辑,标书制作流程C# 两个exe通讯方式 两个应用程序通讯方式
1. 命名管道#xff08;Named Pipes#xff09;
1.1. 概述
命名管道是一种用于在同一台机器或网络中不同进程之间进行双向通信的机制。它支持同步和异步通信#xff0c;适用于需要高效数据传输的场景。
1.2. 特点
双向通信Named Pipes
1.1. 概述
命名管道是一种用于在同一台机器或网络中不同进程之间进行双向通信的机制。它支持同步和异步通信适用于需要高效数据传输的场景。
1.2. 特点
双向通信支持双向数据传输。 安全性可以设置访问权限确保通信的安全性。 跨网络支持跨网络通信。
1.3. 实现方式
1.3.1. 服务器端NamedPipeServerStream
using System;
using System.IO.Pipes;
using System.Text;
using System.Threading.Tasks;class PipeServer
{public static async Task StartServer(){using (var pipeServer new NamedPipeServerStream(TestPipe, PipeDirection.InOut, 1, PipeTransmissionMode.Byte, PipeOptions.Asynchronous)){Console.WriteLine(等待客户端连接...);await pipeServer.WaitForConnectionAsync();Console.WriteLine(客户端已连接。);// 接收数据byte[] buffer new byte[256];int bytesRead await pipeServer.ReadAsync(buffer, 0, buffer.Length);string receivedMessage Encoding.UTF8.GetString(buffer, 0, bytesRead);Console.WriteLine($收到消息{receivedMessage});// 发送回应string response Hello from server!;byte[] responseBytes Encoding.UTF8.GetBytes(response);await pipeServer.WriteAsync(responseBytes, 0, responseBytes.Length);Console.WriteLine(已发送回应。);}}static void Main(string[] args){Task.Run(() StartServer()).Wait();}
}1.3.2. 客户端NamedPipeClientStream
using System;
using System.IO.Pipes;
using System.Text;
using System.Threading.Tasks;class PipeClient
{public static async Task StartClient(){using (var pipeClient new NamedPipeClientStream(., TestPipe, PipeDirection.InOut, PipeOptions.Asynchronous)){Console.WriteLine(尝试连接到服务器...);await pipeClient.ConnectAsync();Console.WriteLine(已连接到服务器。);// 发送数据string message Hello from client!;byte[] messageBytes Encoding.UTF8.GetBytes(message);await pipeClient.WriteAsync(messageBytes, 0, messageBytes.Length);Console.WriteLine(已发送消息。);// 接收回应byte[] buffer new byte[256];int bytesRead await pipeClient.ReadAsync(buffer, 0, buffer.Length);string response Encoding.UTF8.GetString(buffer, 0, bytesRead);Console.WriteLine($收到回应{response});}}static void Main(string[] args){Task.Run(() StartClient()).Wait();}
}1.4. 使用场景
需要高效、双向通信的应用程序。 同一台机器或网络中的进程间通信。 需要传输大量数据或复杂数据结构。
2. 套接字Sockets
2.1. 概述
套接字是一种底层的通信机制支持跨网络的进程间通信。它适用于需要跨不同机器或网络通信的应用程序。
2.2. 特点
灵活性高支持多种协议TCP、UDP。 跨平台可用于不同操作系统间的通信。 高性能适用于实时数据传输和高并发应用。
2.3. 实现方式
2.3.1. 服务器端TCP
using System;
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Threading.Tasks;class SocketServer
{public static async Task StartServer(){TcpListener listener new TcpListener(IPAddress.Any, 5000);listener.Start();Console.WriteLine(服务器已启动等待连接...);using (TcpClient client await listener.AcceptTcpClientAsync()){Console.WriteLine(客户端已连接。);NetworkStream stream client.GetStream();// 接收数据byte[] buffer new byte[1024];int bytesRead await stream.ReadAsync(buffer, 0, buffer.Length);string receivedMessage Encoding.UTF8.GetString(buffer, 0, bytesRead);Console.WriteLine($收到消息{receivedMessage});// 发送回应string response Hello from server!;byte[] responseBytes Encoding.UTF8.GetBytes(response);await stream.WriteAsync(responseBytes, 0, responseBytes.Length);Console.WriteLine(已发送回应。);}listener.Stop();}static void Main(string[] args){Task.Run(() StartServer()).Wait();}
}2.3.2. 客户端TCP
using System;
using System.Net.Sockets;
using System.Text;
using System.Threading.Tasks;class SocketClient
{public static async Task StartClient(){using (TcpClient client new TcpClient()){Console.WriteLine(尝试连接到服务器...);await client.ConnectAsync(127.0.0.1, 5000);Console.WriteLine(已连接到服务器。);NetworkStream stream client.GetStream();// 发送数据string message Hello from client!;byte[] messageBytes Encoding.UTF8.GetBytes(message);await stream.WriteAsync(messageBytes, 0, messageBytes.Length);Console.WriteLine(已发送消息。);// 接收回应byte[] buffer new byte[1024];int bytesRead await stream.ReadAsync(buffer, 0, buffer.Length);string response Encoding.UTF8.GetString(buffer, 0, bytesRead);Console.WriteLine($收到回应{response});}}static void Main(string[] args){Task.Run(() StartClient()).Wait();}
}2.4. 使用场景
需要跨不同机器或网络通信的应用程序。 实时通信如聊天应用、游戏服务器等。 需要灵活控制通信协议和数据格式的场景。
3. 内存映射文件Memory-Mapped Files
3.1. 概述
内存映射文件允许多个进程共享同一块内存区域实现高效的数据交换。它适用于需要频繁、快速共享大量数据的场景。
3.2. 特点
高性能通过共享内存实现快速数据交换。 简单的数据共享适用于需要在多个进程间共享复杂数据结构的应用程序。 跨语言支持不同编程语言的进程可以通过内存映射文件进行通信。
3.3. 实现方式
3.3.1. 创建内存映射文件服务器端
using System;
using System.IO.MemoryMappedFiles;
using System.Text;
using System.Threading;class MemoryMappedFileServer
{static void Main(string[] args){using (var mmf MemoryMappedFile.CreateOrOpen(SharedMemory, 1024)){Console.WriteLine(服务器已启动等待消息...);using (var accessor mmf.CreateViewAccessor()){while (true){byte[] buffer new byte[256];accessor.ReadArray(0, buffer, 0, buffer.Length);string message Encoding.UTF8.GetString(buffer).TrimEnd(\0);if (!string.IsNullOrEmpty(message)){Console.WriteLine($收到消息{message});// 清空消息accessor.WriteArray(0, new byte[256], 0, 256);// 发送回应string response Hello from server!;byte[] responseBytes Encoding.UTF8.GetBytes(response);accessor.WriteArray(0, responseBytes, 0, responseBytes.Length);Console.WriteLine(已发送回应。);}Thread.Sleep(1000); // 等待一段时间再检查}}}}
}3.3.2. 读取内存映射文件客户端
using System;
using System.IO.MemoryMappedFiles;
using System.Text;
using System.Threading.Tasks;class MemoryMappedFileClient
{static async Task Main(string[] args){using (var mmf MemoryMappedFile.OpenExisting(SharedMemory)){using (var accessor mmf.CreateViewAccessor()){// 发送消息string message Hello from client!;byte[] messageBytes Encoding.UTF8.GetBytes(message);accessor.WriteArray(0, messageBytes, 0, messageBytes.Length);Console.WriteLine(已发送消息。);// 等待回应while (true){byte[] buffer new byte[256];accessor.ReadArray(0, buffer, 0, buffer.Length);string response Encoding.UTF8.GetString(buffer).TrimEnd(\0);if (!string.IsNullOrEmpty(response)){Console.WriteLine($收到回应{response});// 清空回应accessor.WriteArray(0, new byte[256], 0, 256);break;}await Task.Delay(500);}}}}
}3.4. 使用场景
需要在多个进程间高效共享大量数据。 实时数据交换如视频流、实时监控数据等。 复杂数据结构的共享如图像数据、结构化信息等。
4. 信号和消息Windows Messages
4.1. 概述
在 Windows 环境下进程可以通过发送和接收窗口消息来进行通信。这种方法通常用于 GUI 应用程序之间的简单通信。
4.2. 特点
适用于 GUI 应用主要用于具有窗口的应用程序之间的通信。 简单实现适合于发送简单的消息或命令。
4.3. 实现方式
4.3.1. 发送消息发送方
using System;
using System.Runtime.InteropServices;
using System.Windows.Forms;class MessageSender
{// 引入 SendMessage 函数[DllImport(user32.dll, CharSet CharSet.Auto)]public static extern IntPtr SendMessage(IntPtr hWnd, uint Msg, IntPtr wParam, IntPtr lParam);// 自定义消息public const uint WM_USER 0x0400;public const uint WM_CUSTOM WM_USER 1;static void Main(string[] args){// 获取目标窗口句柄可以通过窗口标题查找IntPtr hWnd FindWindow(null, 接收消息的窗口标题);if (hWnd ! IntPtr.Zero){string message Hello from sender!;byte[] msgBytes Encoding.UTF8.GetBytes(message);IntPtr lParam Marshal.AllocHGlobal(msgBytes.Length 1);Marshal.Copy(msgBytes, 0, lParam, msgBytes.Length);Marshal.WriteByte(lParam, msgBytes.Length, 0); // 添加 null 终止符SendMessage(hWnd, WM_CUSTOM, IntPtr.Zero, lParam);Marshal.FreeHGlobal(lParam);Console.WriteLine(已发送消息。);}else{Console.WriteLine(未找到目标窗口。);}}// 引入 FindWindow 函数[DllImport(user32.dll, SetLastError true)]public static extern IntPtr FindWindow(string lpClassName, string lpWindowName);
}4.3.2. 接收消息接收方
using System;
using System.Runtime.InteropServices;
using System.Text;
using System.Windows.Forms;class MessageReceiver : Form
{// 自定义消息public const uint WM_USER 0x0400;public const uint WM_CUSTOM WM_USER 1;// 引入 WndProcprotected override void WndProc(ref Message m){if (m.Msg WM_CUSTOM){// 获取消息内容int length 0;while (Marshal.ReadByte(m.LParam, length) ! 0) length;byte[] buffer new byte[length];Marshal.Copy(m.LParam, buffer, 0, length);string receivedMessage Encoding.UTF8.GetString(buffer);MessageBox.Show($收到消息{receivedMessage});}base.WndProc(ref m);}[STAThread]static void Main(){Application.EnableVisualStyles();Application.Run(new MessageReceiver());}
}4.4. 使用场景
简单的 GUI 应用程序之间的通信。 发送简单的命令或通知。 不需要高性能或大量数据传输的场景。
5. 内存映射数据结构Memory-Mapped Data Structures
5.1. 概述
除了简单的数据交换进程间还可以共享复杂的数据结构如对象、数组等。通过内存映射文件可以实现多个进程共享相同的内存空间进而共享数据结构。
5.2. 特点
高效数据共享适用于需要共享复杂数据结构的场景。 实时更新数据在共享内存中实时更新适用于需要实时同步数据的应用。
5.3. 实现方式
5.3.1. 共享类库
创建一个共享的类库定义数据结构并确保它们在内存映射文件中正确对齐和序列化。
5.3.2. 服务器端共享数据写入
using System;
using System.IO.MemoryMappedFiles;
using System.Runtime.InteropServices;
using System.Text;class SharedData
{[MarshalAs(UnmanagedType.ByValTStr, SizeConst 256)]public string Message;
}class MemoryMappedFileServer
{static void Main(string[] args){using (var mmf MemoryMappedFile.CreateOrOpen(SharedData, Marshal.SizeOf(typeof(SharedData)))){using (var accessor mmf.CreateViewAccessor()){SharedData data new SharedData { Message Hello from server! };accessor.Write(0, ref data);Console.WriteLine(已写入共享数据。);}Console.WriteLine(按任意键退出...);Console.ReadKey();}}
}5.3.3. 客户端共享数据读取
using System;
using System.IO.MemoryMappedFiles;
using System.Runtime.InteropServices;
using System.Text;class SharedData
{[MarshalAs(UnmanagedType.ByValTStr, SizeConst 256)]public string Message;
}class MemoryMappedFileClient
{static void Main(string[] args){using (var mmf MemoryMappedFile.OpenExisting(SharedData)){using (var accessor mmf.CreateViewAccessor()){SharedData data new SharedData();accessor.Read(0, ref data);Console.WriteLine($收到共享数据{data.Message});}}}
}5.4. 使用场景
需要共享复杂数据结构或大量数据的进程间通信。 实时数据同步如监控系统、实时数据分析等。
6. Windows Communication Foundation (WCF)
6.1. 概述
WCF 是一个用于构建服务导向应用程序的框架支持多种传输协议和消息格式。它适用于需要跨平台、跨网络通信的复杂应用程序。
6.2. 特点
多协议支持支持 HTTP, TCP, Named Pipes 等多种传输协议。 灵活性高可配置性强适用于不同的通信需求。 安全性内置多种安全机制如消息加密、身份验证等。
6.3. 实现方式
6.3.1. 定义服务契约
using System.ServiceModel;[ServiceContract]
public interface IMyService
{[OperationContract]string GetMessage(string name);
}6.3.2. 实现服务
public class MyService : IMyService
{public string GetMessage(string name){return $Hello, {name}!;}
}6.3.3. 配置服务
App.config服务器端
configurationsystem.serviceModelservicesservice nameMyServiceendpoint address bindingnetNamedPipeBinding contractIMyService /hostbaseAddressesadd baseAddressnet.pipe://localhost/MyService //baseAddresses/host/service/servicesbindingsnetNamedPipeBindingbinding nameNamedPipeBinding //netNamedPipeBinding/bindings/system.serviceModel
/configuration6.3.4. 启动服务
using System;
using System.ServiceModel;class Program
{static void Main(string[] args){using (ServiceHost host new ServiceHost(typeof(MyService))){host.Open();Console.WriteLine(服务已启动。按任意键退出...);Console.ReadKey();}}
}6.3.5. 客户端调用
using System;
using System.ServiceModel;class Program
{static void Main(string[] args){var binding new NetNamedPipeBinding();var endpoint new EndpointAddress(net.pipe://localhost/MyService);ChannelFactoryIMyService factory new ChannelFactoryIMyService(binding, endpoint);IMyService proxy factory.CreateChannel();string response proxy.GetMessage(Client);Console.WriteLine($服务器回应{response});((IClientChannel)proxy).Close();factory.Close();}
}6.4. 使用场景
需要跨网络或跨平台的复杂服务通信。 需要高级的安全性和可靠性。 构建服务导向架构Service-Oriented Architecture, SOA的应用程序。
7. 信号RSignalR
7.1. 概述
SignalR 是一个用于构建实时 Web 功能的库虽然主要用于 Web 应用但也可以用于桌面应用程序间的实时通信。
7.2. 特点
实时通信支持实时数据传输如聊天应用、实时监控等。 简化的 API提供高层次的 API简化实时通信的实现。 跨平台支持多种客户端包括 .NET、JavaScript、Java 等。
7.3. 实现方式
7.3.1. 服务器端Hub
using Microsoft.AspNetCore.SignalR;public class ChatHub : Hub
{public async Task SendMessage(string user, string message){await Clients.All.SendAsync(ReceiveMessage, user, message);}
}7.3.2. 配置服务器
Startup.cs
public class Startup
{public void ConfigureServices(IServiceCollection services){services.AddSignalR();}public void Configure(IApplicationBuilder app, IWebHostEnvironment env){app.UseRouting();app.UseEndpoints(endpoints {endpoints.MapHubChatHub(/chatHub);});}
}7.3.3. 客户端C#
using Microsoft.AspNetCore.SignalR.Client;
using System;
using System.Threading.Tasks;class Program
{static async Task Main(string[] args){var connection new HubConnectionBuilder().WithUrl(http://localhost:5000/chatHub).Build();connection.Onstring, string(ReceiveMessage, (user, message) {Console.WriteLine(${user}: {message});});await connection.StartAsync();Console.WriteLine(已连接到服务器。);while (true){string input Console.ReadLine();if (input exit) break;await connection.InvokeAsync(SendMessage, Client, input);}await connection.StopAsync();}
}7.4. 使用场景
实时数据更新如股票行情、实时监控系统。 聊天应用、多人游戏等需要即时交互的应用。 需要实时通知和推送的桌面或移动应用。
8. 共享数据库
8.1. 概述
通过使用一个共享的数据库两个进程可以通过读写数据库中的数据来实现通信。这种方法简单且可靠适用于不需要实时通信的场景。
8.2. 特点
简单实现利用现有的数据库系统无需额外的通信机制。 持久性数据持久存储适用于需要记录通信历史的应用。 跨平台支持适用于不同操作系统和编程语言的进程。
8.3. 实现方式
8.3.1. 发送方写入数据
using System;
using System.Data.SqlClient;class DatabaseSender
{static void Main(string[] args){string connectionString Serveryour_server;Databaseyour_db;User Idyour_user;Passwordyour_password;;using (SqlConnection connection new SqlConnection(connectionString)){connection.Open();string insertQuery INSERT INTO Messages (Sender, Content, Timestamp) VALUES (sender, content, timestamp);using (SqlCommand command new SqlCommand(insertQuery, connection)){command.Parameters.AddWithValue(sender, SenderProcess);command.Parameters.AddWithValue(content, Hello from sender!);command.Parameters.AddWithValue(timestamp, DateTime.Now);command.ExecuteNonQuery();Console.WriteLine(已发送消息到数据库。);}}}
}8.3.2. 接收方读取数据
using System;
using System.Data.SqlClient;class DatabaseReceiver
{static void Main(string[] args){string connectionString Serveryour_server;Databaseyour_db;User Idyour_user;Passwordyour_password;;using (SqlConnection connection new SqlConnection(connectionString)){connection.Open();string selectQuery SELECT Sender, Content, Timestamp FROM Messages ORDER BY Timestamp DESC;using (SqlCommand command new SqlCommand(selectQuery, connection)){using (SqlDataReader reader command.ExecuteReader()){while (reader.Read()){string sender reader.GetString(0);string content reader.GetString(1);DateTime timestamp reader.GetDateTime(2);Console.WriteLine(${timestamp} - {sender}: {content});}}}}}
}8.4. 使用场景
不需要实时通信但需要可靠数据交换的应用程序。 需要记录通信历史或数据持久性的场景。 多个进程或服务需要共享大量数据。
8.5. 注意事项
性能数据库通信通常比内存共享或管道通信更慢适合不频繁的数据交换。 并发控制需要处理多进程对数据库的并发访问确保数据一致性。 安全性确保数据库连接的安全性防止未经授权的访问。
9. Windows APIWindows Messages
9.1. 概述
利用 Windows API 发送和接收消息也是一种 IPC 方式特别适用于 GUI 应用程序之间的通信。
9.2. 特点
适用于 GUI 应用主要用于具有窗口句柄的应用程序。 简单实现适合发送简单命令或通知。
9.3. 实现方式
9.3.1. 发送消息发送方
using System;
using System.Runtime.InteropServices;class MessageSender
{// 引入 SendMessage 函数[DllImport(user32.dll, CharSet CharSet.Auto)]public static extern IntPtr SendMessage(IntPtr hWnd, uint Msg, IntPtr wParam, IntPtr lParam);// 自定义消息public const uint WM_USER 0x0400;public const uint WM_CUSTOM WM_USER 1;// 引入 FindWindow 函数[DllImport(user32.dll, SetLastError true)]public static extern IntPtr FindWindow(string lpClassName, string lpWindowName);static void Main(string[] args){// 获取目标窗口句柄可以通过窗口标题查找IntPtr hWnd FindWindow(null, 接收消息的窗口标题);if (hWnd ! IntPtr.Zero){string message Hello from sender!;byte[] msgBytes System.Text.Encoding.UTF8.GetBytes(message);IntPtr lParam Marshal.AllocHGlobal(msgBytes.Length 1);Marshal.Copy(msgBytes, 0, lParam, msgBytes.Length);Marshal.WriteByte(lParam, msgBytes.Length, 0); // 添加 null 终止符SendMessage(hWnd, WM_CUSTOM, IntPtr.Zero, lParam);Marshal.FreeHGlobal(lParam);Console.WriteLine(已发送消息。);}else{Console.WriteLine(未找到目标窗口。);}}
}9.3.2. 接收消息接收方
using System;
using System.Runtime.InteropServices;
using System.Text;
using System.Windows.Forms;class MessageReceiver : Form
{// 自定义消息public const uint WM_USER 0x0400;public const uint WM_CUSTOM WM_USER 1;// 重写 WndProc 方法以处理自定义消息protected override void WndProc(ref Message m){if (m.Msg WM_CUSTOM){// 获取消息内容int length 0;while (Marshal.ReadByte(m.LParam, length) ! 0) length;byte[] buffer new byte[length];Marshal.Copy(m.LParam, buffer, 0, length);string receivedMessage Encoding.UTF8.GetString(buffer);MessageBox.Show($收到消息{receivedMessage});}base.WndProc(ref m);}[STAThread]static void Main(){Application.EnableVisualStyles();Application.Run(new MessageReceiver());}
}9.4. 使用场景
简单的 GUI 应用程序之间的通信。 发送简单的命令或通知。 不需要高性能或大量数据传输的场景。
9.5. 注意事项
窗口句柄需要获取目标窗口的句柄Handle可以通过窗口标题或类名查找。 消息格式确保发送方和接收方对消息格式有一致的约定。 安全性避免发送恶意消息确保消息的合法性。
10. 其他 IPC 方法
10.1. COMComponent Object Model
概述COM 是微软的一种组件软件架构用于不同进程或不同编程语言间的对象通信。 特点跨语言、跨进程、支持对象导向。 使用场景需要复杂对象交互和跨语言支持的场景。 缺点配置复杂学习曲线陡峭。
10.2. 共享数据库
概述通过共享数据库如 SQL Server, SQLite, MySQL进行数据交换。 特点数据持久化、易于管理、跨平台。 使用场景不需要实时通信但需要可靠数据交换的场景。 缺点性能较低不适合高频率数据交换。
10.3. 文件系统
概述通过在文件系统中读写文件来实现通信。 特点实现简单、无需特殊配置。 使用场景简单的数据交换如配置文件、日志记录等。 缺点不适合实时通信性能较低易受文件锁定影响。
11. 性能和安全性考虑
11.1. 性能优化
选择合适的 IPC 方法根据通信需求数据量、实时性、跨网络等选择最合适的 IPC 方法。 减少数据传输量只传输必要的数据避免冗余传输。 使用高效的数据格式如二进制格式代替文本格式减少解析开销。 并发处理利用异步编程和并发机制提升数据处理效率。
11.2. 安全性
身份验证确保只有授权的进程可以进行通信。 数据加密在传输敏感数据时使用加密机制保护数据安全。 访问控制设置严格的访问权限防止未授权的访问和操作。 防止注入攻击验证和清理接收到的数据防止恶意代码注入。
12. 总结
C# 提供了多种进程间通信IPC方法涵盖了从简单的数据交换到复杂的实时通信需求。选择合适的 IPC 方法需要根据具体的应用场景、性能需求和安全要求来决定。以下是常见 IPC 方法的简要对比
IPC 方法优点缺点适用场景命名管道高效、支持双向通信、可跨网络仅限于同一台机器或局域网高效数据传输、双向通信套接字Sockets灵活、支持多协议、跨平台实现复杂、需要处理网络延迟和安全性跨网络通信、实时应用如聊天和游戏内存映射文件高性能、适合共享大量数据需要处理内存管理和同步问题实时数据共享、大量数据交换信号和消息简单、适用于 GUI 应用仅适用于具有窗口句柄的应用有限的数据传输能力简单命令或通知的 GUI 应用通信WCF多协议支持、高度可配置、安全性强配置复杂、学习曲线陡峭复杂服务通信、跨平台和跨语言应用SignalR实时通信、简化的 API、跨平台主要用于 Web 应用桌面应用需要额外配置实时数据更新、聊天应用、实时监控系统共享数据库数据持久化、易于管理、跨平台性能较低、不适合高频率实时通信可靠的数据交换、需要记录通信历史的场景文件系统实现简单、无需特殊配置不适合实时通信、性能低、易受文件锁定影响简单的数据交换、配置文件和日志记录COM跨语言、支持复杂对象交互配置复杂、学习曲线陡峭需要复杂对象交互和跨语言支持的场景
