xbyter/amqp-rabbitmq

rabbitmq client for php

v1.0.1 2023-06-30 10:05 UTC

Requires

• php: ^7.4 || ^8.0
• php-amqplib/php-amqplib: ~3.2.0

Requires (Dev)

• phpunit/phpunit: ^6.5.6 || ^7.0 || ^9.6

MIT

• rabbitmq
• AMQP
• rabbit
• php-amqp
• rabbitmq-client
• amqp-client
• php-rabbitmq

README

说明

该库对php-amqplib做了层封装，使得业务上使用更加简便。原生态编写，可以支持各类框架。

示例

详见examples/run.php

/** 以下是示例，根据实际情况可使用依赖注入，supervisor等方式优化 **/

$configs = require "examples/amqp.config.php";

$consumers = $configs['consumers'];
$connections = $configs['connections'];

//创建连接管理器
$connectionManage = \Examples\ConnectionManageBuilder::buildFromConnections($connections);

//创建exchange和queue并绑定他们之间的关系
$declarer = new \Xbyter\Amqp\Declarer($connectionManage);
foreach ($connections as $connName => $connConfig) {
    $declarer->setExchanges($connName, $connConfig['declarer']['exchanges'] ?? []);
    $declarer->setQueues($connName, $connConfig['declarer']['queues'] ?? []);
    $declarer->setBinds($connName, $connConfig['declarer']['binds'] ?? []);
}
$declarer->createAndBind();

//发布消息
$producer = new \Xbyter\Amqp\Producer($connectionManage);
$producer->publish(new \Examples\DefaultConn\Producers\DemoProducer('消息参数1', '消息参数2', '...'));

//消费指定消费者消息
$consumer = new \Xbyter\Amqp\Consumer($connectionManage);
$consumer->consume(new \Examples\DefaultConn\Consumers\DemoConsumer());

//启动消费服务（建议使用supervisor等进程管理工具）
$consumerServer = new \Examples\ConsumerServer($consumer);
$consumerServer->run($consumers);