echo/rabbitmq-tutorials
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Rewrite .NET RPC Server to use EventingBasicConsumer

Browse Source
This commit is contained in:
Oleg Shevchenko 2016-02-11 17:10:29 +03:00
parent 5f4af53774
commit 2049e4c286
2 changed files with 20 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
dotnet-visual-studio/6_RPCServer/Program.cs
View File

@ -8,19 +8,18 @@ class Program
public static void Main() public static void Main()
{ {
var factory = new ConnectionFactory() { HostName = "localhost" }; var factory = new ConnectionFactory() { HostName = "localhost" };
using(var connection = factory.CreateConnection()) using (var connection = factory.CreateConnection())
using(var channel = connection.CreateModel()) using (var channel = connection.CreateModel())
{ {
channel.QueueDeclare(queue: "rpc_queue", durable: false, exclusive: false, autoDelete: false, arguments: null); channel.QueueDeclare(queue: "rpc_queue", durable: false, exclusive: false, autoDelete: false, arguments: null);
channel.BasicQos(0, 1, false); channel.BasicQos(0, 1, false);
var consumer = new QueueingBasicConsumer(channel); var consumer = new EventingBasicConsumer(channel);
channel.BasicConsume(queue: "rpc_queue", noAck: false, consumer: consumer); channel.BasicConsume(queue: "rpc_queue", noAck: false, consumer: consumer);
Console.WriteLine(" [x] Awaiting RPC requests"); Console.WriteLine(" [x] Awaiting RPC requests");
while(true) consumer.Received += (model, ea) =>
{ {
string response = null; string response = null;
var ea = (BasicDeliverEventArgs)consumer.Queue.Dequeue();
var body = ea.Body; var body = ea.Body;
var props = ea.BasicProperties; var props = ea.BasicProperties;
@ -34,7 +33,7 @@ class Program
Console.WriteLine(" [.] fib({0})", message); Console.WriteLine(" [.] fib({0})", message);
response = fib(n).ToString(); response = fib(n).ToString();
} }
catch(Exception e) catch (Exception e)
{ {
Console.WriteLine(" [.] " + e.Message); Console.WriteLine(" [.] " + e.Message);
response = ""; response = "";
@ -45,7 +44,10 @@ class Program
channel.BasicPublish(exchange: "", routingKey: props.ReplyTo, basicProperties: replyProps, body: responseBytes); channel.BasicPublish(exchange: "", routingKey: props.ReplyTo, basicProperties: replyProps, body: responseBytes);
channel.BasicAck(deliveryTag: ea.DeliveryTag, multiple: false); channel.BasicAck(deliveryTag: ea.DeliveryTag, multiple: false);
} }
} };
Console.WriteLine(" Press [enter] to exit.");
Console.ReadLine();
} }
} }
@ -55,7 +57,7 @@ class Program
/// </summary> /// </summary>
private static int fib(int n) private static int fib(int n)
{ {
if(n == 0 || n == 1) if (n == 0 || n == 1)
{ {
return n; return n;
} }

18
dotnet/RPCServer.cs
View File

@ -8,19 +8,18 @@ class RPCServer
public static void Main() public static void Main()
{ {
var factory = new ConnectionFactory() { HostName = "localhost" }; var factory = new ConnectionFactory() { HostName = "localhost" };
using(var connection = factory.CreateConnection()) using (var connection = factory.CreateConnection())
using(var channel = connection.CreateModel()) using (var channel = connection.CreateModel())
{ {
channel.QueueDeclare(queue: "rpc_queue", durable: false, exclusive: false, autoDelete: false, arguments: null); channel.QueueDeclare(queue: "rpc_queue", durable: false, exclusive: false, autoDelete: false, arguments: null);
channel.BasicQos(0, 1, false); channel.BasicQos(0, 1, false);
var consumer = new QueueingBasicConsumer(channel); var consumer = new EventingBasicConsumer(channel);
channel.BasicConsume(queue: "rpc_queue", noAck: false, consumer: consumer); channel.BasicConsume(queue: "rpc_queue", noAck: false, consumer: consumer);
Console.WriteLine(" [x] Awaiting RPC requests"); Console.WriteLine(" [x] Awaiting RPC requests");
while(true) consumer.Received += (model, ea) =>
{ {
string response = null; string response = null;
var ea = (BasicDeliverEventArgs)consumer.Queue.Dequeue();
var body = ea.Body; var body = ea.Body;
var props = ea.BasicProperties; var props = ea.BasicProperties;
@ -34,7 +33,7 @@ public static void Main()
Console.WriteLine(" [.] fib({0})", message); Console.WriteLine(" [.] fib({0})", message);
response = fib(n).ToString(); response = fib(n).ToString();
} }
catch(Exception e) catch (Exception e)
{ {
Console.WriteLine(" [.] " + e.Message); Console.WriteLine(" [.] " + e.Message);
response = ""; response = "";
@ -45,7 +44,10 @@ public static void Main()
channel.BasicPublish(exchange: "", routingKey: props.ReplyTo, basicProperties: replyProps, body: responseBytes); channel.BasicPublish(exchange: "", routingKey: props.ReplyTo, basicProperties: replyProps, body: responseBytes);
channel.BasicAck(deliveryTag: ea.DeliveryTag, multiple: false); channel.BasicAck(deliveryTag: ea.DeliveryTag, multiple: false);
} }
} };
Console.WriteLine(" Press [enter] to exit.");
Console.ReadLine();
} }
} }
@ -55,7 +57,7 @@ public static void Main()
/// </summary> /// </summary>
private static int fib(int n) private static int fib(int n)
{ {
if(n == 0 || n == 1) if (n == 0 || n == 1)
{ {
return n; return n;
} }