12345678910111213141516171819202122232425262728 |
- <?php
- $serv = new Swoole\Server("0.0.0.0", 9501, SWOOLE_BASE);
- $serv->set(array(
- 'worker_num' => 1,
- 'send_yield' => true,
- 'socket_buffer_size' => 512 * 1024,
- 'kernel_socket_buffer_size' => 65536,
- ));
- $serv->on('connect', function ($serv, $fd) {
- echo "Client:Connect.\n";
- });
- $serv->on('receive', function ($serv, $fd, $reactor_id, $data) {
- $length = 0;
- $size = 1024 * 128;
- while (true)
- {
- $ret = $serv->send($fd, str_repeat('A', $size));
- if ($ret == false) {
- break;
- }
- $length += $size;
- echo "send $length success\n";
- }
- });
- $serv->on('close', function ($serv, $fd) {
- echo "Client: Close.\n";
- });
- $serv->start();
|