amphp/beanstalk

Amp 的异步 beanstalk 驱动器

资助包维护!
amphp

v0.3.2 2020-11-18 08:13 UTC

This package is auto-updated.

Last update: 2024-09-19 03:32:44 UTC


README

Build Status CoverageStatus License

amphp/beanstalk 是一个基于 Amp 的异步 Beanstalk 客户端。

安装

composer require amphp/beanstalk

示例

更详细的代码示例位于 examples 目录中。

<?php

require __DIR__ . '/../vendor/autoload.php';

use Amp\Beanstalk\BeanstalkClient;
use Amp\Loop;

Loop::run(function () {
    $beanstalk = new BeanstalkClient("tcp://127.0.0.1:11300");
    yield $beanstalk->use('sometube');

    $payload = json_encode([
        "job" => bin2hex(random_bytes(16)),
        "type" => "compress-image",
        "path" => "/path/to/image.png"
    ]);

    $jobId = yield $beanstalk->put($payload);

    echo "Inserted job id: $jobId\n";

    $beanstalk->quit();
});

许可

MIT 许可证 (MIT)。请参阅 LICENSE 以获取更多信息。