对socket的代码学习和自我理解与记录epoll模式

Z时代
2024-01-10
分类：综合

epoll模式 主要就是直接对socket进行监听，不需要轮询，如果socket有状态变化就会触发
<?php
class Worker{
    //监听socket
    protected $socket = NULL;
    //连接事件回调
    public $onConnect = NULL;
    //接收消息事件回调
    public $onMessage = NULL;
    public $workerNum=4; //子进程个数
    public  $allSocket; //存放所有socket
    public function __construct($socket_address) {
        //监听地址+端口
        $this->socket=stream_socket_server($socket_address);
    }
    public function start() {
        //获取配置文件
        $this->fork();
    }
    public function fork(){
        $this->accept();//子进程负责接收客户端请求
    }
    public  function  accept(){
        //第一个需要监听的事件(服务端socket的事件),一旦监听到可读事件之后会触发
        swoole_event_add($this->socket,function ($fd){
                $clientSocket=stream_socket_accept($fd);
                //触发事件的连接的回调
                if(!empty($clientSocket) && is_callable($this->onConnect)){
                    call_user_func($this->onConnect,$clientSocket);
                }
            //监听客户端可读
            swoole_event_add($clientSocket,function ($fd){
                //从连接当中读取客户端的内容
                $buffer=fread($fd,1024);
                //如果数据为空，或者为false,不是资源类型
                if(empty($buffer)){
                    if(feof($fd) || !is_resource($fd)){
                        //触发关闭事件
                        fclose($fd);
                    }
                }
                //正常读取到数据,触发消息接收事件,响应内容
                if(!empty($buffer) && is_callable($this->onMessage)){
                    call_user_func($this->onMessage,$fd,$buffer);
                }
            });
        });
        echo "非阻塞";
die("eee");
    }
}
$worker = new Worker("tcp://0.0.0.0:9801");
//连接事件
$worker->onConnect = function ($fd) {
    //echo "连接事件触发",(int)$fd,PHP_EOL;
};
//消息接收
$worker->onMessage = function ($conn, $message) {
    $content="123";
    $http_resonse = "HTTP/1.1 200 OK
";
    $http_resonse .= "Content-Type: text/html;charset=UTF-8
";
    $http_resonse .= "Connection: keep-alive
"; //连接保持
    $http_resonse .= "Server: php socket server
";
    $http_resonse .= "Content-length: ".strlen($content)."
";
    $http_resonse .= $content;
    fwrite($conn, $http_resonse);
};
$worker->start(); //启动