PHPackages clearswitch/queue - 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. clearswitch/queue ActiveLibrary[Queues & Workers](/categories/queues) clearswitch/queue ================= base rabbitmq queue 1.2.1(4y ago)012MITPHP Since Aug 13Pushed 4y ago1 watchersCompare [ Source](https://github.com/ClearSwicth/queue)[ Packagist](https://packagist.org/packages/clearswitch/queue)[ RSS](/packages/clearswitch-queue/feed)WikiDiscussions master Synced 1w ago READMEChangelog (2)Dependencies (1)Versions (5)Used By (0) Rabbitmq Queue ============== [](#rabbitmq-queue) \#使用要求 需要 php-amqp 的拓展 需要rabbitmq 的rabbitmq\_delayed\_message\_exchange 的插件 为什么用这个插件：当我们设置每一个消息不同的过期的时候，如：message1(10s过期)；message2(2s过期)；message3(5s过期)； 如果不用这个插件，由于的队列先进先出的原则，就算message2先过期，他消费的顺序也是message1，message2，message3，但是我们期望的是 message2，message3，message1 这样的顺序去消费，这个插件很好解决这个问题 生产者 创建生产者 ----- [](#创建生产者) ``` use ClearSwicth\Queue\Amqp; /** * 创建生产者 * $rabbitmqInfo=['host'=>'127.0.0.1', 'port'=>'5672', 'user'=>'admin', 'password'=>'123456', 'vhost'=>'qa1'] * 通过选择构造器来设置请求参数的 */ $Amqp=new Amqp($rabbitmqInfo); //设置队列的延迟时间 单位是毫秒级的 $Amqp->setDelayedTime(1000); //设置发送消息体 string $Amqp->setMessage($body); //是否开启开启了限流的功能 参数一表示开启，参数2表示的限流的个数，默认是不开启的 $Amqp->setQos(true, 1); //设置队列的名字 $Amqp->setQueueName($queueName); //最后创建队列 $channel=$Amqp->createChannel(); //当然如果觉得上面的写法太繁琐也可以链式调用 list($channel,$connection)=$Amqp->setDelayedTime($delayedTime)->setMessage($message)->setQueueName($queueName)->createChannel(); ``` 如果需要监听消息是否发送成功 -------------- [](#如果需要监听消息是否发送成功) ``` $Amqp->setConfrim(true);//默认是的false 是不开启comfirm 机制的额 //发送成功是监听这个方法，$msg 是队列返回的一些数据，需要的参数是回调函数，回调函数中的是你的业务逻辑 $Amqp->sendSuccess(function ($msg){ echo $msg->body; }); //发送失败 用法和成功一样 $Amqp->sendFiled(function ($msg){ echo $msg->body; }); ``` 发送消息 ---- [](#发送消息) ``` $Amqp->send(); //同理你也可以循环的发送消息 //需要注意的是$Amqp->setQueueName($queueName)->createChannel()；这两个不能放在循环里面 for($i=0;$isetDelayedTime($delayedTime)->setMessage($message)->send(); } ``` 发送完消息就可以 关闭通道和连接 ---------------- [](#发送完消息就可以-关闭通道和连接) ``` $channel->close(); $connection->close(); ``` 消费者 --- [](#消费者) ``` $Amqp=new Amqp($rabbitmqInfo); //开启消费端的限流 参数1:开启限流，参数2 每次消费的个数 $Amqp->setQos(true,1); //这个是消费者的回调函数，就在这里面处理接受到的消息和队列返回的信息 $callback = function ($message,$channel) { //获得消息的长度 $channel->queue_declare($queueName, true); //获得生产者的生产的消息 $message->getBody(); //消息处理完之后，告诉队列这个消息已经消费进行删除这一条消息 $message->delivery_info['channel']->basic_ack($message->delivery_info['delivery_tag']); //当然当我们进行业务处理的时候，发现消息需要重回队列我们只需 //$message->nack(true);//他对应的是ack() }; //监听者 $Amqp->receive('haha',$callback); **** ``` ### Health Score 24 — LowBetter than 32% of packages Maintenance20 Infrequent updates — may be unmaintained Popularity5 Limited adoption so far Community7 Small or concentrated contributor base Maturity54 Maturing project, gaining track record 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 ~41 days Total 4 Last Release 1614d ago ### Community Maintainers ![](https://avatars.githubusercontent.com/u/47359?v=4)[The Apache Software Foundation](/maintainers/Apache)[@apache](https://github.com/apache) --- Top Contributors [![ClearSwicth](https://avatars.githubusercontent.com/u/47941313?v=4)](https://github.com/ClearSwicth "ClearSwicth (15 commits)") --- Tags rabbitmqdelayed ### Embed Badge ![Health badge](/badges/clearswitch-queue/health.svg) ``` [![Health](https://phpackages.com/badges/clearswitch-queue/health.svg)](https://phpackages.com/packages/clearswitch-queue) ``` ### Alternatives [php-amqplib/rabbitmq-bundle Integrates php-amqplib with Symfony & RabbitMq. Formerly emag-tech-labs/rabbitmq-bundle, oldsound/rabbitmq-bundle. 1.3k20.1M65](/packages/php-amqplib-rabbitmq-bundle)[bschmitt/laravel-amqp AMQP wrapper for Laravel and Lumen to publish and consume messages 2752.3M7](/packages/bschmitt-laravel-amqp)[php-amqplib/thumper AMQP Tools 276210.8k8](/packages/php-amqplib-thumper)[videlalvaro/thumper AMQP Tools 27783.1k3](/packages/videlalvaro-thumper)[mikemadisonweb/yii2-rabbitmq Wrapper based on php-amqplib to incorporate messaging in your Yii2 application via RabbitMQ. Inspired by RabbitMqBundle for Symfony 2, really awesome package. 74262.1k1](/packages/mikemadisonweb-yii2-rabbitmq)[simple-bus/rabbitmq-bundle-bridge Use OldSoundRabbitMQBundle with SimpleBus/AsynchronousBundle 39827.3k4](/packages/simple-bus-rabbitmq-bundle-bridge) PHPackages © 2026 [Directory](/)[Categories](/categories)[Trending](/trending)[Changelog](/changelog)[Analyze](/analyze)