php实现的简单多进程服务器类完整示例

深入PHP实现的简单多进程服务器类

在这个技术横飞的时代，PHP多进程服务器的应用越来越广泛。本文将通过实例，带您了解如何使用PHP创建一个简单的多进程服务器。

让我们定义一个名为“server”的类。这个类将包含一些基本属性，如端口和IP地址。在构造函数中，我们将创建一个通讯节点，准备接收客户端的连接。

当客户端尝试连接服务器时，我们的服务器将监听并接收连接请求。一旦接收到数据，服务器就会创建一个子进程来处理该请求。这个过程非常类似于现实中的多线服务场景，主服务员（父进程）在接待新的顾客（客户端连接）时，会呼叫服务员（子进程）来专门处理这个顾客的需求。

下面是代码的核心部分：

```php

class server {

public $port;

public $ip;

protected $server; // 用于存储服务器套接字的变量

public function __construct($ip = '0.0.0.0', $port) { // 构造函数初始化服务器设置

$this->ip = $ip; // 设置IP地址

$this->port = $port; // 设置端口号

$this->createSocket(); // 创建通讯节点，准备接收客户端连接

}

public function listen($callback) { // 监听客户端连接并处理请求的函数

if(!is_callable($callback)){ // 检查传递的回调是否可调用，确保传递正确的参数类型

throw new Exception('请传递正确的参数类型');

}

// 当有客户端连接时，我们创建一个子进程来处理这个连接

while ($client = socket_accept($this->server)) { // 等待客户端接入请求的连接

$buf = socket_read($client, 1024); // 从客户端读取数据内容

$pid = pcntl_fork(); // 创建子进程来处理这个连接的数据请求

if ($pid == -1) { // 如果创建子进程失败，则输出错误信息并终止程序运行

die('无法创建子进程');

```php

class ServerHandler {

protected $server;

protected $ip;

protected $port;

protected $callback;

public function __construct($ip, $port, $callback) {

$this->ip = $ip;

$this->port = $port;

$this->callback = $callback;

$this->createSocket();

}

protected function createSocket() {

$this->server = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);

socket_set_option($this->server, SOL_SOCKET, SO_REUSEADDR, 1);

socket_bind($this->server, $this->ip, $this->port);

socket_listen($this->server);

}

public function handleRequests() {

while (true) {

$client = socket_accept($this->server); //等待客户端接入

$buf = socket_read($client, 1024); //读取客户端发送的数据

//协议过滤和请求处理

if ($this->checkRule($buf)) {

//允许进一步处理请求

$response = call_user_func($this->callback, $buf); //回调用户定义的函数处理请求

$this->response($response, $client); //发送响应给客户端

usleep(1000); //延迟以控制响应速度

} else {

//关闭连接，可能是因为协议不匹配或其他错误

socket_close($client);

}

}

}

protected function checkRule($buf) {

//这里可以定义更复杂的规则检查逻辑，例如基于正则表达式匹配协议或内容等。

//示例中仅包含简单的协议过滤，可以根据实际需求进行扩展。

if (preg_match("/sleep/i", $buf)) { //检查是否包含休眠指令（示例）

return true; //返回匹配结果或进一步处理的数据（如有必要）

} else if (empty($buf) || !preg_match("/GET\s.?HTTP\/1.1/i", $buf)) { //检查是否为有效的HTTP GET请求（示例）

return false; //返回非匹配结果或相应的错误信息（如有必要）

} else { //其他情况，继续处理请求或返回默认响应（如有必要）

return true; //根据实际需求进行调整，例如进一步处理请求内容等。

}

}

protected function response($content, $client) {

//构建HTTP响应并发送给客户端（示例）

$responseString = "HTTP/1.1 200 OK\r"; //设置HTTP状态码为200 OK（示例）

$responseString .= "Content-Type: text/html;charset=utf-8\r"; //设置内容类型和字符集（示例）

$responseString .= "Content-Length: " . strlen($content) . "\r\r"; //设置内容长度（示例）