web编程开发中,会遇到资源争用的情况。举例:
有多个商品,商品抢单,每个商品都有数量限制。
但凡遇到此类问题,自古以来,就有两种解决方式:1、使用锁,2、使用队列。
使用任意一个就可以。
使用队列的方式最为简单,不考虑加锁。也无需使用数据库的锁。
把所有的请求都放入队列,然后把队列处理的结果返回给客户端。
如果商品太多,可以按商品大类分成多个队列。这样处理速度快些。
现在的问题是:队列是异步返回的,怎么办呢?
构思场景,进程A处理web请求,进程B是队列,进程C是监听队列的守护进程。
简单的做法是:A把请求放入队列,然后进程C处理好直接异步通知客户端,但这得有nodejs之类的长连接帮助。因为要推送。
所以使用如下方案解决:
使用redis把队列的异步返回改成同步
添加redis守护进程D。
web请求进程A:
创建一个随机数random。
把处理消息发给队列,但是把random加入到消息里。
使用 $result = $redis->blPop("chan-1",30);// 30秒是等待时间,
BLPOP是列表的阻塞式(blocking)弹出原语。
它是LPOP命令的阻塞版本,当给定列表内没有任何元素可供弹出的时候,连接将被BLPOP命令阻塞,直到等待超时或发现可弹出元素为止。
然后只要从$result中获取进程C的返回即可。
守护进程C:
把rendom从消息中取出,处理整条消息,得到结果。
然后把结果放到以random为键名称的redis的列表里。即可。
$redis->lPush('random键', '处理结果');
已有 0 人发表留言,猛击->> 这里<<-参与讨论
ITeye推荐