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

AWS SQS FIFO无法接收所有消息

令狐嘉运
2023-03-14

(如这张图所示,我有5条消息可用,但我只能收到2条消息。)

我试图删除收到的两条消息中的一条,然后再次轮询。删除的没有了,我收到了新的消息。但总共还是2条消息。

共有1个答案

洪照
2023-03-14

使用Amazon SQS FIFO队列意味着您希望按顺序接收消息。它还将尝试确保消息组内的排序。

这意味着,如果针对给定消息组ID的一些消息当前正在处理(“在飞行中”),则不会为该消息组提供更多的消息,因为如果未完全处理,较早的消息可能会返回到队列。这可能会导致消息的处理顺序混乱。

通过使用Amazon SQS消息组ID-Amazon简单队列服务:

  • 不使用FIFO队列,或
  • 使用不同的消息组ID,或
  • 对它正在做的事情感到满意,因为这是所需的FIFO行为
 类似资料:
  • mosquitto.conf将最大飞行消息设置为0,持久性为true。 发布服务器QOS=2 用户QOS=2 保持活力=60 还有其他参数我应该看吗?

  • 如果我创建上面的类并尝试在tomcat7上部署war,我会看到以下错误。

  • 我在远程机器上设置了Kafka和动物园管理员。在那台机器上,我可以看到下面使用官方网站上的测试方法工作。 但是当我使用本地消费者脚本时,它就不起作用了: 我试着把它改成: 然后运行客户端使用者脚本,它会给出错误: [2017-08-11 15:49:01,591]获取相关id为3的元数据时警告错误:{listings-incoming=leader_not_available}(org.apach

  • 我是一个使用python进行套接字编程的初学者。我正在做我的课程项目。我的项目的一部分需要用不同的端口发送和接收UDP消息。提供了名为robot的服务器程序,我需要编写名为student的客户端程序,它可以与机器人进行交互。因此,我不能显示服务器程序中的所有源代码。 这是服务器程序中与UDP套接字相关的部分 这是我的客户端程序。s3 是 UDP 套接字。我可以成功地向服务器程序发送消息,但无法从中

  • 我想创建一个电报机器人,向添加它的组/频道发送更新。我用BotFather创建了一个机器人https://api.telegram.org/bot 现在这不是问题,但随着时间的推移,json文件可能会变得非常大,并可能造成问题。 有没有办法让我无法获得json中的所有消息都存在于