//创建返回一个新的频道using (var channel = RabbitMqHelper.GetConnection().CreateModel()){//创建一个rpc queuechannel.QueueDeclare("RpcQueue", true, false, false, null);SimpleRpcServer rpc = new SmsSimpleRpcServer(new Subscription(channel, "RpcQueue"));Console.WriteLine("服务端启动成功");

   rpc.MainLoop();

                Console.ReadKey();}

/// <summary>/// 发送短信的Rpc/// </summary>public class SmsSimpleRpcServer : SimpleRpcServer{public SmsSimpleRpcServer(Subscription subscription) : base(subscription){}/// <summary>/// 执行完成后进行h回调/// </summary>/// <param name="isRedelivered"></param>/// <param name="requestProperties"></param>/// <param name="body"></param>/// <param name="replyProperties"></param>/// <returns></returns>public override byte[] HandleSimpleCall(bool isRedelivered, IBasicProperties requestProperties, byte[] body, out IBasicProperties replyProperties){replyProperties = null;return Encoding.UTF8.GetBytes($"给{Encoding.UTF8.GetString(body)}发送短信成功");}/// <summary>/// 进行处理/// </summary>/// <param name="evt"></param>public override void ProcessRequest(BasicDeliverEventArgs evt){// todo.....base.ProcessRequest(evt);}}

using (var channel = RabbitMqHelper.GetConnection().CreateModel()){//创建client的rpcSimpleRpcClient client = new SimpleRpcClient(channel, new PublicationAddress(exchangeType: ExchangeType.Direct, exchangeName: string.Empty, routingKey: "RpcQueue"));bool flag = true;var sendmsg = "";while (flag){Console.WriteLine("请输入要发送的消息");sendmsg = Console.ReadLine();if (string.IsNullOrWhiteSpace(sendmsg)){Console.Write("请输入消息");continue;}var msg = client.Call(Encoding.UTF8.GetBytes(sendmsg));Console.WriteLine(Encoding.UTF8.GetString(msg));}Console.ReadKey();}