/vendor/autoload.php'; use Pheanstalk\Pheanstalk; class beanstalkd{ public $conf=[ 'host { return Pheanstalk::create($this->conf['host'], $this->conf['port'], $this->conf['timeout'] /beanstalkd.php'; $pheanstalk = beanstalkd::factory()->handle(); $re=$pheanstalk ->useTube('testtube /beanstalkd.php'; $pheanstalk = beanstalkd::factory()->handle(); $pheanstalk->watch('testtube'); while (true) { $job = $pheanstalk->reserve(); //echo $job->getData().PHP_EOL; //处理任务 exec
artisan queue:table php artisan migrate QUEUE_CONNECTION=database beanstalkd composer require pda/pheanstalk
migrate 安装依赖包 项目根目录可安装如下依赖包 下面是以上列出队列驱动需要安装的依赖: • Amazon SQS: aws/aws-sdk-php ~3.0 • Beanstalkd: pda/pheanstalk
Message queue packages for PHP, Symfony, Laravel, Magento enqueue/rdkafka enqueue/enqueue enqueue/pheanstalk AMQP (高级消息队列协议) 的服务实现 RocketMQ ActiveMQ Qpid Disque - 分布式内存队列 beanstalkd - 一个高性能、轻量级的消息队列中间件 队列相关类库 Pheanstalk
处理NoSQL后端的库 MongoQB:一个MongoDB查询构建库 官网 Monga:一个MongoDB抽象库 官网 Predis: 一个功能完整的Redis库 官网 队列 处理事件和任务队列的库 Pheanstalk