bariseser/sqs

PHP aws sqs 封装器。

维护者

详细信息

github.com/bariseser/aws_sqs

源代码

问题

安装: 1

依赖项: 0

建议者: 0

安全性: 0

星标: 0

关注者: 2

分支: 0

公开问题: 0

0.0.4 2022-04-18 13:41 UTC

Requires

Requires (Dev)

MIT c075465ac8f276f68bfb2be417de19b8b15ee757

  • Baris Eser <bariseser.woop@gmail.com>

phpawssqsconsumerpub-subproducer

This package is auto-updated.

Last update: 2024-09-18 18:45:41 UTC

README

contributions welcome Latest Stable Version Total Downloads License

安装

Aws Sqs Wrapper 的安装非常简单。打开终端并运行以下命令

composer require bariseser/sqs

消费消息

$consumer = (new SqsConsumer())
    ->setQueueUrl("https://:4566/000000000000/client_api.fifo");

while (true) {
    $messages = $consumer->messages();
    if (!empty($messages->get('Messages'))) {
        foreach ($messages->get('Messages') as $message) {
            echo $message['Body'].PHP_EOL;
        }
    } else {
        echo "No messages in queue". PHP_EOL;
    }
}

生产消息

$producer = (new SqsConsumer())
    ->setQueueUrl("https://:4566/000000000000/client_api.fifo");
$producer->setMessageBody(json_encode(['title' => "baris eser", 'id' => 12345]))->publish();

获取帮助/联系

贡献

1 - 分支项目

2 - 确保您已安装 Composer（请参阅 Composer 下载说明）

3 - 安装开发依赖项

composer install

4 - 运行测试套件

vendor/bin/phpunit

5 - 向我们发送 Pull Request