PHP 模拟开发 单进程阻塞网络服务器 -理解swoole实现

1 单进程阻塞网络服务器

一个连接-请求-阻塞-返回数据

原理 ：创建-绑定-监听-接收请求-回复-逻辑处理-关闭

说明：

1、创建一个socket，绑定服务器端口（bind），监听端口（listen），在PHP中用stream_socket_server一个函数就能完成上面3个步骤

2、进入while循环，阻塞在accept操作上，等待客户端连接进入。此时程序会进入睡眠状态，直到有新的客户端发起connect到服务器，操作系统会唤醒此进程。accept函数返回客户端连接的socket

3、利用fread读取客户端socket当中的数据收到数据后服务器程序进行处理然后使用fwrite向客户端发送响应。长连接的服务会持续与客户端交互，而短连接服务一般收到响应就会close。

缺点：

1、一次只能处理一个连接，不支持多个连接同时处理

 

每个连接进入到我们的服务端的时候,单独创建一个进程/线程提供服务

<?php
//多个客户端发起请求，观察服务端状态
//ab -n 请求数 -c 并发数 -k 保持连接
 class Worker{
     //监听socket
     protected $socket = NULL;
     //连接事件回调
     public $onConnect = NULL;
     //接收消息事件回调
     public $onMessage = NULL;
     public function __construct($socket_address) {
        //监听地址+端口 相当于socket 绑定监听
         $this->socket = stream_socket_server($socket_address);
     }

     public function start() {
        while (true){

         $clientSocket = stream_socket_accept($this->socket); //阻塞监听

         if(!empty($clientSocket) && is_callable($this->onConnect)){
             //有客户端进来
             call_user_func($this->onConnect,$clientSocket); //连接建立成功触发
         }
         //从连接当中读取客户端内容
         $buffer = fread($clientSocket,65535); //缓冲区
         //正常读取到数据，触发消息接收事件，响应内容
         if(!empty($buffer) && is_callable($this->onRecive)){
             call_user_func($this->onRecive,$clientSocket,$buffer);
         }
        fclose($clientSocket);
        }

     }
 }



$worker = new Worker('tcp://0.0.0.0:9812');

 //事件
$worker->onConnect = function ($fd) {
        echo '连接事件触发'.(int)$fd.PHP_EOL;
};
$worker->onRecive = function ($conn, $message) {
    //事件回调当中写业务逻辑
    var_dump($conn,$message);
    //http 响应头
    $content = '响应http了';
    $http_resonse = "HTTP/1.1 200 OK\r\n";
    $http_resonse .= "Content-Type: text/html;charset=UTF-8\r\n";
    $http_resonse .= "Connection: keep-alive\r\n"; //连接保持
    $http_resonse .= "Server: php socket server\r\n";
    $http_resonse .= "Content-length: ".strlen($content)."\r\n\r\n";
    $http_resonse .= $content;
    fwrite($conn, $http_resonse);

};

$worker->start();