http://jackxiang.com/index.php zh-cn http://jackxiang.com/post// jack <xdy108@126.com> Wed, 11 Apr 2018 06:41:48 +0000 http://jackxiang.com/post// Swoole-2.1.2 进程池模块的使用：http://mp.weixin.qq.com/s?__biz=MzI0MjEwMDMzNQ==&mid=2652517441&idx=1&sn=06909bb58cc4c0f3ade589a005ed6e84&chksm=f2efe541c5986c5741aa240e9a4daaab47c542b325a0042c4fbd5094ded48221035d90003fe1&mpshare=1&scene=1&srcid=04119CY2J0y8Az2isPm9UKyL#rd


redis-cli
127.0.0.1:6379> del list1 list2
(integer) 0
127.0.0.1:6379> rpush list1 a b c
(integer) 3
127.0.0.1:6379> brpop list1 list2 0
1) "list1"
2) "c"



brpop的效果吧，首先模拟一个消息的“生产者”
<?php           $r = new Redis();           $r->connect("127.0.0.1", 6379);              $r->lpush("msg","Hello ciaos");           $r->lpush("msg","Hello penjin");   ?>   然后模拟一个消息的消费者，而redis-server则充当中间的消息队列（我这里当然用的是redis的list类型） [codes=php] <?php           $r = new Redis();           $r->connect("127.0.0.1", 6379);              $res = $r->brpop("msg",0);           var_dump($res);   ?>  
很简单，brpop的意思是在消息队列尾阻塞地取出消息，参数0表示一直阻塞下去直到有消息在msg这个list中，我们可以指定一个数字代表过期时间。首先运行消费者，可以看到程序阻塞了，然后运行“生产者”，则消费者输出了消息如下：
php consumer.php  
array(2) {  
  [0]=>  
  string(3) "msg"  
  [1]=>  
  string(11) "Hello ciaos"  
}  

lpush操作和brpop操作也保证了队列的先进先出，如果用blpop则会看到输出的是"Hello penjin"(第二条消息)。
其中brpop还可以指定监测多个消息队列，直到有任意一个消息队列中有待处理消息时阻塞返回，感觉还是比较简单易用的。redis的list消息队列没有优先级的概念，所有消息都只能先进先出或者后进先出，要实现优先级，可以考虑使用set数据结构。 ]]> http://jackxiang.com/post//#blogcomment <user@domain.com> Thu, 01 Jan 1970 00:00:00 +0000 http://jackxiang.com/post//#blogcomment