本文共 306 字,大约阅读时间需要 1 分钟。
引入beanstalkd 并且连接服务,调用封装接口Pheanstalkbeanstalkd.php
生产者 demo.php
useTube('newUsers') ->put(123456); ?>消费者 test.php
watch('newUsers') //监听管道 ->reserve(); //把监听到的ready状态的任务读取出来 echo ($job->getData()); //读取任务里面的数据 getId(); //处理具体业务 $pheanstalk->delete($job);}?>
转载地址:http://foboi.baihongyu.com/