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
? (编辑:李大同)
【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容!
|