默认的AMQP发布不是事务性的,而且不能保证您的消息实际上会到达代理。 AMQP指定了一个事务性发布,可是对于RabbitMQ来讲,它很是慢,咱们尚未经过EasyNetQ API支持。 对于高性能保证交付,建议您使用“发布确认”。 简而言之,这是AMQP的扩展,当代理成功收到您的消息时,它会提供回调。性能
'成功收到'是什么意思? 这取决于 ...spa
经过在链接字符串上设置publisherConfirms = true来启用发布确认:代理
bus = RabbitHutch.CreateBus("host=localhost;publisherConfirms=true;timeout=10");
同步bus.Publish(..)方法将在返回以前等待确认。 在超时期限以前未确认(也在链接字符串中配置)将致使引起异常。 发布确认同步发布方法会显着减慢。 若是性能问题,您应该考虑使用PublishAsync方法:code
bus.PublishAsync(new MyMessage { Text = "Hello World" }).ContinueWith(task => { // 这只会检查完成的任务IsCompleted是否成立,即便对于咱们使用if(task.IsCompleted &&!task.IsFaulted)来检查成功的故障状态任务 if (task.IsCompleted) { //Console.Out.WriteLine("{0} Completed", count); } if (task.IsFaulted) { Console.Out.WriteLine("\n\n"); Console.Out.WriteLine(task.Exception); Console.Out.WriteLine("\n\n"); } });
这将在收到确认以前返回。 若是未收到确认或NACK确认,任务将在故障状态下完成。blog