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

在服务总线客户端中处理取消

顾涵衍
2023-03-14

我想在异步模式下使用Azure服务总线客户端(Microsoft.ServiceBus.dll),但不知道如何处理取消。例如,QueueClient.ReceiveAsync方法不采取任何CancellationToken,因此考虑到只要队列中没有消息,此方法就不会返回,如果要取下接收循环,我如何优雅地中断它呢?

多谢.

共有1个答案

徐欣德
2023-03-14

我在这里回答了关于httpwebrequest.getresponseasync的类似问题。虽然我不熟悉Azure服务总线,但我认为您可以使用queueclient.abortqueueclient.close,因为我使用的是httpwebrequest.abort,所以模式应该保持不变。

 类似资料:
  • 我正在尝试从Qpid JMS客户端连接到Windows服务总线。身份验证和握手成功,但无法从主题或队列中获取任何信息。 我的代码基于这里提供的教程。 读取时尝试从服务总线获取消息: 服务器无法处理该请求;请重试该操作。如果问题仍然存在,请与服务总线管理员联系并提供跟踪id。。跟踪ID:583da4f8d58d4fa59dc9521c6f799cb8\U GWIN-AN5B0307EEHM,时间戳:

  • 在本节中,我们将构建一个完整的的 Netty客 户端和服务器。虽然你可能集中在写客户端是浏览器的基于 Web 的服务,接下来你将会获得更完整了解 Netty 的 API 是如何实现客户端和服务器的。 Figure 2.1.Echo client / server 图中显示了连接到服务器的多个并发的客户端。在理论上,客户端可以支持的连接数只受限于使用的 JDK 版本中的制约。 echo(回声)客户端

  • 我已经设法编写了一个小型控制台应用程序来连接到Azure服务总线中的一个主题/订阅。我已经向订阅发送了消息并注册了一个消息处理程序。我看到消息处理程序每60秒轮询一次。例如,是否将轮询间隔延长至30或60分钟?

  • 我想在一些计算机之间建立点对点连接,这样用户就可以在没有外部服务器的情况下聊天和交换文件。我最初的想法如下: 我在服务器上制作了一个中央服务器插座,所有应用程序都可以连接到该插座。此ServerSocket跟踪已连接的套接字(客户端),并将新连接的客户端的IP和端口提供给所有其他客户端。每个客户端都会创建一个新的ServerSocket,所有客户端都可以连接到它。 换句话说:每个客户端都有一个Se

  • 使用Azure Service Bus-Topics,我想实现一个解决方案,其中一旦生产者将消息发送到Topic,消息就会被发送/通知给最终消费者(比如队列)。 我理解主题作为pub/sub模型工作,其中订阅者需要从订阅中读取消息。但是我正在寻找一种类似队列的工作方法(当接收到任何消息时,它会触发web作业/服务)。 首先,我想知道服务巴士的主题是否是正确的选择?接下来,如果可能的话,实现一个变通

  • 我对Azure服务总线队列还比较陌生,正在构建一个项目,该项目需要按照消息到达的顺序(FIFO)处理队列中的消息。 使用微软的文档,我能够理解这一部分。据我所知,我需要为队列打开会话? 我所面临的困难是确定对队列执行以下一组有序任务的最佳方法/服务堆栈。 首先,让我们假设我们有一个基于先进先出的服务总线队列,它有n个消息。我怎么可能: 从队列中拾取第一条消息。 使用Azure函数处理消息。 将有效