补充：Tcp粘包处理方案-包头+协议

           客户端也需要跟服务器端的同样参数设置

服务器端：swoole\tcpServer2.php

<?php
echo swoole_get_local_ip()['ens33'].":9503\n";
$server = new Swoole\Server("0.0.0.0", 9503);
//设置参数
$server->set([
'open_length_check'     => true,
'package_length_type'   => 'n',
'package_body_offset'   => 2,
'package_length_offset' => 0,
'package_max_length'    => 2 * 1024 * 1024,
]);

$server->on('connect', function ($server, $fd){
echo "connection open: {$fd}\n";
});
$server->on('receive', function ($server, $fd, $reactor_id, $data) {
echo "接收到数据：".$data."\n";
//echo "接收到数据：".$fd."\n";
$server->send($fd, "Swoole: ok\n");
});
$server->on('close', function ($server, $fd) {
echo "connection close: {$fd}\n";
});
$server->start();

客户端：tcpClient2.php

<?php
$client = new Swoole\Client(SWOOLE_SOCK_TCP );
//客户端也需要对应 设置参数 跟服务器端对应起来
$client->set([
'open_length_check'     => true,
'package_length_type'   => 'n',
'package_body_offset'   => 2,
'package_length_offset' => 0,
'package_max_length'    => 2 * 1024 * 1024,
]);
if (!$client->connect('127.0.0.1', 9503, -1)) {
exit("connect failed. Error: {$client->errCode}");
}
//注意，同样还需要pack进行打包
for ($i=0; $i < 10; $i++) {
//$client->send("hello_world_{$i}");
echo "start ====> \n";
$context = "123";
var_dump($context);
//利用Pack打包长度
$len = pack("n",strlen($context));
var_dump($len);//注意，二进制数字打印不出来，可看长度来辨别，确实存在
    //组包
$send=$len. $context;
var_dump($send);//注意，其内的二进制数据打印不出来，可看长度来辨别，确实存在
$client->send($send);
    echo " <==== end \n";
}
echo $client->recv();

打开两个xshell，进入 对应目录，运行服务端及客户端，结果如下：

补充服务器端的几个参数配置

buffer_output_size/output_buffer_size

配置发送输出缓存区内存尺寸。【默认值：2M】

$server->set([
    'buffer_output_size' => 32 * 1024 * 1024, //必须为数字
]);Copy to clipboardErrorCopied

• 提示

  • 单位为字节，默认为 2M，如设置 32 * 1024 * 1024 表示，单次 Server->send 最大允许发送 32M 字节的数据
  • 调用 Server->send，Http\Server->end/write，WebSocket\Server->push 等发送数据指令时，单次最大发送的数据不得超过 buffer_output_size 配置。

worker_num

设置启动的 Worker 进程数。【默认值：CPU 核数】

如 1 个请求耗时 100ms，要提供 1000QPS 的处理能力，那必须配置 100 个进程或更多。
但开的进程越多，占用的内存就会大大增加，而且进程间切换的开销就会越来越大。所以这里适当即可。不要配置过大。

• 提示

  • 如果业务代码是全异步 IO 的，这里设置为 CPU 核数的 1-4 倍最合理
  • 如果业务代码为同步 IO，需要根据请求响应时间和系统负载来调整，例如：100-500
  • 默认设置为 swoole_cpu_num()，最大不得超过 swoole_cpu_num() * 1000
  • 假设每个进程占用 40M 内存，100 个进程就需要占用 4G 内存，

daemonize

守护进程化【默认值：0】

设置 daemonize => 1 时，程序将转入后台作为守护进程运行。长时间运行的服务器端程序必须启用此项。
如果不启用守护进程，当 ssh 终端退出后，程序将被终止运行。

• 提示

  • 启用守护进程后，标准输入和输出会被重定向到 log_file

  • 如果未设置 log_file，将重定向到 /dev/null，所有打印屏幕的信息都会被丢弃

  • 启用守护进程后，CWD（当前目录）环境变量的值会发生变更，相对路径的文件读写会出错。PHP 程序中必须使用绝对路径

  • systemd

    • 使用 systemd 或者 supervisord 管理 Swoole 服务时，请勿设置 daemonize = 1。主要原因是 systemd 的机制与 init 不同。init 进程的 PID 为 1，程序使用 daemonize 后，会脱离终端，最终被 init 进程托管，与 init 关系变为父子进程关系。
    • 但 systemd 是启动了一个单独的后台进程，自行 fork 管理其他服务进程，因此不需要 daemonize，反而使用了 daemonize = 1 会使得 Swoole 程序与该管理进程失去父子进程关系。
    • 
      

案例演示：客户端同上

服务器端：

<?php
echo swoole_get_local_ip()['ens33'].":9503\n";
$server = new Swoole\Server("0.0.0.0", 9503);
//设置参数
$server->set([
'open_length_check'     => true,
'package_length_type'   => 'n',
'package_body_offset'   => 2,
'package_length_offset' => 0,
'package_max_length'    => 2 * 1024 * 1024,
'daemonize'             => 1,//守护进程
    //'buffer_input_size'   => 3 * 1024 * 1024, //设置接收输入缓存区内存大小，默认2M  
    //'worker_num'          => 16, //设置启动的 Worker 进程数。【默认值：CPU 核数】,适合1-4倍，最佳2倍
]);

$server->on('connect', function ($server, $fd){
echo "connection open: {$fd}\n";
});
$server->on('receive', function ($server, $fd, $reactor_id, $data) {
echo "接收到数据：".$data."\n";
//echo "接收到数据：".$fd."\n";
$server->send($fd, "Swoole: ok\n");
});
$server->on('close', function ($server, $fd) {
echo "connection close: {$fd}\n";
});
$server->start();

运行结果如下

服务端后台运行，运行结果仅仅是不显示了，通过ps可以看到，仍在进程中

1.理解linux内核与用户调度

linux内核是硬件与软件之间的一个中间层。 作用是将应用程序的请求传递给硬件，充当底层驱动程序，对系统中的各种设备和组件进行寻址。内核是一个资源管理程序。负责将可用的共享资源(CPU时间、磁盘空间、网络连接等)分配得到各个系统进程。

web项目及swoole的访问结构

用户空间与内核空间

除段：内核空间从接收用户空间指令到开始处理指令，

           内核空间处理指令并返回结果

也就是说，用户空间从传递用户指令，到得到结果，需要等待一定的时间，这个一定的时间，是内核空间接受指令并处理指令这些过程的时间。这个等待的过程，会出现阻塞问题。

2.理解5大网络io模型

23）多路复用模型

24）信号驱动io模型（图不对，待更换）

25）异步io模型

26）五大网络io模型对比

    

{
"name": "jhy/iostarjhy",
"type": "library",
"authors": [
        {
"name": "jhy",
"email": "1195863294@qq.com"
}
    ],
"autoload": {
"psr-4": {
"IoStarJhy\\": "src"
}
    },
"require": {}
}

<?php
namespace IoStarJhy;

class Index
{

public function index()
    {
return "this is index index";
}
}

<?php
require __DIR__."/../vendor";

<?php
require __DIR__."/../vendor/autoload.php";

use IoStarJhy\Index;

echo (new Index())->index();

<?php
echo swoole_get_local_ip()['ens33'].":9503\n";
$server = new Swoole\Server("0.0.0.0", 9503);

$server->on('connect', function ($server, $fd){
echo "connection open: {$fd}\n";
});

$server->on('receive', function ($server, $fd, $reactor_id, $data) {
echo "接收到信息".$data." \n";

});

$server->on('close', function ($server, $fd) {
echo "connection close: {$fd}\n";
});

$server->start();

<?php
//利用php原生函数stream_socket_client与服务端进行连接，这里并没有利用到swoole（new Swoole\Server等形式）
$fp = stream_socket_client("tcp://192.168.204.168:9503");
if (!$fp) {
echo "$errstr ($errno)<br />\n";
} else {
    fwrite($fp, "GET / HTTP/1.0\r\nHost: www.example.com\r\nAccept: */*\r\n\r\n");
    while (!feof($fp)) {
echo fgets($fp, 1024);
}
    fclose($fp);
}

运行结果

  42）服务端利用原生函数连接客户端

<?php
//连接服务端
$client = new Swoole\Client(SWOOLE_SOCK_TCP );

if (!$client->connect('127.0.0.1', 8000, -1)) {
exit("connect failed. Error: {$client->errCode}\n");
}
$client->send("hello world\n");
/*$client->send("hello world\n");
$client->send("hello world\n");
$client->send("hello world\n");*/

echo $client->recv();

$client->close();

<?php
//建立协议服务
$socket = stream_socket_server("tcp://0.0.0.0:8000", $errno, $errstr);
//创建服务和客户和客户连接的socket stream_socket_accept
if (!$socket) {
echo "$errstr ($errno)<br />\n";
} else {
while ($conn = stream_socket_accept($socket)) {
        fwrite($conn, 'The local time is ' . date('n/j/Y g:i a') . "\n");
fclose($conn);
}
    fclose($socket);
}

完