C# RabbitMQ RPC直接回复 示例

在C#中，RabbitMQ通常用于消息队列通信，而不是RPC（Remote Procedure Call，远程过程调用）。然而，如果你想在RabbitMQ中实现类似RPC的功能，一种方法是结合AMQP协议和序列化库（如MessagePack或Json.NET）来封装请求-响应模型。

以下是一个简单的示例，展示了如何使用RabbitMQ和NServiceBus（一个基于RabbitMQ的消息传递框架）来实现实现RPC：

using NServiceBus;
using Newtonsoft.Json;

// 定义一个接口作为服务
public interface IRpcService
{
    string Add(int a, int b);
}

// 实现接口
[EndpointName("RpcService")]
public class RpcServiceImpl : IRpcService
{
    public string Add(int a, int b)
    {
        return $"The sum is {a + b}";
    }
}

// 在发送端（客户端）
class Client
{
    private IBus bus;

    public Client()
    {
        bus = Bus.Create();
    }

    public async Task<string> CallAddAsync(int a, int b)
    {
        var request = new
        {
            Method = "Add",
            Args = new[] { a, b }
        };
        
        // 序列化成JSON
        var jsonRequest = JsonConvert.SerializeObject(request);

        await bus.SendLocal(new RpcRequest
        {
            Destination = "RpcService", // 服务器端接口名称
            Body = jsonRequest
        });

        // 接收并反序列化响应
        var response = await bus.Receive<RpcResponse>();
        return JsonConvert.DeserializeObject<RpcResponse>(response.Body).Result;
    }
}

// 定义一个接收消息并处理的类（服务器端）
public class RpcRequestHandler : IHandleMessages<RpcRequest>
{
    public void Handle(RpcRequest message)
    {
        // 反序列化请求
        var request = JsonConvert.DeserializeObject<Dictionary<string, object>>(message.Body);

        // 获取服务对象并执行方法
        var service = container.Resolve<IRpcService>();
        var result = service.Add((int)request["Args"], (int)request["Args"]);

        // 序列化结果为响应
        var response = new RpcResponse { Result = result };

        // 发送响应回客户端
        bus.SendLocally(response);
    }
}

// 配置NServiceBus
public class EndpointConfig : IConfigureThisEndpoint, AsA_Server
{
    public void Customize(BusConfiguration configuration)
    {
        configuration.UseJsonSerializer();
        configuration.UseTransport<RabbitMQTransport>()
                   .ConnectionString(() => Configuration.Settings.RabbitMQ.ConnectionString);
    }
}

在这个例子中，`Client`通过序列化的JSON向`RpcService`发送请求，`RpcRequestHandler`负责接收到请求后调用相应的方法并返回结果。这个架构并非真正的RPC，因为消息在发送者和接受者之间是异步的，并不是直接从一个进程到另一个进程。