hutong/queue

数据列队

Maintainers

Details

github.com/HuTong/queue

Source

Issues

Installs: 18

Dependents: 0

Suggesters: 0

Security: 0

Stars: 0

Watchers: 2

Forks: 0

Open Issues: 0

dev-master 2017-07-21 05:27 UTC

Requires

  • php: >=7.0.0

MIT 4d39c3f64dcb0dfbccaf0e434d986180a6ace239

  • hutong <hutong0521.woop@163.com>

This package is auto-updated.

Last update: 2025-01-21 19:57:16 UTC

README

数据列队

配置

1、php数组存储
$config = array(
    'type' => 'Arr',
    'host' => '0.0.0.0',
    'port' => '9510',
    'server' => array(
        'worker_num' => 1,
    )
);
2、redis存储
$config = array(
    'type' => 'Redis',
    'host' => '0.0.0.0',
    'port' => '9510',
    'server' => array(
        'worker_num' => 1,
    ),
    'set' => array(
        'host' => '127.0.0.1',
        'port' => '6379',
        'password' => '123456',
        'listName' => 'queueList',
    ),
);
3、SplQueue存储
$config = array(
    'type' => 'Spl',
    'host' => '0.0.0.0',
    'port' => '9510',
    'server' => array(
        'worker_num' => 1,
    )
);

服务端

include './vendor/autoload.php';

$serv = new HuTong\Queue\Server($config);
$serv->listen();

客户端

$config = array(
    'ip' => '127.0.0.1',
    'port' => '9510',
    'timeout' => 2
);

include './vendor/autoload.php';

$client = new HuTong\Queue\Client($config);

for ($i = 0; $i < 100; $i++)
{
    $info = $client->push('N:'.$i);
    var_dump($info);
}

$info = $client->pop();
var_dump($info);

学习交流群

630730920