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