wuwuseo / hibiken-asynq-client

go hibiken/asynq 客户端

维护者

详细信息

github.com/wuwuseo/hibiken-asynq-client

源代码

问题

安装次数: 13

依赖者: 0

建议者: 0

安全: 0

星标: 2

关注者: 0

分支: 1

开放问题: 0

1.0.1 2023-10-07 10:33 UTC

Requires

Requires (Dev)

MIT af0ba7cafc0c6c6065a7ffab43a5b248c62cedc1

  • 五五 <15093565100.woop@163.com>

This package is auto-updated.

Last update: 2024-09-07 12:56:12 UTC

README

这是一个用于在PHP中发送asynq任务的hibiken/asynq GO任务队列的客户端。

其他语言的Asynq客户端问题

hibiken/asynq#105 (评论) hibiken/asynq#105 (评论)

Asynq

https://github.com/hibiken/asynq Asynq是一个用于队列任务并以异步方式使用工作者处理它们的Go库。它由Redis支持，设计得既可扩展又易于开始。

必需的

"php": "^8.1",
"ext-redis": "^5.3",

安装

composer require wuwuseo/hibiken-asynq-client:dev-main

使用

使用客户端将任务放入队列。

示例

namespace Wuwuseo\HibikenAsynqClient\Tests;

use Ramsey\Uuid\Uuid;
use Wuwuseo\HibikenAsynqClient\Client;

class ClientTest extends \PHPUnit\Framework\TestCase
{
    public function testEnqueue()
    {
        $redis = new \Redis();
        $redis->connect('127.0.0.1');
        $clinet = new Client($redis);
        $res = $clinet->Enqueue([
            'typename'=>'newtest:user:xxxx',
            'payload'=>[
                'test'=>'xxxx',
                'user'=>1111
            ],
            'opts'=>[
                'timeout'=>0,
            ]
        ],[
            'queue'=>'test'        
        ]);
        $this->assertTrue($res);
    }
}