携手老李一起整山寨Workerman（八）

<?php
$host = '0.0.0.0';
$port = 9999;
// 创建一个tcp socket，底层就是对socket() API的封装
// 第一个参数有AF_INET、AF_INET6、AF_UNIX三种，其实分别就是IPv4、IPv6、文件sock的意思
// 第二个参数有SOCK_STREAM、SOCK_DGRAM、SOCK_RAW等五种，这三种比较常见
// SOCK_STREAM就是流式面向连接的可靠协议，TCP就是基于SOCK_STREAM
// SOCK_DGRAM就是数据包、无连接的不可靠协议，UDP基于SOCK_DGRAM
// SOCK_RAW就是最粗暴原始的那种，你要完全手工来控制，你可以做成面向连接，
// 也可以做成无连接，由你掌控，这种用的比较多的是基于SOCK_RAW实现ping
// 第三个参数共有两个值SOL_TCP、SOL_UDP
// 这里提醒一下就是，后两个参数的选择是有关联性的，比如第二个参你用了
// SOCK_STREAM，那么第三个参数记得用SOL_TCP
// 这里值得注意是：$listen_socket实际上就是一个文件描述符了，也就是fd
$listen_socket = socket_create( AF_INET, SOCK_STREAM, SOL_TCP );
// 将socket bind到IP：port上
// 这里实际上还是有一些说法的，我这里结合UNP按照自己理解这么来说：
// 就是将$listen_socket协议捆绑到以$host&$port指定的socket上
// 实际上$listen_socket已经实现了一个本地协议
// bind就是要把这个本地协议绑定到指定的网络socket上
socket_bind( $listen_socket, $host, $port );
// 开始监听socket
socket_listen( $listen_socket );
// 进入while循环，不用担心死循环死机，因为程序将会阻塞在下面的socket_accept()函数上
while( true ){
  // 此处将会阻塞住，一直到有客户端来连接服务器。阻塞状态的进程是不会占据CPU的
  // 所以你不用担心while循环会将机器拖垮，不会的 
  // 此处请你记住阻塞这个词
  $connection_socket = socket_accept( $listen_socket );
  // 从客户端读取信息
  $content = socket_read( $connection_socket, 4096 );
  echo "从客户端获取：{$content}"; 
  // 向客户端发送一个helloworld
  $msg = "helloworld\r\n";
  socket_write( $connection_socket, $msg, strlen( $msg ) );
  socket_close( $connection_socket );
}
// 出于礼貌，记得用完了关闭掉...
socket_close( $listen_socket );

socket_read ( resource $socket , int $length [, int $type = PHP_BINARY_READ ] ) : string

// 第一个参数，好理解
socket
A valid socket resource created with socket_create() or socket_accept().

// 第二个参数，好理解吧？
length
The maximum number of bytes read is specified by the length parameter. Otherwise you can use \r, \n, or \0 to end reading (depending on the type parameter, see below).

// 第三个参数，我们重点关注下
type
Optional type parameter is a named constant:
// 这个是默认的，这种情况下，实际上就相当于调用了系统的recv() API
// 这个函数是二进制安全的
PHP_BINARY_READ (Default) - use the system recv() function. Safe for reading binary data.
// 当遇到\r或\n就会停止
PHP_NORMAL_READ - reading stops at \n or \r.

// 这个函数返回值就是收到内容

socket_recv ( resource $socket , string &$buf , int $len , int $flags ) : int

// 这个参数好说
socket
参数 socket 必须是一个由 socket_create() 创建的socket资源。

// 接受的数据将会保存到buf里来
// 可能有同学没太见过用法，这种方式叫做“ 值-结果 ”参数
buf
从socket中获取的数据将被保存在由 buf 制定的变量中。如果有错误发生，如链接被重置，数据不可用等等， buf 将被设为 NULL。

// 这个我要解释了，似乎就是在侮辱你们
len
长度最多为 len 字节的数据将被接收。

// 很好，这个参数需要重点照顾了
flags
flags 的值可以为下列任意flag的组合。使用按位或运算符(|)来 组合不同的flag。
MSG_OOB       处理超出边界的数据
MSG_PEEK      从接受队列的起始位置接收数据，但不将他们从接受队列中移除。
MSG_WAITALL   在接收到至少 len 字节的数据之前，造成一个阻塞，并暂停脚本运行（block）。但是， 如果接收到中断信号，或远程服务器断开连接，该函数将返回少于 len 字节的数据。
MSG_DONTWAIT  如果制定了该flag，函数将不会造成阻塞，即使在全局设置中指定了阻塞设置。

<?php
$host = '0.0.0.0';
$port = 9999;
// 创建一个tcp socket
$listen_socket = socket_create( AF_INET, SOCK_STREAM, SOL_TCP );
// 将socket bind到IP：port上
socket_bind( $listen_socket, $host, $port );
// 开始监听socket
socket_listen( $listen_socket );
while( true ){
  // 所以你不用担心while循环会将机器拖垮，不会的 
  $connection_socket = socket_accept( $listen_socket );
  // 从客户端读取信息
  // MSG_WAITALL的意思就是“阻塞读取客户端消息”，一只要等足够6个字节长度
  $recv_len = socket_recv( $connection_socket, $recv_content, 6, MSG_WAITALL );
  echo "从客户端获取：{$recv_content}，长度是{$recv_len}".PHP_EOL; 
  // 向客户端发送一个helloworld
  $msg = "helloworld\r\n";
  socket_write( $connection_socket, $msg, strlen( $msg ) );
  socket_close( $connection_socket );
}
socket_close( $listen_socket );

<?php
$host = '0.0.0.0';
$port = 9999;
// 创建一个tcp socket
$listen_socket = socket_create( AF_INET, SOCK_STREAM, SOL_TCP );
// 将socket bind到IP：port上
socket_bind( $listen_socket, $host, $port );
// 开始监听socket
socket_listen( $listen_socket );
while( true ){
  // 所以你不用担心while循环会将机器拖垮，不会的 
  $connection_socket = socket_accept( $listen_socket );
  // 从客户端读取信息
  $total_len = 8;
  $recv_len  = 0;
  $recv_content = ''; 
  // 程序不会阻塞在socket_recv()这里，如果没有收到客户端数据
  // 因为用了MSG_DONTWAIT所以会立马往下执行
  $len = socket_recv( $connection_socket, $content, $total_len, MSG_DONTWAIT );
  // 到了while后，一旦客户端连接上来，就会不断循环
  while ( $recv_len < $total_len ) { 
    $len = socket_recv( $connection_socket, $content, ( $total_len - $recv_len ), MSG_DONTWAIT );
    $recv_len = $recv_len + $len;
    // ⚠️⚠️⚠️⚠️⚠️⚠️⚠️ 如果你想观察 ⚠️⚠️⚠️⚠️⚠️⚠️
    // 你可以人为添加一行sleep(1)来~~~
    echo $recv_len.':'.$total_len.PHP_EOL;
    if ( $recv_len > 0 ) { 
      $recv_content = $recv_content.$content;
    }   
  }
  echo "从客户端获取：{$recv_content}"; 
  // 向客户端发送一个helloworld
  $msg = "helloworld\r\n";
  socket_write( $connection_socket, $msg, strlen( $msg ) );
  socket_close( $connection_socket );
}
socket_close( $listen_socket );