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

使用Azure Service Bus对队列和主题/订阅进行消息排序传递

秦育
2023-03-14

我对队列和主题是否默认支持消息排序传递感到困惑。

它说下面的队列支持FIFO消息传递。我假设这与消息排序传递是一样的。

队列向一个或多个竞争的消费者提供先进先出(FIFO)消息传递。https://docs.microsoft.com/en-us/Azure/service-bus-messaging/service-bus-queues-topics-subscriptions

主题和订阅的FIFO怎么办?

更新

我的问题是:

1, 2, 3, 4, ... n
session 1: 1, 2, 3, n

session 2: 1, 2, 3, n

session n: 1, 2, 3, n

共有1个答案

毕衡
2023-03-14

可以在支持接收的实体上启用会话。这将是队列和订阅。主题只能用于发送。

已更新

我需要保留所有消息顺序而不启用会话

 类似资料:
  • 在我们的业务需求中,我们需要将更新传输到分布在全国各地的数千个客户端。问题是,许多这些客户端使用3G网络连接到我们,因此,发生了许多连接/断开连接...我们需要提供的更新是诸如“企业A不能再兑现”或“企业B能够再次兑现”之类的东西,我们正在考虑使用ActiveMQ持久主题来提供这些更新。我的理解是,一旦客户端连接到持久主题,即使他断开连接,每当他回来时,他都会在脱机时收到发送到该主题的消息。最大的

  • 我需要将我的消息发送到死信队列从Azure主题订阅在任何错误的情况下,而阅读和处理从主题的消息。所以我尝试直接将消息推送到DLQ。 我的样本代码会像 我试着获取死信队列路径 我得到了死信队列的路径,如=“mytopic/$deadletterqueue” 但它在将路径作为主题名传递时不起作用。它引发实体主题未找到异常。 有谁能告诉我这件事吗 参考:如何使用Java将错误消息移动到Azure死信队列

  • 问题内容: 我正在使用Paho发送和接收mqtt消息。到目前为止,发送消息一直没有问题,我正在使用mosquitto接收消息。 现在,我想使用Java客户端读取消息,并且注意到关于接收消息的文档越来越少。 我实现了MqttCallback接口,但仍然无法弄清楚如何阅读已订阅的主题的消息。 到目前为止,这是我的源代码,我可以使用mosquitto_sub读取消息。 问题答案: 您将在代理有时间将消息

  • 是否有一种方法可以使用AWS CLI列出特定SQS队列订阅的所有AWS SNS主题? 我已经知道如何看到一个SNS主题上的订阅者列表,但这只有在我知道SNS主题的名称时才起作用。在这种情况下,我只知道SQS队列的名称。 我在网上搜索什么也找不到。

  • 我正试图找到一种方法,使用Firebase云消息发送通知给我的应用程序的所有用户,但我有一个仅限web的应用程序。我见过一些针对Android/iOS的解决方案,基本上是让用户自动订阅一个名为“allDevices”的主题,然后向订阅该主题的所有用户发送通知。我似乎找不到任何关于如何让基于web的用户订阅主题的文档。有人知道这是否可能吗?如果有,是否有我遗漏的文件可以涵盖这一点? 谢谢!

  • 我正在配置一个Apache Artemis消息代理。代理将接受大文件,下游消费者访问该主题以处理最新文件。现在我想知道如何使最新文件可用于开发运行。因为消息一天只到达几次,所以测试运行需要访问最近发送的几条消息,不能等待下一条。 对于生产和登台系统,我发现持久订阅工作良好。我已经改编了ApacheCamel配置作为示例。以下是两个接收消息的消费者,每个消费者都使用持久订阅: 这很好。如果一个消费者