PHP+Socket 시리즈의 IO 다중화 및 웹서버 구현-PHP 튜토리얼-php.cn

이 기사는 주로 IO 멀티플렉싱을 소개하는 php+socket에 대한 관련 지식과 php+socket이 웹 서버를 구현하는 방법을 제공합니다. 관심 있는 친구들은 아래를 살펴보시면 모두에게 도움이 되길 바랍니다.

PHP 네이티브 소켓 IO 다중화 및 웹 서버 구현

multiplexing

이전글간단한 서버-클라이언트 통신은 네이티브 소켓을 통해 이루어지지만, 클라이언트가 여러 개인 경우 클라이언트가 연결되면 서버는 첫 번째 클라이언트의 요청만 처리할 수 있지만 후속 클라이언트에 서비스를 제공할 수 없는 이유는 IO 모델이 차단되고 동시에 하나의 클라이언트만 사용할 수 있기 때문입니다. 액세스하려면 두 가지 주요 솔루션이 있습니다. 이 문제 해결:

PHP+Socket 시리즈의 IO 다중화 및 웹서버 구현

다중 프로세스, 즉 서버에서 여러 프로세스를 시작하여 모니터링

N 클라이언트 사용을 간단히 구현하는 IO 다중화 메커니즘 하나의 네트워크 케이블을 통한 동시 액세스
동시 멀티플렉싱은select와epoll이라는 두 가지 모델로 나뉩니다. 일반적인 소프트웨어에서Apache는select모델을 사용합니다. ,nginx는epoll모델을 사용합니다. PHP에는select모델이 내장되어 있으며 해당 함수는socket_select입니다. 멀티플렉싱은 먼저 http 서버
구문
을 구현하는 기초입니다. 이 기사에서는 PHP 네이티브 소켓에select모델을 구현하는 내장socket_select함수가 있음을 소개했습니다. 해당 구문은 다음과 같습니다.

socket_select( array &$read, array &$write, array &$except, int $seconds [, int $microseconds = 0]): int|false

로그인 후 복사

매개변수

readselect与epoll，常见的软件中，Apache使用了select模型，nginx则使用epoll模型。在 php 中内置了select模型，对应的函数为socket_select，多路复用是实现 http 服务器的基础

语法

在前文中我们介绍了 php 原生 socket 内置了socket_select函数实现了select模型，其语法如下：


        
         로그인 후 복사

参数

read
服务端监听的套接字资源，当他有变化（即收到新的消息或有客户端连接、断开）时，socket_select函数才会返回（否则继续阻塞），同时修改该变量为当前发生事件（收到消息或有客户端连接、断开）的套接字资源列表，并继续向下执行。
write
监听是否有客户端写数据，传入null则代表不关心是否有写变化
except
套接字内要排除的元素，传入null是「监听」全部
seconds
秒和微秒一起构成超时参数。如果传入null则会阻塞，为 0 非阻塞，如果是 >0 则为最大阻塞时间
microseconds

优化

我们在上篇文章简单实现了 socket 服务端监听与客户端的连接，接下来我们在服务端监听代码的基础上通过多路复用优化代码：

this is php worker'; $len = strlen($output); $response = "HTTP/1.1 200 OK\r\n"; $response .= "content-type: text/html\r\n"; $response .= "server: php socket\r\n"; $response .= "Content-Length: {$len}\r\n\r\n"; $response .= $output; socket_write($sock, $response); } } }

로그인 후 복사

在本示例中socket_select函数会阻塞当前进程，当$tmp_sockets数组内的 socket 资源有新的客户端连接或断开或收到新消息时，会将$tmp_sockets数组修改为当前活跃的 socket 资源，随后通过遍历该数组处理业务逻辑

PHP+Socket 시리즈의 IO 다중화 및 웹서버 구현

使用socket实现简易http服务器

http 协议是在 socket 的基础上规定了指定的数据格式，所以我们只需在socket_write时按照格式发送数据，浏览器就可正常响应请求

GET / HTTP/1.1 Host: 124.222.**.**:8888 Connection: keep-alive Cache-Control: max-age=0 Upgrade-Insecure-Requests: 1 User-Agent: Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/101.0.0.0 Safari/537.36 Accept: text/html,application/xhtml+xml,application/xml;q=0.9,image/avif,image/webp,image/apng,*/*;q=0.8,application/signed-exchange;v=b3;q=0.9 Accept-Encoding: gzip, deflate Accept-Language: zh-CN,zh;q=0.9 Cookie: jenkins-timestamper-offset=-28800000; _ga=GA1.1.1403944751.1652010033; _ga_2GM6102E19=GS1.1.1652802985.7.1.1652803014.0

로그인 후 복사

在服务端运行此示例，随后在浏览器访问ip:8888，可以看到如下：

PHP+Socket 시리즈의 IO 다중화 및 웹서버 구현

同时服务端会输出如下内容：

rrreee

该内容即为用户端请求原始数据，可解析此数据并根据请求做出响应，比如使用file_get_content

서버에서 모니터링하는 소켓 리소스입니다. 변경되면(즉, 새 메시지가 수신되거나 클라이언트가 연결되거나 연결이 끊어지는 경우) 소켓_선택함수는 반환할 것이며(그렇지 않으면 계속 차단됩니다) 동시에 현재 이벤트(수신된 메시지 또는 클라이언트 연결 또는 연결 끊김)의 소켓 리소스 목록에 대한 변수를 수정하고 계속 실행합니다. 하향의.

write

클라이언트가 데이터를 쓰는지 여부를 모니터링합니다. null을 전달하면 쓰기 변경 사항이 있는지 상관하지 않는다는 뜻입니다

Except code> 소켓에서 제외될 요소, null전달은 "수신"입니다. 모두
       초초와 마이크로초를 함께 구성합니다. 시간 초과 매개변수.
       null이 전달되면 차단되고, 0이면 차단되지 않습니다.>0이면 최대 차단 시간이 됩니다
       마이크로초
       최적화우리는
       이전 기사 서버는 클라이언트와의 연결을 모니터링합니다. 다음으로 서버 모니터 코드를 기반으로 멀티플렉싱을 통해 코드를 최적화합니다. rrreee이 예에서는socket_select함수는$tmp_sockets배열의 소켓 리소스에 새로운 클라이언트 연결 또는 연결 끊김이 있거나 새 메시지를 수신할 때$tmp_sockets배열을 차단합니다. 현재 활성 소켓 리소스로 수정한 다음 배열을 순회하여 비즈니스 로직을 처리합니다
        소켓을 사용하여 간단한 http 서버 구현http 프로토콜은 소켓을 기반으로 지정된 데이터 형식을 지정하므로socket_write, 그러면 브라우저가 정상적으로 작동합니다. rrreee 요청에 대한 응답으로 이 예제를 서버에서 실행한 후 브라우저에서ip:8888에 액세스하면 다음을 볼 수 있습니다. :동시에 서버는 다음 콘텐츠를 출력합니다: rrreee 이 콘텐츠는 클라이언트 요청 원시 데이터입니다. 이 데이터를 구문 분석하고file_get_content를 사용하여 요청에 따라 응답할 수 있습니다. 지정된 파일 내용을 브라우저로 반환합니다추천 학습: "PHP 비디오 튜토리얼"
       위 내용은 PHP+Socket 시리즈의 IO 다중화 및 웹서버 구현의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!