swoole的TCP服务

前端之家收集整理的这篇文章主要介绍了swoole的TCP服务前端之家小编觉得挺不错的,现在分享给大家,也给大家做个参考。

1.服务器端程序代码
tcp_server.PHP

<?PHP
///创建Server对象,监听 127.0.0.1:9501端口
$serv = new swoole_server("127.0.0.1",9501);

$serv->set([
  'worker_num' => 4,// worker 进程数,cpu的1-4倍
  'max_request'=> 10000
]);

// 命令行查看server开启的worker数
// 如果当前文件名为 tcp_server.PHP,则 ps aft | grep tcp_server.PHP

//监听连接进入事件
$serv->on('connect',function ($serv,$fd) {
  echo "Client: fd:{$fd} Connect.\n";
});

//监听数据接收事件
$serv->on('receive',$fd,$from_id,$data) {
  $serv->send($fd,"Server: fd:{$fd} data:{$data}");
});

//监听连接关闭事件
$serv->on('close',$fd) {
  echo "Client: fd:{$fd} Close.\n";
});

//启动服务器
$serv->start();

2.客户端程序代码
tcp_client.PHP

<?PHP
/**
* 创建同步阻塞模式下的TCP客户端
* 同步阻塞模式下connect/send/recv会等待IO完成后再返回,服务端返回后才会向下执行。
* 同步阻塞模式下并不会消耗cpu资源,IO操作未完成当前进程会自动转入sleep模式。
* 当IO完成后操作系统会唤醒当前进程,继续向下执行代码
*/
$client = new swoole_client(SWOOLE_TCP);

//连接到服务器
$host = "127.0.0.1";
$port = 9501;
$timeout = 1; //超过与服务器交互的超时秒数会自动断开
if (!$client->connect($host,$port,$timeout)) {
  die("[connect] Failed" . PHP_EOL);
}

//发送数据
$message = "hello world";
if (!$client->send($message)) {
  die("[send] Failed" . PHP_EOL);
}

//接收数据
if (!$data = $client->recv()) {
  die("[recv] Failed" . PHP_EOL);
}
echo $data . PHP_EOL;

//关闭连接
$client->close();

3.服务器端执行程序
PHP tcp_server.PHP

在命令行下运行 PHP tcp_server.PHP 程序,启动成功后可以使用 netstat -an | grep 9501 看到,已经在监听 9501 端口。

4.客户端执行程序
PHP tcp_client.PHP

5.服务器端执行结果
Client: fd:1 Connect.
Client: fd:1 Close.

6.客户端执行结果
Server: fd:1 data:hello world