代码之家 › 专栏 › 技术社区 › Pankaj Rawat

ServiceBus重试策略不适用于QueueClient

servicebus azure-functions azure

Pankaj Rawat · 技术社区 · 8 年前

我想限制azure servicebus队列接收器中的重试次数。

使用控制台应用程序发送消息 最大重试次数:3

private static async Task MainAsync()
    {
        string connectionString = ConfigurationManager.AppSettings["ServiceBusConnection"];
        QueueClient queueClient = QueueClient.CreateFromConnectionString(connectionString, QueueName);
        queueClient.RetryPolicy = new RetryExponential(
                minBackoff: TimeSpan.FromSeconds(0),
                maxBackoff: TimeSpan.FromSeconds(30),
                maxRetryCount: 3);

        string tradeData = File.ReadAllText("TradeSchemaDemo.json");
        var message = new BrokeredMessage(tradeData);
        await queueClient.SendAsync(message);
        await queueClient.CloseAsync();
    }

另一边我有azure函数来接收消息,

public static void run([ServiceBusTrigger("TestQueue", AccessRights.Manage, Connection = "servicebusconnection")]string myqueueitem, TraceWriter log)
    {
        retry++;
        System.Console.WriteLine($"Retry attempt {retry}");
        throw new System.Exception("Human error");
        log.Info($"c# servicebus queue trigger function processed message: {myqueueitem}");
    }

不过,我的函数调用了10次。为什么??

2 回复 | 直到 8 年前

Mikhail Shilkov 8 年前

在这种情况下, RetryPolicy 定义发送操作(不是在接收端)的重试次数。

接收器重试次数由队列属性定义 Max Delivery Count . 您可以使用服务总线资源管理器等工具在队列级别设置它,也可以在创建队列时以编程方式设置它:

var namespaceManager = NamespaceManager.CreateFromConnectionString(connectionString);
var queue = new QueueDescription(queueName);
queue.MaxDeliveryCount = 3;
if (!namespaceManager.QueueExists(queueName))
    namespaceManager.CreateQueue(queue);

Pankaj Rawat 8 年前

万一有人想看代码

private static async Task MainAsync()
    {
        string connectionString = ConfigurationManager.AppSettings["ServiceBusConnection"];
        var nm = NamespaceManager.CreateFromConnectionString(connectionString);
        var queue = new QueueDescription(QueueName);
        queue.MaxDeliveryCount = 3;
        if (!nm.QueueExists(QueueName))
            await nm.CreateQueueAsync(queue);

        QueueClient queueClient = QueueClient.CreateFromConnectionString(connectionString, QueueName);
        string tradeData = File.ReadAllText("TradeSchemaDemo.json");
        var message = new BrokeredMessage(tradeData);
        await queueClient.SendAsync(message);
        await queueClient.CloseAsync();
    }

推荐文章

BPengu · 发现运算符-eq的操作数无效

1 年前

Scott · Terraform Azure包含带有子网部署的NSG

1 年前

akaparadox · 使用Microsoft Entra(Azure AD)获取SPA应用程序的刷新令牌

1 年前

nop · 如何在本地环境中加载secrets.json而不是在ASP。NET核心?

1 年前

Amit Kanala · 我尝试在microsoft outlook日历中创建事件,但出现错误,访问令牌验证失败。无效受众

1 年前

Adnane Bady Soussi · 我试图更新我在代码中通过graphapi创建的一个现有用户,但我从azure graphapi返回了403错误

1 年前

Luca · 问题/如何使用GRAPH API获取我的SharePoint网站的文档库

1 年前

VivekAnandChakravarthy · 在azure逻辑应用程序标准vs代码中以设计器身份打开工作流时出错

1 年前

Romeo · 密钥保管库机密问题-防火墙已打开,您的客户端IP地址无权访问此密钥保管库

1 年前

T McKeown · 您是否可以使用Azure API/M调用基于WCF SOAP的端点?

1 年前