https://www.jianshu.com/p/5c2befeb3c6b  转自这个大佬的代码

1.安装Beanstalkd

  yum install beanstalkd

2.启动beanstalked

  beanstalkd -l 0.0.0.0 -p 11300

3.composer安装 Pheanstalk 类库

composer require pda/pheanstalk

4.Pheanstalk使用方法

  维护方法

        stats() 查看状态方法

        listTubes() 目前存在的管道

        listTubesWatched() 目前监听的管道

        statsTube() 管道的状态

        useTube() 指定使用的管道

        statsJob() 查看任务的详细信息

        peek() 通过任务ID获取任务

    生产者方法

        putInTube() 往管道中写入数据

        put() 配合useTube()使用

    消费者方法

        watch() 监听管道，可以同时监听多个管道

        ignore() 不监听管道

        reserve() 以阻塞方式监听管道，获取任务

        reserveFromTube()

        release() 把任务重新放回管道

        bury() 把任务预留

        peekBuried() 把预留任务读取出来

        kickJob() 把buried状态的任务设置成ready

        kick() 批量把buried状态的任务设置成ready

        peekReady() 把准备好的任务读取出来

        peekDelayed() 把延迟的任务读取出来

        pauseTube() 给管道设置延迟

        resumeTube() 取消管道延迟

        touch() 让任务重新计算ttr时间，给任务续命

5. Pheanstalk在Thinkphp5演示

生成者

消费者

    第一步，配置command.php文件，目录在application/command.php

    第二步，建立命令类文件，新建application/beanstalkd/command/Test.php

    第三步，执行 php think test  启动命令

6.使用Supervisor管理Beanstalkd 和  php think test 进程

    6.1 安装Supervisor:  yum install supervisor