PHP RabbitMQ使用者:预取1

托马斯·普拉多(Tomas Prado)

为了避免常见的并发问题,我使用了单线程php使用者,该使用者使用了一个RabbitMQ队列中的多个消息。

基本上,相同的php脚本已执行X次并等待新消息。

我的问题是:
假设由于我的使用者是单线程的,所以我将预取配置设置为1条消息,这是正确的吗?

PHP预取计数RabbitMQ

因为很明显它一次不会处理多于一条消息...
对吗?

现在不能睡觉

预取只是一些消息,代理会将这些消息放在消费者端,并仅在确认这些消息后才将其删除。现在,如果我们假设客户(消费者)当时正在处理一条消息,那么这个数字prefetch_count并不是很重要。但是,如果客户端在一个线程使用消息,然后生成新线程-每个线程都处理一条消息,那么显然是另一回事了。因此,可以说多线程确认更像是一个故事。
因为您编写了单线程使用者,所以我很确定您的意思是整个客户端都是单线程的,而不仅仅是“消耗”部分,所以我的直接答案是是可以将其设置为1,但不是必须的,它更多地取决于ACK消息的方式。我只想详细介绍多线程处理部分。

本文收集自互联网,转载请注明来源。

如有侵权,请联系[email protected] 删除。

编辑于
0

我来说两句

0条评论
登录后参与评论

相关文章

来自分类Dev

PHP RabbitMQ使用者:预取1

来自分类Dev

在PHP上如何取消RabbitMQ中的使用者?

来自分类Dev

RabbitMq使用者未处理消息

来自分类Dev

Pika-RabbitMQ-为什么为消费者使用预取计数1时我的交付率大于确认率

来自分类Dev

使用nodeJS在RabbitMQ中删除使用者

来自分类Dev

如何使用Pyspark Streaming模块实现RabbitMQ使用者?

来自分类Dev

如何使用Docker运行RabbitMQ使用者-NodeJS

来自分类Dev

RabbitMQ固定答复和使用者配置

来自分类Dev

RabbitMQ重试消息而不从使用者发布

来自分类Dev

Rabbitmq使用者获取不同路由密钥的消息

来自分类Dev

如何为ServiceStack RabbitMQ使用者创建多个线程?

来自分类Dev

RabbitMQ-如何为新使用者保存消息

来自分类Dev

RabbitMQ使用者在收到MQTT消息时失败

来自分类Dev

闲置90秒后,RabbitMQ使用者连接消失

来自分类Dev

RabbitMQ使用者未收到该消息

来自分类Dev

RabbitMQ 消费者性能 - 预取与并发

来自分类Dev

PHP Rabbitmq消费者重新连接

来自分类Dev

删除RabbitMQ使用者并在浏览器的RabbitMQ控制台中查看

来自分类Dev

RabbitMQ:如何在Python生产者和使用者之间发送Python字典?

来自分类Dev

Rabbitmq生产者(symfony 3)和使用者错误(NodeJs)

来自分类Dev

使用spring RabbitMQ时如何设置预取

来自分类Dev

使用spring RabbitMQ时如何设置预取

来自分类Dev

如何使用SimpleMessageListenerContainer禁用RabbitMQ预取计数

来自分类Dev

如何在.Net中与不同类型的使用者一起使用RabbitMq消息?

来自分类Dev

如何在.Net中与不同类型的使用者一起使用RabbitMq消息?

来自分类Dev

如何设置RabbitMQ使用者以从非空队列中使用?

来自分类Dev

使用预取> 1运行的MassTransit传奇

来自分类Dev

使用预取> 1运行的MassTransit传奇

来自分类Dev

我可以为RabbitMQ使用者设置一个明确的任务超时吗?

Related 相关文章

  1. 1

    PHP RabbitMQ使用者:预取1

  2. 2

    在PHP上如何取消RabbitMQ中的使用者?

  3. 3

    RabbitMq使用者未处理消息

  4. 4

    Pika-RabbitMQ-为什么为消费者使用预取计数1时我的交付率大于确认率

  5. 5

    使用nodeJS在RabbitMQ中删除使用者

  6. 6

    如何使用Pyspark Streaming模块实现RabbitMQ使用者?

  7. 7

    如何使用Docker运行RabbitMQ使用者-NodeJS

  8. 8

    RabbitMQ固定答复和使用者配置

  9. 9

    RabbitMQ重试消息而不从使用者发布

  10. 10

    Rabbitmq使用者获取不同路由密钥的消息

  11. 11

    如何为ServiceStack RabbitMQ使用者创建多个线程?

  12. 12

    RabbitMQ-如何为新使用者保存消息

  13. 13

    RabbitMQ使用者在收到MQTT消息时失败

  14. 14

    闲置90秒后,RabbitMQ使用者连接消失

  15. 15

    RabbitMQ使用者未收到该消息

  16. 16

    RabbitMQ 消费者性能 - 预取与并发

  17. 17

    PHP Rabbitmq消费者重新连接

  18. 18

    删除RabbitMQ使用者并在浏览器的RabbitMQ控制台中查看

  19. 19

    RabbitMQ:如何在Python生产者和使用者之间发送Python字典?

  20. 20

    Rabbitmq生产者(symfony 3)和使用者错误(NodeJs)

  21. 21

    使用spring RabbitMQ时如何设置预取

  22. 22

    使用spring RabbitMQ时如何设置预取

  23. 23

    如何使用SimpleMessageListenerContainer禁用RabbitMQ预取计数

  24. 24

    如何在.Net中与不同类型的使用者一起使用RabbitMq消息?

  25. 25

    如何在.Net中与不同类型的使用者一起使用RabbitMq消息?

  26. 26

    如何设置RabbitMQ使用者以从非空队列中使用?

  27. 27

    使用预取> 1运行的MassTransit传奇

  28. 28

    使用预取> 1运行的MassTransit传奇

  29. 29

    我可以为RabbitMQ使用者设置一个明确的任务超时吗?

热门标签

归档