swoole的TCP服务
发布于2021-03-14 06:11 阅读(1220) 评论(0) 点赞(0) 收藏(4)
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', function ($serv, $fd, $from_id, $data) {
$serv->send($fd, "Server: fd:{$fd} data:{$data}");
});
//监听连接关闭事件
$serv->on('close', function ($serv, $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
所属网站分类: 技术文章 > 博客
作者：叮叮当当
链接：http://www.phpheidong.com/blog/article/3498/3a124912d6d85a195db2/
来源：php黑洞网
任何形式的转载都请注明出处,如有侵权 一经发现 必将追究其法律责任
昵称:
评论内容：(最多支持255个字符)
---无人问津也好，技不如人也罢，你都要试着安静下来，去做自己该做的事，而不是让内心的烦躁、焦虑，坏掉你本来就不多的热情和定力