消息推送系统

using System;

using RabbitMQ.Client;

using RabbitMQ.Client.Events;

namespace MessageCenterExample

{

class Program

{

static void Main(string[] args)

{

var factory = new ConnectionFactory() { HostName = "localhost" };

using (var connection = factory.CreateConnection())

using (var channel = connection.CreateModel())

{

// 声明队列

channel.QueueDeclare(queue: "test_queue", durable: false, exclusive: false, autoDelete: false, arguments: null);

// 发送消息

string message = "Hello World!";

var body = System.Text.Encoding.UTF8.GetBytes(message);

channel.BasicPublish(exchange: "", routingKey: "test_queue", basicProperties: null, body: body);

Console.WriteLine(" [x] Sent {0}", message);

// 接收消息

数字迎新管理系统

var consumer = new EventingBasicConsumer(channel);

consumer.Received += (model, ea) =>

{

var bodyReceived = ea.Body.ToArray();

var messageReceived = System.Text.Encoding.UTF8.GetString(bodyReceived);

Console.WriteLine(" [x] Received {0}", messageReceived);

};

channel.BasicConsume(queue: "test_queue", autoAck: true, consumer: consumer);

Console.WriteLine(" Press [enter] to exit.");

Console.ReadLine();

}

}

}

}