当前位置: 首页 > 知识库问答 >
问题:

设置服务总线队列超时

邢焱
2023-03-14

我正在尝试创建QueueClient并将其超时时间从默认值60秒增加到60秒。当我从Connectionstring创建客户端时,它工作正常,但我无法调整时间。当我使用下面的工厂代码创建客户机时,我得到以下超时异常。谁能告诉我我错过了什么或只是没有做什么。

{“请求在00:00:00毫秒后超时。无法确定请求是否成功完成。应进行其他查询以确定操作是否成功。”}

工作于Endpoint=sb://xxxx的连接字符串。服务总线。窗户。净/;SharedAccessKeyName=策略;SharedAccessKey=密钥

代码:

MessagingFactorySettings settings = new MessagingFactorySettings
      {
        OperationTimeout = TimeSpan.FromSeconds(120),
        TokenProvider = TokenProvider.CreateSharedSecretTokenProvider("policy", "key")
      };

      var address = ServiceBusEnvironment.CreateServiceUri("sb", "xxxx.servicebus.windows.net", string.Empty);

      var messagingFactory = MessagingFactory.Create(address, settings);

      QueueClient result = messagingFactory.CreateQueueClient(queueName);

      result.RetryPolicy = new RetryExponential(TimeSpan.Zero, TimeSpan.FromMilliseconds(1000), 5);
      return result;

共有1个答案

黄彬
2023-03-14

您使用的是ACS还是SAS密钥?从您的连接字符串来看,它看起来像SAS,因此您可能希望改用CreateSharedSecretTokenProvider。如

令牌提供者凭据=令牌提供者。CreateSharedAccessSignatureTokenProvider(sasKeyName、sasKeyValue);

 类似资料:
  • 我正在使用azure服务总线主题和订阅机制,并希望处理所有在死信队列中的消息。 此外,我想通过C#中的Azure Web作业处理消息,并将其发送回队列。所以我想知道如何通过我的应用程序处理死信队列上的消息?

  • 我有一个服务总线Q,从Azure门户可以或多或少地看到服务总线Q包含多少条目。如何使用他们的管理API获取此计数?我仔细阅读了文档,但没有找到答案。

  • 今天晚上,我们观察到排队时间非常慢。我们的追踪数据告诉我们 需要45-60秒。这种情况发生在两个已经存在很长时间的队列上。他们几乎从来没有超过1-2条记录,我们使用一个带有服务总线触发器的网络作业来完成任务。我们正在排队等候一个简单的POCO。还有另一个队列正在快速排队,所以由于没有任何其他想法,我删除了两个麻烦的队列。当代码重新创建它们时(正如它被构建时所做的那样),它们在不到一秒钟的时间里开始

  • 使用WebJobs SDK时,将代理消息移动到死信队列的正确方法是什么?通常我会打电话给味精。死信()。但是,SDK负责管理代理消息的生命周期。它将调用msg。如果方法返回成功,则返回Complete(),如果发生异常,则将重试该消息。我需要第三种情况,告诉ServiceBus队列将消息移动到死信队列,因为它是一条坏消息。

  • 我有一个windows服务,它侦听Azure服务总线队列消息,以便从我的WebApi应用程序分发处理。此外,我还需要处理重复性任务(每晚/每周),我认为最好使用相同的系统来处理这些任务。 例如,假设我有一个“CleanupDb”队列,每天午夜删除过时的DB节点: 理论上这应该行得通,但我觉得我错过了一个更明显的处理方法。有没有更好的办法?