laravel8 beanstalk 使用说明

小编这里使用的是laravel 8版本来做解析

1、使用composer 加载组件库，不指定版本号的话默认安装最新版本，安装完成后进行配置

composer require pda/pheanstalk

2、配置beanstalk服务，这里小编把配置摘到env当中了

#beanstalk 队列
BEANSTALKD_HOST=127.0.0.1

3、put数据使用，不多说直接上代码

//先引入类
use Pheanstalk\Pheanstalk;

//创建链接
$pheanstalk = Pheanstalk::create(env('BEANSTALKD_HOST'));
//选择管道尽心存储数据
$pheanstalk->useTube('管道名称（自行定义）')->put(json_encode($info));
$res = $pheanstalk->stats();
if (empty($res) || !isset($res['name']) || $res['name'] != 'OK') {
	//报警
}

4、获取beanstalk管道数据

//先引入类
use Pheanstalk\Pheanstalk;

//创建链接
$pheanstalk = Pheanstalk::create(env('BEANSTALKD_HOST'));
//选择管道
$pheanstalk->watch('yunDuoDataList');
//设置链接超时时间
$job = $pheanstalk->reserveWithTimeout (3);
if (!$job) {
    return false;
}
//获取数据
$beanstalkStr = $job->getData();
if (empty($beanstalkStr)) {
    return false;
}
//解析数据进行业务使用
$beanstalkInfo = json_decode($beanstalkStr, true);

5、常用方法参考

beanstalk 常用方法、说明_蹲在角落数蚂蚁的博客-CSDN博客