DotNet開發中實現多進程之間通信的幾種方式
作者：小乖獸技術
.Net開發中常用的多進程通信方式，每種方式都有其適用場景和注意事項。需要根據具體需求進行選擇和設計。
在.Net開發中，通常可以使用以下幾種方式實現多進程之間的通信：
1. 內存映射文件（Memory-mapped Files）：內存映射文件允許不同進程共享同一段物理內存。當一個進程將數據寫入內存映射文件時，其他進程可以通過讀取該內存映射文件來訪問這些數據。
// 創建內存映射文件
using var mmf = MemoryMappedFile.CreateNew("TestMap", 10000);
// 獲取內存映射文件中的視圖
using var view = mmf.CreateViewAccessor();
// 向內存映射文件寫入數據
byte[] buffer = ...
view.WriteArray(0, buffer, 0, buffer.Length);
// 從內存映射文件中讀取數據
byte[] readBuffer = new byte[buffer.Length];
view.ReadArray(0, readBuffer, 0, readBuffer.Length);2. 命名管道（Named Pipes）：命名管道是一種單向或雙向通信機制，可以在多個進程間進行通信。一個進程將數據寫入其中一個命名管道，而另一個進程則從該管道中讀取數據。
// 創建服務器端命名管道
var pipeServer = new NamedPipeServerStream("TestPipe");
// 等待客戶端連接
pipeServer.WaitForConnection();
// 向管道中寫入消息
byte[] buffer = ...
pipeServer.Write(buffer, 0, buffer.Length);
// 關閉管道
pipeServer.Close();
// 創建客戶端命名管道
var pipeClient = new NamedPipeClientStream("TestPipe");
// 連接服務器端管道
pipeClient.Connect();
// 從管道中讀取消息
byte[] readBuffer = new byte[buffer.Length];
pipeClient.Read(readBuffer, 0, readBuffer.Length);
// 關閉管道
pipeClient.Close();3. 遠程過程調用（Remote Procedure Call, RPC）：遠程過程調用是一種通過網絡通信實現進程間通信的方法。它允許一個進程調用另一個進程（通常是運行在遠程計算機上）中的函數，并返回結果。
// 創建RPC服務主機
var host = new ServiceHost(typeof(MyService));
host.Open();
// 創建RPC客戶端代理（需要引用服務契約）
var client = new MyServiceClient();
// 調用遠程方法
var result = client.MyMethod("參數");
// 關閉RPC客戶端代理
client.Close();
// 關閉RPC服務主機
host.Close();4. Windows消息隊列：Windows消息隊列是一種通過操作系統提供的通信機制實現進程間通信的方式。它基于Windows消息機制，可用于在多個進程之間傳遞消息。
// 創建消息隊列
var queue = MessageQueue.Create(@".\Private$\MyQueue");
// 發送消息
var message = new Message
{
Body = "消息內容"
};
queue.Send(message);
// 接收消息
var message = queue.Receive();
string body = (string)message.Body;
// 刪除消息
queue.ReceiveById(message.Id);
// 刪除消息隊列
MessageQueue.Delete(@".\Private$\MyQueue");5. .NET Remoting：.NET Remoting 是一種在相互協作的對象之間提供遠程對象調用服務的機制，可以用于在多個進程之間進行通信。
// 創建遠程對象
var obj = new MyRemoteObject();
// 啟動遠程對象服務
var channel = new TcpChannel(12345);
ChannelServices.RegisterChannel(channel, false);
RemotingServices.Marshal(obj, "MyRemoteObject");
// 創建遠程對象代理
var proxy = (MyRemoteObject)Activator.GetObject(
typeof(MyRemoteObject), "tcp://localhost:12345/MyRemoteObject");
// 調用遠程方法
var result = proxy.MyMethod("參數");
// 關閉遠程對象代理
RemotingServices.Disconnect(proxy);
// 停止遠程對象服務
ChannelServices.UnregisterChannel(channel);6. Socket：使用TCP或UDP協議進行通信，需要處理網絡編程相關問題。
// 服務器端
var listener = new TcpListener(IPAddress.Loopback, 12345);
listener.Start();
while (true)
{
var client = listener.AcceptTcpClient();
using var networkStream = client.GetStream();
// 處理網絡流中的數據
}
// 客戶端
var client = new TcpClient();
client.Connect(IPAddress.Loopback, 12345);
using var networkStream = client.GetStream();
// 向服務端發送數據
byte[] buffer = ...
networkStream.Write(buffer, 0, buffer.Length);
// 從服務端接收數據
byte[] readBuffer = new byte[buffer.Length];
networkStream.Read(readBuffer, 0, readBuffer.Length);
client.Close();7. PipeStream：使用命名管道或匿名管道進行通信，與Named Pipes類似。
// 服務器端
var serverPipe = new NamedPipeServerStream("MyPipe", PipeDirection.InOut);
serverPipe.WaitForConnection();
// 讀取客戶端發來的消息
using var streamReader = new StreamReader(serverPipe);
var message = streamReader.ReadToEnd();
// 發送響應消息到客戶端
using var streamWriter = new StreamWriter(serverPipe);
streamWriter.WriteLine("響應消息");
streamWriter.Flush();
// 客戶端
var clientPipe = new NamedPipeClientStream(".", "MyPipe", PipeDirection.InOut);
clientPipe.Connect();
// 向服務器發送消息
using var streamWriter = new StreamWriter(clientPipe);
streamWriter.WriteLine("請求消息");
streamWriter.Flush();
// 讀取服務器返回的響應消息
using var streamReader = new StreamReader(clientPipe);
var response = streamReader.ReadLine();8. Shared Memory：使用共享內存進行通信，與Memory-mapped Files類似。
// 創建MemoryMappedFile
var memoryMappedFile = MemoryMappedFile.CreateNew(
"MySharedMemory", 4096, MemoryMappedFileAccess.ReadWrite);
// 獲取共享內存視圖
var memoryMappedViewAccessor = memoryMappedFile.CreateViewAccessor();
// 在共享內存中寫入數據
byte[] buffer = ...
memoryMappedViewAccessor.WriteArray(0, buffer, 0, buffer.Length);
// 讀取共享內存中的數據
byte[] readBuffer = new byte[buffer.Length];
memoryMappedViewAccessor.ReadArray(0, readBuffer, 0, readBuffer.Length);9. MSMQ（Microsoft Message Queue）：使用消息隊列進行通信，相較于Windows消息隊列更加高級，支持分布式事務和異步發送等特性。
// 創建消息隊列
var messageQueue = new MessageQueue(@".\Private$\MyQueue")
{
Formatter = new XmlMessageFormatter(new[] { typeof(string) })
};
// 發送消息
messageQueue.Send("請求消息");
// 接收消息
var message = messageQueue.Receive();
string body = (string)message.Body;
// 刪除消息
messageQueue.ReceiveById(message.Id);
// 刪除消息隊列
MessageQueue.Delete(@".\Private$\MyQueue");10. MQTT（Message Queuing Telemetry Transport）：一種輕量級的、基于發布/訂閱模型的消息協議，通常用于物聯網和移動應用場景。
// 創建MQTT客戶端
var client = new MqttClient(IPAddress.Loopback);
// 連接MQTT服務器
client.Connect("MyClient");
// 訂閱主題并接收消息
client.Subscribe(new[] { "topic/mytopic" }, new[] { MqttMsgBase.QOS_LEVEL_EXACTLY_ONCE });
client.MqttMsgPublishReceived += (s, e) =>
{
var message = Encoding.UTF8.GetString(e.Message);
};
// 發布消息
var payload = Encoding.UTF8.GetBytes("消息內容");
client.Publish("topic/mytopic", payload);以上就是.Net開發中常用的多進程通信方式，每種方式都有其適用場景和注意事項。需要根據具體需求進行選擇和設計。
責任編輯：姜華
來源：
今日頭條
