统一消息系统

using System;

using System.Threading.Tasks;

using Microsoft.Extensions.DependencyInjection;

using RabbitMQ.Client;

namespace MessagePlatform

{

public class MessageProducer

{

private readonly IConnection _connection;

public MessageProducer()

{

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

免费排课系统

_connection = factory.CreateConnection();

}

public async Task SendMessageAsync(string queueName, string message)

{

using (var channel = _connection.CreateModel())

{

channel.QueueDeclare(queue: queueName,

durable: false,

exclusive: false,

autoDelete: false,

arguments: null);

byte[] body = System.Text.Encoding.UTF8.GetBytes(message);

await Task.Run(() => channel.BasicPublish(exchange: "",

routingKey: queueName,

basicProperties: null,

body: body));

}

}

}

}