~~~ <?php require_once 'vendor/autoload.php'; use Pheanstalk\Pheanstalk; //创建一个Pheanstalk对象 $p = new Pheanstalk('192.168.241.129', 11300); //监听userReg管道,忽略default管道 $job = $p->watch('userReg')->ignore('default')->reserve(); $data = json_decode($job->getData()); //打印任务中的数据 print_r($data); //最后删除任务,表示任务处理完成 $p->delete($job); ~~~ reserve方法为阻塞方法,可以使用下面方法监听读取消息数据 ``` while (true) { //监听userReg管道,忽略default管道 $job = $p->watch('test')->ignore('default')->reserve(); $data = json_decode($job->getData(),true); //打印任务中的数据 print_r($data); //最后删除任务,表示任务处理完成 $p->delete($job); } ```