PHPackages wzhanjun/think-queue-rabbitmq - PHPackages - PHPackages [Skip to content](#main-content)[PHPackages](/)[Directory](/)[Categories](/categories)[Trending](/trending)[Leaderboard](/leaderboard)[Changelog](/changelog)[Analyze](/analyze)[Collections](/collections)[Log in](/login)[Sign up](/register) 1. [Directory](/) 2. / 3. [Queues & Workers](/categories/queues) 4. / 5. wzhanjun/think-queue-rabbitmq ActiveThink-extend[Queues & Workers](/categories/queues) wzhanjun/think-queue-rabbitmq ============================= 为 ThinkPHP5.0 队列增加 RabbitMQ 驱动 v0.1.0(5y ago)09Apache-2.0PHPPHP >=7.1 Since Nov 20Pushed 5y agoCompare [ Source](https://github.com/wzhanjun/think-queue-rabbitmq)[ Packagist](https://packagist.org/packages/wzhanjun/think-queue-rabbitmq)[ RSS](/packages/wzhanjun-think-queue-rabbitmq/feed)WikiDiscussions master Synced 1mo ago READMEChangelogDependencies (3)Versions (3)Used By (0) think-queue-rabbitmq for ThinkPHP5.0 ==================================== [](#think-queue-rabbitmq-for-thinkphp50) 本项目基于[jayazhao/think-queue-rabbitmq](https://github.com/jayazhao/think-queue-rabbitmq), 调整原项目适配TP5.0 安装 -- [](#安装) > composer require wzhanjun/think-queue-rabbitmq 配置 -- [](#配置) > 本驱动包基于 `think-queue`，配置文件位于 `config/queue.php` ### 驱动配置 [](#驱动配置) ``` return [ 'connector' => 'jayazhao\\queue\\connector\\RabbitMQ', 'dsn' => env('RABBITMQ_DSN', null), 'host' => env('RABBITMQ_HOST', '127.0.0.1'), 'port' => env('RABBITMQ_PORT', 5672), 'vhost' => env('RABBITMQ_VHOST', '/'), 'login' => env('RABBITMQ_LOGIN', 'guest'), 'password' => env('RABBITMQ_PASSWORD', 'guest'), 'queue' => env('RABBITMQ_QUEUE', 'default'), 'options' => [ 'exchange' => [ 'name' => env('RABBITMQ_EXCHANGE_NAME'), /* * Determine if exchange should be created if it does not exist. */ 'declare' => env('RABBITMQ_EXCHANGE_DECLARE', true), /* * Read more about possible values at https://www.rabbitmq.com/tutorials/amqp-concepts.html */ 'type' => env('RABBITMQ_EXCHANGE_TYPE', \Interop\Amqp\AmqpTopic::TYPE_DIRECT), 'passive' => env('RABBITMQ_EXCHANGE_PASSIVE', false), 'durable' => env('RABBITMQ_EXCHANGE_DURABLE', true), 'auto_delete' => env('RABBITMQ_EXCHANGE_AUTODELETE', false), 'arguments' => env('RABBITMQ_EXCHANGE_ARGUMENTS'), ], 'queue' => [ /* * Determine if queue should be created if it does not exist. */ 'declare' => env('RABBITMQ_QUEUE_DECLARE', true), /* * Determine if queue should be binded to the exchange created. */ 'bind' => env('RABBITMQ_QUEUE_DECLARE_BIND', true), /* * Read more about possible values at https://www.rabbitmq.com/tutorials/amqp-concepts.html */ 'passive' => env('RABBITMQ_QUEUE_PASSIVE', false), 'durable' => env('RABBITMQ_QUEUE_DURABLE', true), 'exclusive' => env('RABBITMQ_QUEUE_EXCLUSIVE', false), 'auto_delete' => env('RABBITMQ_QUEUE_AUTODELETE', false), 'arguments' => env('RABBITMQ_QUEUE_ARGUMENTS'), ], ], /* * Determine the number of seconds to sleep if there's an error communicating with rabbitmq * If set to false, it'll throw an exception rather than doing the sleep for X seconds. */ 'sleep_on_error' => env('RABBITMQ_ERROR_SLEEP', 5), /* * Optional SSL params if an SSL connection is used */ 'ssl_params' => [ 'ssl_on' => env('RABBITMQ_SSL', false), 'cafile' => env('RABBITMQ_SSL_CAFILE', null), 'local_cert' => env('RABBITMQ_SSL_LOCALCERT', null), 'local_key' => env('RABBITMQ_SSL_LOCALKEY', null), 'verify_peer' => env('RABBITMQ_SSL_VERIFY_PEER', true), 'passphrase' => env('RABBITMQ_SSL_PASSPHRASE', null), ], ]; ``` 创建任务类 ----- [](#创建任务类) > 单模块项目推荐使用 `app\job` 作为任务类的命名空间 多模块项目可用使用 `app\module\job` 作为任务类的命名空间 也可以放在任意可以自动加载到的地方 任务类不需继承任何类，如果这个类只有一个任务，那么就只需要提供一个`fire`方法就可以了，如果有多个小任务，就写多个方法，下面发布任务的时候会有区别 每个方法会传入两个参数 `think\queue\Job $job`（当前的任务对象） 和 `$data`（发布任务时自定义的数据） 还有个可选的任务失败执行的方法 `failed` 传入的参数为`$data`（发布任务时自定义的数据） ### 下面写两个例子 [](#下面写两个例子) ``` namespace app\job; use think\queue\Job; class Job1{ public function fire(Job $job, $data){ //....这里执行具体的任务 if ($job->attempts() > 3) { //通过这个方法可以检查这个任务已经重试了几次了 } //如果任务执行成功后 记得删除任务，不然这个任务会重复执行，直到达到最大重试次数后失败后，执行failed方法 $job->delete(); // 也可以重新发布这个任务 $job->release($delay); //$delay为延迟时间 } public function failed($data){ // ...任务达到最大重试次数后，失败了 } } ``` ``` namespace app\lib\job; use think\queue\Job; class Job2{ public function task1(Job $job, $data){ } public function task2(Job $job, $data){ } public function failed($data){ } } ``` 发布任务 ---- [](#发布任务) > `think\Queue::push($job, $data = '', $queue = null)` 和 `think\Queue::later($delay, $job, $data = '', $queue = null)` 两个方法，前者是立即执行，后者是在`$delay`秒后执行 `$job` 是任务名 单模块的，且命名空间是`app\job`的，比如上面的例子一,写`Job1`类名即可 多模块的，且命名空间是`app\module\job`的，写`model/Job1`即可 其他的需要些完整的类名，比如上面的例子二，需要写完整的类名`app\lib\job\Job2` 如果一个任务类里有多个小任务的话，如上面的例子二，需要用@+方法名`app\lib\job\Job2@task1`、`app\lib\job\Job2@task2` `$data` 是你要传到任务里的参数 `$queue` 队列名，指定这个任务是在哪个队列上执行，同下面监控队列的时候指定的队列名,可不填 监听任务并执行 ------- [](#监听任务并执行) > php think queue:listen > php think queue:work --daemon（不加--daemon为执行单个任务） 两种，具体的可选参数可以输入命令加 --help 查看 > 可配合supervisor使用，保证进程常驻 ### Health Score 19 — LowBetter than 10% of packages Maintenance20 Infrequent updates — may be unmaintained Popularity4 Limited adoption so far Community8 Small or concentrated contributor base Maturity39 Early-stage or recently created project Bus Factor1 Top contributor holds 80% of commits — single point of failure How is this calculated?**Maintenance (25%)** — Last commit recency, latest release date, and issue-to-star ratio. Uses a 2-year decay window. **Popularity (30%)** — Total and monthly downloads, GitHub stars, and forks. Logarithmic scaling prevents top-heavy scores. **Community (15%)** — Contributors, dependents, forks, watchers, and maintainers. Measures real ecosystem engagement. **Maturity (30%)** — Project age, version count, PHP version support, and release stability. ### Release Activity Cadence Unknown Total 1 Last Release 1997d ago ### Community Maintainers ![](https://www.gravatar.com/avatar/fccfec2f6b67a9769b2c8a27901e62ebc5333cf3262ae087b5a073a44ab847b5?d=identicon)[wzhanjun](/maintainers/wzhanjun) --- Top Contributors [![wzhanjun](https://avatars.githubusercontent.com/u/15346702?v=4)](https://github.com/wzhanjun "wzhanjun (4 commits)")[![jayazhao](https://avatars.githubusercontent.com/u/13504408?v=4)](https://github.com/jayazhao "jayazhao (1 commits)") --- Tags queuerabbitmqthink-extendthinkphp5 ### Embed Badge ![Health badge](/badges/wzhanjun-think-queue-rabbitmq/health.svg) ``` [![Health](https://phpackages.com/badges/wzhanjun-think-queue-rabbitmq/health.svg)](https://phpackages.com/packages/wzhanjun-think-queue-rabbitmq) ``` ### Alternatives [php-amqplib/php-amqplib Formerly videlalvaro/php-amqplib. This library is a pure PHP implementation of the AMQP protocol. It's been tested against RabbitMQ. 4.6k125.3M871](/packages/php-amqplib-php-amqplib)[php-amqplib/rabbitmq-bundle Integrates php-amqplib with Symfony & RabbitMq. Formerly emag-tech-labs/rabbitmq-bundle, oldsound/rabbitmq-bundle. 1.3k20.1M64](/packages/php-amqplib-rabbitmq-bundle)[bunny/bunny Performant pure-PHP AMQP (RabbitMQ) non-blocking ReactPHP library 7426.5M37](/packages/bunny-bunny)[enqueue/enqueue-bundle Message Queue Bundle 27615.6M38](/packages/enqueue-enqueue-bundle)[enqueue/enqueue Message Queue Library 19820.0M56](/packages/enqueue-enqueue)[bschmitt/laravel-amqp AMQP wrapper for Laravel and Lumen to publish and consume messages 2752.3M7](/packages/bschmitt-laravel-amqp) PHPackages © 2026 [Directory](/)[Categories](/categories)[Trending](/trending)[Changelog](/changelog)[Analyze](/analyze)