yylh/client

['异步','事件驱动','套接字','客户端','流包装器']

维护者

详细信息

github.com/alwaysLinger/client

源代码

问题

安装: 0

依赖项: 0

建议者: 0

安全: 0

星标: 2

关注者: 1

分支: 0

公开问题: 0

v0.0.1 2022-03-16 18:01 UTC

Requires

  • php: >=8.0,<8.2
  • ext-event: >=2.5.5

Requires (Dev)

MIT 76be399e4b26423febf16d1fe92b6e498a120471

This package is auto-updated.

Last update: 2024-09-29 06:08:44 UTC

README

安装说明

composer require yylh/client

用法

# client
$c = new Client('stream://127.0.0.1:9527');

$c->onConnect(function (Client $client) {
    dump($client);
});
$c->onReceive(function (Client $client, string $payload) {
    dump($payload);
    $client->send('client echo');
});

$c->start();

# server
$server = new Swoole\Server('127.0.0.1', 9527);

$server->set([
    'open_length_check' => true,
    'package_length_type' => 'N',
    'package_length_offset' => 0,
    'package_body_offset' => 4,
]);

$server->on('connect', function ($server, $fd) {
    echo "connection open: {$fd}\n";
    $data = 'server echo';
    $pp = pack('N', strlen($data)) . $data;
    $server->send($fd, $pp);
});

$server->on('receive', function ($server, $fd, $reactor_id, $data) {
    var_dump('recv:' . substr($data, 4));
    $data = '123123123123';
    $pp = pack('N', strlen($data)) . $data;
    $server->send($fd, $pp);
});

$server->on('close', function ($server, $fd) {
    echo "connection close: {$fd}\n";
});

$server->start();