redis 队列应用实例

Question

先来看看异步处理

如中的异步读取通过什么方式呢，是写一个php进程来不断循环读取某个redis 的 list（push/pop） 数据吗？

还有就是系统解耦方面的

这个订阅是使用Pub/sub 吗？

文章地址是 http://www.cnblogs.com/stopfa...，看了是懂的，但就是实现上还需要考虑，请问有没有什么具体的例子呢，毕竟看完不做实例总不是太踏实。

Answer 1

1. 不是循环读取。是阻塞，没有消息的话进程会阻塞在那里。有消息就会自动拿下来执行业务逻辑
2. 基于消息队列的系统都是 Pub/Sub（也成生产者/消费者）模式

Answer 2

redis只能做简单的消息队列 消费者只能有一个 而且要实现阻塞需要用while true sleep 在一些单应用可以使用 推荐用kafka 支持多个消费者 还可以设置位移偏量 rdkafka扩展可以实现阻塞 项目如果比较重 考虑用kafka