PHPackages xskit/laravel-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. xskit/laravel-rabbitmq AbandonedArchivedLibrary[Queues & Workers](/categories/queues) xskit/laravel-rabbitmq ====================== 采用laravel queue的方式监听 RabbitMQ 消息，完成 分布式 服务的通信功能。 2.2.0(7y ago)678MITPHPPHP ^7.1.3 Since May 24Pushed 7y ago1 watchersCompare [ Source](https://github.com/xskit/laravel-rabbitmq)[ Packagist](https://packagist.org/packages/xskit/laravel-rabbitmq)[ RSS](/packages/xskit-laravel-rabbitmq/feed)WikiDiscussions master Synced 3w ago READMEChangelogDependencies (7)Versions (9)Used By (0) 安装 -- [](#安装) ``` composer require xskit/laravel-rabbitmq ``` 使用方法 ---- [](#使用方法) ### Laravel [](#laravel) 安装后使用 Laravel 自动发现,包将自动注册自己。 ### Lumen [](#lumen) 对于Lumen的使用，服务提供者应该手动注册，`bootstrap/app.php` 如下面所示: ``` $app->register(XsKit\LaravelRabbitMQ\RabbitMQServiceProvider::class); ``` ### 配置 [](#配置) 修改配置可以根据 `config/queue.php` 配置到 `.env`文件中，或者添加配置到 `config/queue.php` 进行配置修改 ### 队列监听，开始消费消息 [](#队列监听开始消费消息) - 使用方式 ``` $ php artisan rabbitmq:work [options] [--] [] [--routing=] [--no-ack] ``` - 查看help ``` $ php artisan rabbitmq:work --help ``` **选项** \--queue\[=QUEUE\] 工作队列名 \--routing\[=ROUTING\] 消息路由 \--no-ack 关闭消息确认 \--daemon 以守护进程模式运行工作程序 (弃用) \--once 只处理队列上的下一个作业 \--delay\[=DELAY\] 延迟失败作业的秒数 \[default: "0"\] \--force 强制在维护模式下运行 \--memory\[=MEMORY\] 内存限制，以 M 为单位( \[default: "128"\] \--sleep\[=SLEEP\] 没有工作时睡觉的秒数 \[default: "3"\] \--timeout\[=TIMEOUT\] 子进程可以运行的秒数 \[default: "60"\] \--tries\[=TRIES\] 在记录作业失败之前尝试该作业的次数 \[default: "0"\] 消息处理的方式 ------- [](#消息处理的方式) - 消息确认机制的说明，与 Laravel 队列 Job 的处理保持一致 - Job 执行失败时，自动确认消息后进行消息重发 - Job 执行成功时，消息自动确认 - 在 Job 中 主动删除消息，就可以确认进行消息确认 ``` $job->delete(); ``` Laravel 使用示例 ------------ [](#laravel-使用示例) - 场景一 - 后台处理长时任务 1. 创建 laravel 队列任务，发布到 RabbitMQ （默认配置连接名：rabbitmq）连接。使用说明可查看 [Laravel 官方手册](https://laravel.com/docs/5.8/queues)。 2. 区别在执行队列监听命令： ``` // 连接到 rabbitmq ,监听 default 队列 ，接收当前队列名为路由的消息 $ php artisan rabbitmq:work ``` - 场景二 - 分布式消息处理，例如： - 在 A 项目上发布作业，名为 OneJob： ``` $ php artisan make:job OneJob ``` 产生并修改如下： ``` namespace App\Jobs\OneJob use Illuminate\Bus\Queueable; use Illuminate\Queue\SerializesModels; use Illuminate\Queue\InteractsWithQueue; use Illuminate\Contracts\Queue\ShouldQueue; use Illuminate\Foundation\Bus\Dispatchable; use XsKit\LaravelRabbitMQ\Contracts\PublishJobContract; use XsKit\LaravelRabbitMQ\Contracts\QueueNotDeclare; class OneJob extends PublishJobContract implements QueueNotDeclare { use Dispatchable, InteractsWithQueue, Queueable, SerializesModels; public $data; public function __construct($data) { //定义连接到队列 rabbitmq 发送路由：b.queue $this->onConnection('rabbitmq')->onQueue('b.queue'); $this->$data = $data; } } ``` - 在 B 项目上接收处理作业，创建一样的同名job： - 第一步 ``` $ php artisan make:job OneJob ``` - 第二步 ，产生并修改如下： ``` namespace App\Jobs\OneJob use Illuminate\Bus\Queueable; use Illuminate\Queue\SerializesModels; use Illuminate\Queue\InteractsWithQueue; use Illuminate\Contracts\Queue\ShouldQueue; use Illuminate\Foundation\Bus\Dispatchable; use XsKit\LaravelRabbitMQ\Contracts\ConsumeJobContract; class OneJob extends ConsumeJobContract { use Dispatchable, InteractsWithQueue, Queueable, SerializesModels; public $data; public function handle($data) { //在这里处理你的业务 } } ``` - 第三步，启动消息者消息处理进程： ``` # 处理 队列名为default ,接收 b.queue 路由消息 $ php artisan rabbitmq:work --routing=b.queue ``` ### Health Score 28 — LowBetter than 52% of packages Maintenance20 Infrequent updates — may be unmaintained Popularity14 Limited adoption so far Community7 Small or concentrated contributor base Maturity60 Established project with proven stability Bus Factor1 Top contributor holds 100% 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 Every ~5 days Total 8 Last Release 2557d ago Major Versions 1.1.0 → 2.1.02019-05-24 1.x-dev → 2.2.02019-06-27 PHP version history (2 changes)2.0.3PHP ^7.1.3 1.0.5PHP ^7.1 ### Community Maintainers ![](https://avatars.githubusercontent.com/u/1817715?v=4)[xingshun](/maintainers/xingshun)[@xingshun](https://github.com/xingshun) --- Top Contributors [![xskit](https://avatars.githubusercontent.com/u/12838078?v=4)](https://github.com/xskit "xskit (2 commits)") ### Code Quality TestsPHPUnit ### Embed Badge ![Health badge](/badges/xskit-laravel-rabbitmq/health.svg) ``` [![Health](https://phpackages.com/badges/xskit-laravel-rabbitmq/health.svg)](https://phpackages.com/packages/xskit-laravel-rabbitmq) ``` ### Alternatives [psalm/plugin-laravel Psalm plugin for Laravel 3345.1M337](/packages/psalm-plugin-laravel)[illuminate/queue The Illuminate Queue package. 20432.2M1.5k](/packages/illuminate-queue)[rapidez/core Rapidez Core 1822.4k65](/packages/rapidez-core) PHPackages © 2026 [Directory](/)[Categories](/categories)[Trending](/trending)[Changelog](/changelog)[Analyze](/analyze)