hyssa-dev/hibiken-asynq-client

go hibiken/asynq 客户端

维护者

详细信息

github.com/hyssa-dev/hibiken-asynq-client

源代码

安装: 3

依赖者: 0

建议者: 0

安全性: 0

星标: 0

关注者: 0

分支: 1

0.0.3 2024-08-19 11:30 UTC

Requires

Requires (Dev)

MIT 14901afd2b84b2e53e4bf6bcd2347aa4eee63319

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

This package is not auto-updated.

Last update: 2024-10-01 10:10:34 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 hyssa-dev/hibiken-asynq-client:dev-main

使用

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

示例

namespace HyssaDev\HibikenAsynqClient\Tests;

use Ramsey\Uuid\Uuid;
use HyssaDev\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);
    }
}