c# linux开发如何处理进程间通信 - 问答

在C#中，处理Linux进程间通信（IPC）的方法与在Windows中有所不同

使用套接字（Sockets）：套接字是一种通用的IPC机制，可以在本地或通过网络进行通信。在C#中，你可以使用System.Net.Sockets.TcpClient和System.Net.Sockets.NetworkStream类来创建TCP套接字。对于UDP通信，可以使用System.Net.Sockets.UdpClient类。

using System;
using System.Net.Sockets;
using System.Text;
using System.Threading.Tasks;

class TcpClientExample
{
    static async Task Main(string[] args)
    {
        using (TcpClient client = new TcpClient("localhost", 8080))
        {
            using (NetworkStream stream = client.GetStream())
            {
                string message = "Hello, Server!";
                byte[] data = Encoding.ASCII.GetBytes(message);
                await stream.WriteAsync(data, 0, data.Length);

                byte[] buffer = new byte[1024];
                int bytesRead = await stream.ReadAsync(buffer, 0, buffer.Length);
                string response = Encoding.ASCII.GetString(buffer, 0, bytesRead);
                Console.WriteLine("Server response: " + response);
            }
        }
    }
}

使用命名管道（Named Pipes）：命名管道是一种在同一台计算机上的进程间进行通信的高效方式。在C#中，你可以使用System.IO.Pipes类来创建和使用命名管道。

using System;
using System.IO.Pipes;
using System.Text;
using System.Threading.Tasks;

class NamedPipeExample
{
    static async Task Main(string[] args)
    {
        using (NamedPipeClientStream client = new NamedPipeClientStream(".", "TestPipe", PipeDirection.InOut))
        {
            await client.ConnectAsync();

            string message = "Hello, Server!";
            byte[] data = Encoding.ASCII.GetBytes(message);
            await client.WriteAsync(data, 0, data.Length);

            byte[] buffer = new byte[1024];
            int bytesRead = await client.ReadAsync(buffer, 0, buffer.Length);
            string response = Encoding.ASCII.GetString(buffer, 0, bytesRead);
            Console.WriteLine("Server response: " + response);
        }
    }
}

使用消息队列（Message Queues）：消息队列是一种进程间通信方法，允许进程将消息发送到队列中，其他进程可以从队列中接收消息。在Linux中，你可以使用RabbitMQ、Apache Kafka等消息队列系统。在C#中，你可以使用RabbitMQ.Client库来与RabbitMQ进行交互。

using System;
using System.Text;
using RabbitMQ.Client;
using RabbitMQ.Client.Events;

class RabbitMQExample
{
    static async Task Main(string[] args)
    {
        var factory = new ConnectionFactory() { HostName = "localhost" };
        using (var connection = factory.CreateConnection())
        using (var channel = connection.CreateModel())
        {
            channel.QueueDeclare(queue: "hello", durable: false, exclusive: false, autoDelete: false, arguments: null);

            string message = "Hello, Server!";
            var body = Encoding.UTF8.GetBytes(message);

            channel.BasicPublish(exchange: "", routingKey: "hello", basicProperties: null, body: body);
            Console.WriteLine(" [x] Sent '" + message + "'");
        }
    }
}

使用共享内存（Shared Memory）：共享内存是一种高效的进程间通信方法，允许多个进程访问同一块内存区域。在Linux中，你可以使用System V共享内存或POSIX共享内存。在C#中，你可以使用System.IO.MemoryMappedFiles类来创建和使用共享内存。

这些是在C#中进行Linux进程间通信的一些方法。你可以根据你的需求和场景选择合适的方法。

0 赞

0 踩