C#多進(jìn)程通信機(jī)制詳解

C# 多進(jìn)程通信是指在一個(gè)應(yīng)用程序中，多個(gè)進(jìn)程之間需要共享數(shù)據(jù)或者協(xié)同工作。為了實(shí)現(xiàn)這種通信，我們可以使用以下幾種方法：

1. 匿名管道（Anonymous Pipe）： 匿名管道是一種半雙工的通信機(jī)制，只能在具有父子關(guān)系的進(jìn)程之間使用。匿名管道使用 System.IO.Pipes.AnonymousPipeServerStream 和 System.IO.Pipes.AnonymousPipeClientStream 類(lèi)來(lái)創(chuàng)建。

示例代碼：

// 服務(wù)器端
using (var server = new AnonymousPipeServerStream(PipeDirection.Out, HandleInheritability.Inheritable))
{
    // 創(chuàng)建客戶端
    var client = new AnonymousPipeClientStream(PipeDirection.In, server.GetClientHandleAsString());

    // 寫(xiě)入數(shù)據(jù)
    using (var writer = new StreamWriter(server))
    {
        writer.WriteLine("Hello from server!");
    }
}

// 客戶端
using (var client = new AnonymousPipeClientStream(PipeDirection.In, "client_handle"))
{
    // 讀取數(shù)據(jù)
    using (var reader = new StreamReader(client))
    {
        Console.WriteLine(reader.ReadLine());
    }
}

2. 命名管道（Named Pipe）： 命名管道是一種全雙工的通信機(jī)制，可以在任意兩個(gè)進(jìn)程之間使用。命名管道使用 System.IO.Pipes.NamedPipeServerStream 和 System.IO.Pipes.NamedPipeClientStream 類(lèi)來(lái)創(chuàng)建。

示例代碼：

// 服務(wù)器端
using (var server = new NamedPipeServerStream("my_pipe", PipeDirection.InOut))
{
    // 等待客戶端連接
    server.WaitForConnection();

    // 讀取數(shù)據(jù)
    using (var reader = new StreamReader(server))
    {
        Console.WriteLine(reader.ReadLine());
    }

    // 寫(xiě)入數(shù)據(jù)
    using (var writer = new StreamWriter(server))
    {
        writer.WriteLine("Hello from server!");
    }
}

// 客戶端
using (var client = new NamedPipeClientStream(".", "my_pipe", PipeDirection.InOut))
{
    // 連接到服務(wù)器
    client.Connect();

    // 寫(xiě)入數(shù)據(jù)
    using (var writer = new StreamWriter(client))
    {
        writer.WriteLine("Hello from client!");
    }

    // 讀取數(shù)據(jù)
    using (var reader = new StreamReader(client))
    {
        Console.WriteLine(reader.ReadLine());
    }
}

3. 共享內(nèi)存（Shared Memory）： 共享內(nèi)存是一種基于內(nèi)存的通信機(jī)制，可以在任意兩個(gè)進(jìn)程之間使用。共享內(nèi)存使用 System.IO.MemoryMappedFiles.MemoryMappedFile 類(lèi)來(lái)創(chuàng)建。

示例代碼：

// 服務(wù)器端
using (var mmf = MemoryMappedFile.CreateNew("my_shared_memory", 1024))
{
    // 寫(xiě)入數(shù)據(jù)
    using (var accessor = mmf.CreateViewAccessor())
    {
        accessor.Write(0, "Hello from server!");
    }
}

// 客戶端
using (var mmf = MemoryMappedFile.OpenExisting("my_shared_memory"))
{
    // 讀取數(shù)據(jù)
    using (var accessor = mmf.CreateViewAccessor())
    {
        string message;
        accessor.Read(0, out message);
        Console.WriteLine(message);
    }
}

4. 消息隊(duì)列（Message Queue）： 消息隊(duì)列是一種基于消息的通信機(jī)制，可以在任意兩個(gè)進(jìn)程之間使用。消息隊(duì)列使用 System.Messaging.MessageQueue 類(lèi)來(lái)創(chuàng)建。

示例代碼：

// 服務(wù)器端
using (var queue = MessageQueue.Create(".\\private$\\my_queue"))
{
    // 發(fā)送消息
    queue.Send("Hello from server!");
}

// 客戶端
using (var queue = new MessageQueue(".\\private$\\my_queue"))
{
    // 接收消息
    var message = queue.Receive();
    Console.WriteLine(message.Body);
}

5. 套接字（Socket）： 套接字是一種基于網(wǎng)絡(luò)的通信機(jī)制，可以在任意兩個(gè)進(jìn)程之間使用。套接字使用 System.Net.Sockets.Socket 類(lèi)來(lái)創(chuàng)建。

示例代碼：

// 服務(wù)器端
using (var listener = new TcpListener(IPAddress.Loopback, 8080))
{
    listener.Start();

    // 接受客戶端連接
    using (var client = listener.AcceptTcpClient())
    using (var stream = client.GetStream())
    using (var reader = new StreamReader(stream))
    {
        Console.WriteLine(reader.ReadLine());
    }
}

// 客戶端
using (var client = new TcpClient())
{
    // 連接到服務(wù)器
    client.Connect(IPAddress.Loopback, 8080);

    // 發(fā)送數(shù)據(jù)
    using (var stream = client.GetStream())
    using (var writer = new StreamWriter(stream))
    {
        writer.WriteLine("Hello from client!");
        writer.Flush();
    }
}

這些通信機(jī)制都有各自的優(yōu)缺點(diǎn)，根據(jù)實(shí)際需求選擇合適的通信方式。