根据调用事件处理程序的函数返回值
本文关键字:函数 返回值 程序 事件处理 调用 | 更新日期: 2024-09-23 00:31:39
我正在使用RabbitMQ(.Net客户端库)将XML消息从WebAPI发布到队列。如果已发布的消息成功地持久化到磁盘,则我需要发送状态代码200(如果不是),则应返回代码400。RabbitMQ客户端库提供两个单独的事件来发送ACK或NACK事件,指示消息是否已保存。因此,在返回http响应之前,我的发布函数需要等待两个事件句柄中的任何一个被调用。
我怎样才能做到这一点?
Api控制器操作
[HttpPost]
public HttpResponseMessage SendSomething()
{
...
bool success = _publisher.Publish(bytes);
if(success) // Send status 200
else // Send status 400
...
}
消息发布代码
public bool Publish(byte[] data)
{
..
channel.BasicAcks += OnAck;
channel.BasicNacks += OnNack;
channel.BasicPublish("", "test", null, data);
..
// Depending on if OnAck or OnNack is called I need to return true or false
return ??
}
private void OnNack(IModel model, BasicNackEventArgs args)
{
...
}
private void OnAck(IModel model, BasicAckEventArgs args)
{
...
}
如果我没看错,您需要将基于异步回调的例程转换为同步例程。天真的答案是让线程休眠并等待某件事发生:
public bool Publish(byte[] data)
{
//..
bool? response = null;
channel.BasicAcks += (model, args) => response = true;
channel.BasicNacks += (model, args) => response = false;
channel.BasicPublish("", "test", null, data);
while (response == null)
Thread.Sleep(300);
return response.Value;
}
然而,这意味着您的响应时间将始终是300ms的倍数,并且您存在难以实现超时逻辑的问题。一个更好的答案可能是使用ManualResetEvent
。这允许回调在收到响应后立即通知被阻止的线程,方法是"设置"事件:
public bool Publish(byte[] data)
{
//..
bool successful = false;
var responseReceivedEvent = new ManualResetEvent(false);
channel.BasicAcks += (model, args) =>
{
successful = true;
responseReceivedEvent.Set();
};
channel.BasicNacks += (model, args) =>
{
successful = false;
responseReceivedEvent.Set();
};
channel.BasicPublish("", "test", null, data);
responseReceivedEvent.WaitOne();
return successful;
}
在任何一种情况下,您都可以(或应该)实现某种超时/重试逻辑,除非RabbitMQ为您这样做。您可以在最后一个示例中使用ManualResetEvent.WaitOne()
的WaitOne(int)
或WaitOne(TimeSpan)
重载来执行此操作。