我似乎找不到任何关于如何 * 异步 * 发布消息到RabbitMQ的信息。
I stumble across的例子通常是关于使用async/await从 * RabbitMQ中检索/使用消息。
var consumer = new AsyncEventingBasicConsumer(model);
consumer.Received += async (o, a) =>
{
Console.WriteLine("Message Get" + a.DeliveryTag);
await Task.Yield();
};
是否有一些示例或示例代码?
编辑
下面是我一直在尝试的一些示例代码:
public Task AddMessageAsync(string content,
TimeSpan? timeToLive,
TimeSpan? initialVisibilityDelay,
CancellationToken cancellationToken)
{
_logger.LogDebug("Starting to add a Message to queue. {content}", content);
CheckRabbitMQPolicy(_logger).Execute(() =>
{
using (var connection = _factory.CreateConnection())
{
_logger.LogDebug("Created a connection to factory.");
using (var channel = connection.CreateModel())
{
_logger.LogDebug("Created a channel");
AddMessageToRabbitMQPolicy(_logger).Execute(() =>
{
_logger.LogDebug("Check or Create a queue '{queueName}'", _queueName);
channel.QueueDeclare(queue: _queueName,
durable: false, // Could be TRUE
exclusive: false,
autoDelete: false,
arguments: null);
_logger.LogDebug("'{queueName}' exists or was created.", _queueName);
var body = Encoding.UTF8.GetBytes(content);
_logger.LogDebug("About to publish message to queue '{queueName}'", _queueName);
//var foo = new AsyncEventingBasicPublish()
channel.BasicPublish(exchange: "",
routingKey: _queueName,
basicProperties: null,
body: body);
_logger.LogDebug("Message published to queue '{queueName}'", _queueName);
});
}
}
});
return Task.CompletedTask;
}
1条答案
按热度按时间zi8p0yeb1#
在当前状态下,RabbitMQ.NET客户端只支持异步使用。
如果你只想遵守一个合同,你可以返回一个
Task.CompletedTask
,就像你做的那样。如果您想开始一些工作并在以后观察它,您可以用对
Task.Run
的调用 Package 该代码,或者只是在您想从同步中断到异步的地方放置一个await Task.Yield()
。