zoukankan      html  css  js  c++  java
  • 10,EasyNetQ-发布确认

    默认的AMQP发布不是事务性的,并且不能保证您的消息实际上会到达代理。 AMQP指定了一个事务性发布,但是对于RabbitMQ来说,它非常慢,我们还没有通过EasyNetQ API支持。 对于高性能保证交付,建议您使用“发布确认”。 简而言之,这是AMQP的扩展,当代理成功收到您的消息时,它会提供回调

    '成功收到'是什么意思? 这取决于 ...

    • transient(瞬时)消息在队列入场时被确认。
    • 持久性消息一旦被保存到磁盘或者在每个队列上被使用,就会被确认。
    • 直接发布不可修改的瞬态消息。

    通过在连接字符串上设置publisherConfirms = true来启用发布确认:

    bus = RabbitHutch.CreateBus("host=localhost;publisherConfirms=true;timeout=10");

    同步bus.Publish(..)方法将在返回之前等待确认。 在超时期限之前未确认(也在连接字符串中配置)将导致引发异常。 发布确认同步发布方法会显着减慢。 如果性能问题,您应该考虑使用PublishAsync方法:

    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("
    
    ");
                    Console.Out.WriteLine(task.Exception);
                    Console.Out.WriteLine("
    
    ");
                }
            });

    这将在收到确认之前返回。 如果未收到确认或NACK确认,任务将在故障状态下完成。

  • 相关阅读:
    范例-项目-.NET-PetShop-4.0-架构设计:目录、PetShop概述
    汉语-词语:立志
    汉语-汉字:被
    汉语-成语:被褐怀珠
    汉语-成语:被褐怀玉
    汉语-成语:被褐藏辉
    汉语-词语:处世
    使用exp&imp工具进行数据库备份及恢复
    oracle创建表空间-用户-角色-授权
    linux下单独安装oracle12.1客户端
  • 原文地址:https://www.cnblogs.com/zd1994/p/8651190.html
Copyright © 2011-2022 走看看