数据处理器/amqp-async

适用于 PHP 的异步 AMQP 0.9.1 客户端，旨在与 Icicle 一起使用。

维护者

详细信息

github.com/DataProcessors/amqp-async

主页

源代码

问题

安装: 3,533

依赖项: 0

建议者: 0

安全: 0

星标: 13

关注者: 5

分支: 2

开放问题: 0

v1.0.10 2018-02-06 01:16 UTC

Requires

Requires (Dev)

LGPL-2.1 c88d3a2e889e9ef5e9a49e52349a79173e288cab

  • Data Processors

queuerabbitmqmessage

This package is not auto-updated.

Last update: 2024-09-28 18:05:24 UTC

README

Build Status LGPL-2.1 License

amqp-async 是一个为 PHP 实现的 AMQP 0.9.1 协议，旨在与 Icicle 一起使用。

未来可能支持 Amp。

要求
  • PHP 7.0+
安装

推荐使用 Composer 包管理器安装 amqp-async。（有关安装和使用 Composer 的信息，请参阅Composer 安装指南。）

运行以下命令以在项目中使用库

composer require dataprocessors/amqp-async

您还可以手动编辑 composer.json 以将 amqp-async 添加为项目依赖项。

// composer.json
{
    "require": {
        "dataprocessors/amqp-async": "1.0.*"
    }
}

示例

<?php
require_once "vendor/autoload.php";

class Demo {

  public function go() {
    $conn = new DataProcessors\AMQP\AMQPConnection();
    yield $conn->connect('127.0.0.1', 5672, 'guest', 'guest');
    $channel = yield $conn->channel();
    yield $channel->basic_consume('test', '', false, false, false, false,
      function($msg) {
        echo "Got a message\n";
      }
    );
  }

}

$demo = new Demo();
$coroutine = new Icicle\Coroutine\Coroutine($demo->go());
Icicle\Loop\run();

鸣谢

amqp-async 基于 php-amqplib