class Program{static void Main(string[] args){var factory = new ConnectionFactory() { HostName = "localhost", VirtualHost = "OrderQueue", UserName = "zhangweizhong", Password = "weizhong1988", Port = 5672 };using (var connection = factory.CreateConnection())using (var channel = connection.CreateModel()){channel.QueueDeclare(queue: "rpc_queue",durable: false,exclusive: false,autoDelete: false,arguments: null);channel.BasicQos(0, 1, false);var consumer = new QueueingBasicConsumer(channel);channel.BasicConsume(queue: "rpc_queue",noAck: false,consumer: consumer);Console.WriteLine(" [x] Awaiting RPC requests");while (true){string response = null;var ea = (BasicDeliverEventArgs)consumer.Queue.Dequeue();var body = ea.Body;var props = ea.BasicProperties;var replyProps = channel.CreateBasicProperties();replyProps.CorrelationId = props.CorrelationId;try{var message = Encoding.UTF8.GetString(body);int n = int.Parse(message);Console.WriteLine(" [.] fib({0})", message);response = fib(n).ToString();}catch (Exception e){Console.WriteLine(" [.] " + e.Message);response = "";}finally{var responseBytes = Encoding.UTF8.GetBytes(response);channel.BasicPublish(exchange: "",routingKey: props.ReplyTo,basicProperties: replyProps,body: responseBytes);channel.BasicAck(deliveryTag: ea.DeliveryTag,multiple: false);}}}}/// <summary>/// Assumes only valid positive integer input./// Don't expect this one to work for big numbers,/// and it's probably the slowest recursive implementation possible./// </summary>private static int fib(int n){if (n == 0 || n == 1){return n;}Thread.Sleep(1000 * 10);return n;}}

    class Program{static void Main(string[] args){for (int i = 0; i < 10; i++){Stopwatch watch = new Stopwatch();watch.Start();var rpcClient = new RPCClient();Console.WriteLine(string.Format(" [x] Requesting fib({0})", i));var response = rpcClient.Call(i.ToString());Console.WriteLine(" [.] Got '{0}'", response);rpcClient.Close();watch.Stop();Console.WriteLine(string.Format(" [x] Requesting complete {0} ,cost {1} ms", i, watch.Elapsed.TotalMilliseconds));}Console.WriteLine(" complete!!!! ");Console.ReadLine();}}class RPCClient{private IConnection connection;private IModel channel;private string replyQueueName;private QueueingBasicConsumer consumer;public RPCClient(){var factory = new ConnectionFactory() { HostName = "localhost", VirtualHost = "OrderQueue", UserName = "zhangweizhong", Password = "weizhong1988", Port = 5672 };connection = factory.CreateConnection();channel = connection.CreateModel();replyQueueName = channel.QueueDeclare().QueueName;consumer = new QueueingBasicConsumer(channel);channel.BasicConsume(queue: replyQueueName,noAck: true,consumer: consumer);}public string Call(string message){var corrId = Guid.NewGuid().ToString();var props = channel.CreateBasicProperties();props.ReplyTo = replyQueueName;props.CorrelationId = corrId;var messageBytes = Encoding.UTF8.GetBytes(message);channel.BasicPublish(exchange: "",routingKey: "rpc_queue",basicProperties: props,body: messageBytes);while (true){var ea = (BasicDeliverEventArgs)consumer.Queue.Dequeue();if (ea.BasicProperties.CorrelationId == corrId){return Encoding.UTF8.GetString(ea.Body);}}}public void Close(){connection.Close();}}

作者：章为忠 
出处：http://www.fpeach.com/ 
本文版权归作者所有，欢迎转载，但未经作者同意必须保留此段声明，且在文章页面明显位置给出原文连接。如有问题，可以微信：18618243664 联系我，非常感谢。

扫下面的二维码关注我的微信公众号。