1.服务器端程序代码
tcp_rver.php
<?php
///创建rver对象,监听 127.0.0.1:9501端口
$rv = new swoole_rver(“127.0.0.1”, 9501);
$rv->t([
’worker_num’ => 4, // worker 进程数,cpu的1-4倍
’max_requestR李廷佑17;=> 10000
]);
// 命令行查看rver开启的worker数
// 如果当前文件名为 tcp_rver.php, 则 ps aft | grep tcp_rver.php
//监听连接进入事件
$rv->on(‘connect’, function ($rv, $fd) {
echo “client: fd:{$fd} connect.\n”;
});
//监听数据接收事件
$rv->on(‘receive’, function ($rv, $fd, $from_id, $data) {
$rv->nd($fd, “rver: fd:{$fd} data:{$data}”);
});
//监听连接关闭事件
$rv->on(‘clo’, function ($rv, $fd) {
echo “client: fd:{$fd} clo.\n”;
});
//启动服管仲和鲍叔牙的故事务器
$rv->start();
2.客户端程序代码
tcp_client.php
<?php
/**
* 创建同步阻塞模式下的tcp客户端
* 同步阻塞模式下connect/nd/recv会等待io完成后再返回,服务端返回后才会向下执行。
* 同步阻塞模式下并不会消耗cpu资源,io操作未完成当前进程会怎么样才能当明星自动转入sleep模式。
* 当io完成后操作系统会唤醒当前进程,继续向下执行代码。
*/
$client = new swoole_client(swoole_tcp);
//连接到服务器
$host = “127.11月你好图片配文字0.0.1”;
$port = 9501;
$timeout = 1; //超过与服务器交互的超时秒数会自动断开
if (!$client->connect($host, $port, $timeout)) {
die(“[connect] failed” . php_eol);
}
//发送数据
$message = “hello world”;
if (!$client->nd($message))幽默段子大全 {
die(“[nd] failed” . php_eol);
}
//接收数据
if (!$data = $client->recv()) {
die(“[recv] failed” . php_eol);
}
echo $data . php_eol;
//关闭连接
$client->clo();
3.服务器端执行程序
php tcp_rver.php
在命令行下运行 php tcp_rver.php 程序,启动成功后可以使用 netstat -an | grep 9501 看到,已经在监听 9501 端口。
4.客户端执行程序
php tcp_client.php
5.服务器端执行结果
client: fd:1 connect.
client: fd:1 clo.
6.客户端执行结果
rver: fd:1 data:hello world
本文发布于:2023-04-08 13:54:01,感谢您对本站的认可!
本文链接:https://www.wtabcd.cn/fanwen/zuowen/7a370863812dffec7b53787b74e8bd06.html
版权声明:本站内容均来自互联网,仅供演示用,请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系,我们将在24小时内删除。
本文word下载地址:swoole的TCP服务.doc
本文 PDF 下载地址:swoole的TCP服务.pdf
留言与评论(共有 0 条评论) |