PHP使用Beanstalkd实例详解
发布时间：2022-07-29 12:03:29 所属栏目：PHP教程 来源：互联网
导读：有关Beanstalkd的基本概念，编译和yum的安装方法已经在上篇文章《Beanstalkd消息/任务队列的详解》中介绍了，今天练习下PHP使用Beanstalkd的过程，我选择的是使用Pheanstalk类来连接Beanstalkd 1.使用Composer安装Pheanstalk composer require pda/pheanstal
|
有关Beanstalkd的基本概念，编译和yum的安装方法已经在上篇文章《Beanstalkd消息/任务队列的详解》中介绍了，今天练习下PHP使用Beanstalkd的过程，我选择的是使用Pheanstalk类来连接Beanstalkd 1.使用Composer安装Pheanstalk composer require pda/pheanstalk 2.实现代码 php查看beanstalkd状态脚本Status.php <?php /** * Created by PhpStorm. * User: jmsite.cn * Date: 2019/1/21 * Time: 10:32 */ require "../vendor/autoload.php"; use PheanstalkPheanstalk; $pheanstalk = new Pheanstalk('192.168.75.135',11300); print_r($pheanstalk->stats()); 生产者代码Producter.php <?php /** * Created by PhpStorm. * User: jmsite.cn * Date: 2019/1/20 * Time: 16:30 */ require "../vendor/autoload.php"; use PheanstalkPheanstalk; $pheanstalk = new Pheanstalk('192.168.75.135',11300); for ($i=0;$i<50;$i++){ $data = array( 'key' => 'testkey'.$i, 'value' => 'testvalue', 'time' => time(), //phpfensi.com ); $ret = $pheanstalk->putInTube('test-tube', json_encode($data), Pheanstalk::DEFAULT_PRIORITY, Pheanstalk::DEFAULT_DELAY, Pheanstalk::DEFAULT_TTR); var_dump($ret); } 消费者代码Consumer.php <?php /** * Created by PhpStorm. * User: jmsite.cn * Date: 2019/1/20 * Time: 16:31 */ set_time_limit(0); ini_set('default_socket_timeout', 900); require "../vendor/autoload.php"; use PheanstalkPheanstalk; $pheanstalk = new Pheanstalk('192.168.75.135',11300); while (true){ $job = $pheanstalk ->watch('test-tube') ->ignore('default') ->reserve(); if ($job){ sleep(2); echo $job->getData(); echo "n"; $pheanstalk->delete($job); } } 打开命令行/终端窗口，执行生产者，会向tube写入50条任务 PS E:repositoryworkbeanstalk> php .Producter.php int(101) int(102) int(103) int(104) int(105) int(106) int(107) int(108) int(109) int(110) int(111) int(112) int(113) int(114) ...... 由此可见，$pheanstalk->putInTube成功后返回的是job的id 查看状态 PS E:repositoryworkbeanstalk> php Status.php PheanstalkResponseArrayResponse Object ( [_name:PheanstalkResponseArrayResponse:private] => OK [storage:ArrayObject:private] => Array ( [current-jobs-urgent] => 0 [current-jobs-ready] => 50 [current-jobs-reserved] => 0 [current-jobs-delayed] => 0 [current-jobs-buried] => 0 ...... 结果中显示处于ready待读取状态的job是50个 打开两个或以上命令行/终端窗口，执行消费者，模拟多消费者竞争 （编辑：信阳站长网） 【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容! |
