static void Main(string[] args) { var factory = new ConnectionFactory() { HostName = "localhost", VirtualHost = "frexport" };
using (var connection = factory.CreateConnection()) { using (var channel = connection.CreateModel()) { //指定交换机以及交换机模式 channel.ExchangeDeclare(exchange: ExchangeName, type: ExchangeType.Direct, durable: true);
var severity = (args.Length > 0) ? args[0] : "info"; var message = (args.Length > 1) ? args[1] : "HelloWorld!";
var body = System.Text.Encoding.UTF8.GetBytes(message); channel.BasicPublish(exchange: ExchangeName, routingKey:severity, basicProperties:null, body:body);
Console.WriteLine(" [x] Sent '{0}':'{1}'", severity, message);
} }
Console.WriteLine(" Press [enter] to exit."); Console.ReadLine(); } } }
var consumer = new EventingBasicConsumer(channel); consumer.Received += (sender, ea) => { var body = ea.Body; var message = Encoding.UTF8.GetString(body); var routingKey = ea.RoutingKey; Console.WriteLine(" [x] Received '{0}':'{1}'", routingKey, message); };