第一次听说端口复用是在mixphp最新版本中发现的,mixphp启动监听9501端口,现在作者说可以多开几个进程来执行mixphp,我心里想了下再启动不是会端口冲突嘛,但是却没有问题,于是下载mixphp的源码解读,原来是启动http服务器使用new Co\Http\Server('0.0.0.0', 80, false, true); swoole这个http构造方法第4个参数是是否开启端口复用,这样就能多个进程来监听相同端口。底层负载调度由linux自动处理。切记需要linux3.10以上内核才支持。我们来做个试验。
【一】.基于swoole的端口复用
(1).创建t1.php:监听80端口
go(function () {
$server = new Co\Http\Server('0.0.0.0', 80, false, true);
$server->handle('/', function ($request, $response) {
$response->end("<h1>T1 is work!</h1>");
echo 'replay from T1' . PHP_EOL;
});
$server->start();
});(2).创建t2.php:监听80端口
go(function () {
$server = new Co\Http\Server('0.0.0.0', 80, false, true);
$server->handle('/', function ($request, $response) {
$response->end("<h1>T2 is work!</h1>");
echo 'replay from T2' . PHP_EOL;
});
$server->start();
});(3).通过ab.exe并发请求:
./ab.exe -n 1000 -c 1000 http://127.0.0.1/
(4).查看服务器php脚本输出:
replay from T2 replay from T1 replay from T2 replay from T1 replay from T1 replay from T2 replay from T1 replay from T2 replay from T1
(5).关闭t1脚本继续访问80端口:
replay from T2 replay from T2 replay from T2
通过上面的验证我们可以知道端口复用能够提高多核利用率,提高socket的处理能力,同时也实现了高可用,一个进程意外退出,其他继续工作,不需要重新建立socket句柄。另外端口重用解决了端口占用不能及时释放的问题,不释放我们可以直接重用。
【二】.基于原生socket的端口复用
(1).创建w1.php:监听8484端口
// 设置IP
$host = '0.0.0.0';
// 设置端口
$port = 8484;
// 创建socket
$listen_socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
// 设置端口复用
socket_set_option($listen_socket, SOL_SOCKET, SO_REUSEPORT, 1);
// 绑定端口
socket_bind($listen_socket, $host, $port);
// 监听socket
socket_listen($listen_socket);
// 事件轮询
while (true)
{
// 客户端
$client = socket_accept($listen_socket);
// 向客户端发送消息
$msg = "This is w1\r\n";
// 记录响应来自哪个进程
echo 'replay from W1' . PHP_EOL;
//发送消息
socket_write($client, $msg, strlen($msg));
//关闭客户端
socket_close($client);
}
socket_close($listen_socket);(2).创建w2.php:监听8484端口
// 设置IP
$host = '0.0.0.0';
// 设置端口
$port = 8484;
// 创建socket
$listen_socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
// 设置端口复用
socket_set_option($listen_socket, SOL_SOCKET, SO_REUSEPORT, 1);
// 绑定端口
socket_bind($listen_socket, $host, $port);
// 监听socket
socket_listen($listen_socket);
// 事件轮询
while (true)
{
// 客户端
$client = socket_accept($listen_socket);
// 向客户端发送消息
$msg = "This is w2\r\n";
// 记录响应来自哪个进程
echo 'replay from W2' . PHP_EOL;
//发送消息
socket_write($client, $msg, strlen($msg));
//关闭客户端
socket_close($client);
}
socket_close($listen_socket);(3).并发后两个脚本的输出:
replay from W1 replay from W1 replay from W1 replay from W1 replay from W1 replay from W1 replay from W1 replay from W1 replay from W1 replay from W2 replay from W2 replay from W2 replay from W2 replay from W2 replay from W2 replay from W2 replay from W2 replay from W2 replay from W2 replay from W2
Linux底层会自动负载均衡。
注意事项:
linux内核必须大于等于3.10以上
windows下的php原生socket不支持端口复用。
windows下的linux子系统wsl1暂时对内核实现不完整,测试不出负载调度效果。
<!doctype html> <html> <head> <meta charset="utf-8"> <title>demo</title> </head> <bod...
php多进程应用场景主要是非web端,fpm下是不支持多进程的,非类linux操作系统都不支持,请在cli模式使用.可以使用多进程做任务分发,批量计算,批量文件处理,批量爬虫,网络运维等等。下面看一份简单的入门demo//创建子进程 $pid=pcntl_fork(); //返回-1,创建失败,不...
php官方的超全局变量$_SERVER['PHP_SELF']也能直接获取,只不过如果url参数太多也会获取。下面提供一个方法获取/* * 获取当前PHP文件名称 */ if (!function_exists('phpself...
(1).config.php 配置文件<?php /** * RabbitMQ_Config */ $config = [ 'host' => ...
最近在公司开发一个新的项目假设项目域名是a.com,需要接入b.com的单点登陆系统。(1).首先我们会在a.com的登陆页面用iframe引入b.com来显示登陆界面,实际上登陆验证操作都是在b.com上面(2).当b.com验证通过,会在前端ajax请求a.com的回调地址,这个回调地址目的就是...
php生成器的方法getReturn获取生成器迭代完成后的返回值,当生成器迭代完成会将生成器的返回值返回,因此如果迭代器未进行迭代是获取不到值的,如果你没有return值则返回null,参考代码:<?php function G1() { &nbs...