wandu/q

该包已被弃用，不再维护。没有推荐替代包。

非常简单的队列。

维护者

详细信息

github.com/Wandu/Q

源码

安装数： 2,754

依赖项: 0

推荐者: 1

安全性: 0

星标: 2

关注者: 2

分支: 0

v4.0.0-beta2 2017-07-11 09:07 UTC

Requires

  • php: >=7.0

Suggests

MIT 4f33c112495a583441f06349b7405ca056676ef2

queuewandu

This package is not auto-updated.

Last update: 2022-03-30 02:02:41 UTC

README

Latest Stable Version Latest Unstable Version Total Downloads License

非常简单的队列。

安装

composer require wandu/q

使用

发送者

use Wandu\Q\Adapter\SqsAdapter;
use Wandu\Q\Queue;
use Wandu\Q\Serializer\JsonSerializer;

$sender = new Queue(new JsonSerializer(), new SqsAdapter(
    'xxxxxxxxxxxx', // key
    'xxxxxxxxxxxx', // secret
    'ap-northeast-1', // region
    'https://sqs.ap-northeast-1.amazonaws.com/000000000000/queue-name' // queue url
));
$sender->enqueue([
    'body' => 'kkk',
    '333' => 'halelleknflaksdf',
]);

接收者

use Wandu\Q\Adapter\SqsAdapter;
use Wandu\Q\Queue;
use Wandu\Q\Serializer\JsonSerializer;

$sender = new Queue(new JsonSerializer(), new SqsAdapter(
    'xxxxxxxxxxxx', // key
    'xxxxxxxxxxxx', // secret
    'ap-northeast-1', // region
    'https://sqs.ap-northeast-1.amazonaws.com/000000000000/queue-name' // queue url
));
while (true) {
    $job = $sender->dequeue();
    if ($job) {
        print_r($job->read());
        $job->delete();
    }
    sleep(3);
}

网站