请教下关于php消息队列的问题

问题描述: 最近在实现一个功能后台添加一个用户,需要将这个用户添加到已有的群组里面去。群组功能是通过腾讯云IM实现的,已有的群组也可以通过腾讯云IM的接口获取到群组列表,然后可以通过腾讯IM接口去添加类似于群组ID+新建用户ID传参调用添加已有群组成员。如果群组列表比较多,所以通过循环的列表的方式去调用接口,可能会造成响应时间太久,于是就想到了使用队列的方式。因为也是第一次使用队列,看了被人使用队列都会有生产者和消费者。我的疑问在于,我是应该在生产者中通过循环出群组的次数(假设有100个组),然后在生产者中 Queue::push 100次,然后消费者去处理。还是说生产者中只Queue:push 1次,将这100个群组的id携带传递给消费者,在消费者中遍历然后调用接口去进行处理。

阅读 1.4k
1 个回答

你一次 push 100个,那不就把消费者阻塞了么。

假设你现在系统需要重启,有10个消费者,如果你一次 push 100 个,那要等队列退出,就得等 100 个都完成才行,显然 大部分时间时候,系统不会留给你那么多时间去等待,如果时一次 push 1 个,那只需要等当前的结束就行了。当然,你也可以自行实现100个的中断与恢复。

撰写回答
你尚未登录,登录后可以
  • 和开发者交流问题的细节
  • 关注并接收问题和回答的更新提醒
  • 参与内容的编辑和改进,让解决方法与时俱进
推荐问题