RabbitMQ 生产者

原文连接：https://www.cnblogs.com/ysmc/p/16225118.html

项目需要引用 RabbitMQ.Client Nuget包

生产消息

IAsyncConnectionFactory connectionFactory = new ConnectionFactory
{
HostName = _rabbitMqOptions.HostName,
Port = _rabbitMqOptions.Port,
UserName = _rabbitMqOptions.UserName,
Password = _rabbitMqOptions.Password,
VirtualHost = _rabbitMqOptions.VirtualHost,
DispatchConsumersAsync = true
};

using (var connection = connectionFactory.CreateConnection())
{
using var channel = connection.CreateModel();

var routingKey = queueName;

channel.QueueDeclare(queueName, true, false, false, null);

foreach (var message in messages)
{
var sendBody = Encoding.UTF8.GetBytes(message);

channel.BasicPublish("", routingKey, null, sendBody);
}
}