redis_queue
简介
基于redis服务实现的简单消息队列
组件接口
redis_queue.gs
函数原型 | 函数作用 |
---|---|
object create_queue(string id, string redis_db) | 创建一个消息队列 |
ReidsQueue.gs
基于redis lpush/brpop操作实现的消息队列
发送端send数据返回true: 表示接收端一定会recv到数据
函数原型 | 函数作用 |
---|---|
bool send(mixed val) | 发送数据 |
array recv_once(int seconds) | 执行一次接收数据 |
array recv(int seconds = -1) | 接收数据直到超时或者收到数据 |