{"id":297406,"date":"2020-01-20T15:00:31","date_gmt":"2020-01-20T15:00:31","guid":{"rendered":"http:\/\/savepearlharbor.com\/?p=297406"},"modified":"-0001-11-30T00:00:00","modified_gmt":"-0001-11-29T21:00:00","slug":"","status":"publish","type":"post","link":"https:\/\/savepearlharbor.com\/?p=297406","title":{"rendered":"\u0412\u044b\u0442\u0430\u0441\u043a\u0438\u0432\u0430\u0435\u043c \u0432\u0438\u0434\u0435\u043e \u0441 \u043a\u0430\u043c\u0435\u0440\u044b \u043f\u043e DVRIP \u0441 \u043f\u043e\u043c\u043e\u0449\u044c\u044e PHP"},"content":{"rendered":"\n<div class=\"post__text post__text-html\" id=\"post-content-body\" data-io-article-url=\"https:\/\/habr.com\/ru\/post\/484518\/\">\u0412 <a href=\"https:\/\/habr.com\/ru\/post\/482864\/\">\u043f\u0440\u043e\u0448\u043b\u043e\u0439 \u0441\u0442\u0430\u0442\u044c\u0435<\/a> \u044f \u043e\u0431\u0435\u0449\u0430\u043b \u043f\u043e\u043a\u0430\u0437\u0430\u0442\u044c \u0441\u043a\u0440\u0438\u043f\u0442, \u043a\u043e\u0442\u043e\u0440\u044b\u043c \u0442\u044f\u043d\u0443 \u0432\u0438\u0434\u0435\u043e \u0441 \u043a\u0430\u043c\u0435\u0440\u044b \u0438, \u0445\u043e\u0442\u044f \u0441 \u0442\u0435\u0445 \u043f\u043e\u0440 \u043f\u0440\u043e\u0448\u043b\u043e \u0432\u0441\u0435 \u0436\u0435 \u043d\u0435\u043a\u043e\u0442\u043e\u0440\u043e\u0435 \u043a\u043e\u043b\u0438\u0447\u0435\u0441\u0442\u0432\u043e \u0432\u0440\u0435\u043c\u0435\u043d\u0438, \u043e\u0431\u0435\u0449\u0430\u043d\u0438\u044f \u0436\u0435 \u043d\u0443\u0436\u043d\u043e \u0432\u044b\u043f\u043e\u043b\u043d\u044f\u0442\u044c. \u0412\u043e\u0442 \u044f \u0438 \u0432\u044b\u043f\u043e\u043b\u043d\u044f\u044e.<\/p>\n<p>  \u0422\u0430\u043a \u0443\u0436 \u0432\u044b\u0448\u043b\u043e, \u0447\u0442\u043e \u0441 \u0430\u0441\u0438\u043d\u0445\u0440\u043e\u043d\u043d\u043e\u0441\u0442\u044c\u044e \u0432 \u043c\u0438\u0440\u0435 \u0441\u0435\u0440\u0432\u0435\u0440\u043d\u043e\u0433\u043e web \u0430\u0441\u0441\u043e\u0446\u0438\u0438\u0440\u0443\u0435\u0442\u0441\u044f \u0432\u0441\u0435 \u0447\u0442\u043e \u0443\u0433\u043e\u0434\u043d\u043e, \u043d\u043e \u043d\u0435 PHP.<\/p>\n<p>  \u041d\u0443 \u043f\u043e\u0442\u043e\u043c\u0443 \u0447\u0442\u043e, \u043d\u0443 \u0432\u044b \u0437\u043d\u0430\u0435\u0442\u0435, \u0432\u043e\u0442 \u044d\u0442\u0430 \u0443\u043c\u0438\u0440\u0430\u044e\u0449\u0430\u044f \u043c\u043e\u0434\u0435\u043b\u044c, \u0443\u0442\u0435\u0447\u043a\u0438 \u043f\u0430\u043c\u044f\u0442\u0438, \u0434\u0430 \u0438 \u0432\u043e\u043e\u0431\u0449\u0435 \u0432 PHP \u0438\u0437 \u043a\u043e\u0440\u043e\u0431\u043a\u0438 \u043d\u0435\u0442 \u043d\u0438\u0447\u0435\u0433\u043e, \u043a\u0440\u043e\u043c\u0435 <a href=\"https:\/\/www.php.net\/manual\/ru\/function.stream-select.php\">stream_select()<\/a> \u0438 <a href=\"https:\/\/www.php.net\/manual\/ru\/function.stream-select.php\">stream_set_blocking()<\/a>. <\/p>\n<p>  \u0413\u0434\u0435-\u0442\u043e \u0442\u0430\u043c, \u043d\u0430 PECL, \u0435\u0441\u0442\u044c \u043a\u0430\u043a\u043e\u0439-\u0442\u043e <a href=\"https:\/\/pecl.php.net\/package\/uv\">libuv<\/a>, \u043a\u043e\u0442\u043e\u0440\u044b\u0439 \u0432 \u043f\u0440\u0438\u043d\u0446\u0438\u043f\u0435 \u0432\u0441\u0435\u0433\u043e \u043b\u0438\u0448\u044c \u043e\u0431\u0435\u0440\u0442\u043a\u0430 \u0434\u043b\u044f \u0441\u0438\u0448\u043d\u044b\u0445 \u0444\u0443\u043d\u043a\u0446\u0438\u0439 \u043e\u0440\u0438\u0433\u0438\u043d\u0430\u043b\u044c\u043d\u043e\u0439 \u0431\u0438\u0431\u043b\u0438\u043e\u0442\u0435\u043a\u0438, \u043f\u043e\u044d\u0442\u043e\u043c\u0443 \u0435\u0433\u043e \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u043d\u0438\u0435 \u043a\u0430\u043a \u0435\u0441\u0442\u044c \u0431\u0440\u043e\u0441\u0430\u0435\u0442 \u0432\u0430\u043c \u043d\u0435\u043a\u043e\u0442\u043e\u0440\u044b\u0435 \u0432\u044b\u0437\u043e\u0432\u044b. \u0414\u0430 \u0438 \u0432\u043e\u043e\u0431\u0449\u0435, \u043a\u0442\u043e \u0432 \u0437\u0434\u0440\u0430\u0432\u043e\u043c \u0443\u043c\u0435 \u0431\u0443\u0434\u0435\u0442 \u044d\u0442\u0438\u043c \u0437\u0430\u043d\u0438\u043c\u0430\u0442\u044c\u0441\u044f?<\/p>\n<p>  \u041d\u043e \u0435\u0441\u043b\u0438 \u043c\u044b \u043f\u0435\u0440\u0435\u0441\u0442\u0430\u043d\u0435\u043c \u0436\u0438\u0442\u044c \u0432 \u043c\u0438\u0440\u0435 PHP4 \u0438 \u043d\u0435\u043c\u043d\u043e\u0433\u043e \u0432\u0435\u0440\u043d\u0435\u043c\u0441\u044f \u0432 \u0441\u043e\u0432\u0440\u0435\u043c\u0435\u043d\u043d\u044b\u0435 \u0440\u0435\u0430\u043b\u0438\u0438, \u0442\u043e \u0443\u0432\u0438\u0434\u0438\u043c, \u0447\u0442\u043e \u0437\u0430 \u043f\u043e\u0441\u043b\u0435\u0434\u043d\u0438\u0435 \u0433\u043e\u0434\u044b \u0434\u0435\u043b\u0430 \u043d\u0435\u0441\u043a\u043e\u043b\u044c\u043a\u043e \u0438\u0437\u043c\u0435\u043d\u0438\u043b\u0438\u0441\u044c. \u0423 \u043d\u0430\u0441 \u043f\u043e\u044f\u0432\u0438\u043b\u0438\u0441\u044c \u0442\u0430\u043a\u0438\u0435 \u0438\u043d\u0442\u0435\u0440\u0435\u0441\u043d\u044b\u0435 \u0438\u043d\u0441\u0442\u0440\u0443\u043c\u0435\u043d\u0442\u044b \u043a\u0430\u043a <b>ReactPHP<\/b> \u0438 <b>AmPHP<\/b>, \u043a\u043e\u043c\u043f\u043e\u043d\u0435\u043d\u0442\u044b \u043a\u043e\u0442\u043e\u0440\u044b\u0445 \u0445\u043e\u0440\u043e\u0448\u043e \u043f\u043e\u043a\u0440\u044b\u0432\u0430\u044e\u0442 \u0444\u0443\u043d\u043a\u0446\u0438\u043e\u043d\u0430\u043b Node.js, \u0430 \u043d\u0430\u043b\u0438\u0447\u0438\u0435 \u0433\u0435\u043d\u0435\u0440\u0430\u0442\u043e\u0440\u043e\u0432 \u043f\u043e\u0437\u0432\u043e\u043b\u044f\u0435\u0442 \u043f\u0438\u0441\u0430\u0442\u044c \u0430\u0441\u0438\u043d\u0445\u0440\u043e\u043d\u043d\u044b\u0439 \u043a\u043e\u0434 \u0432 \u0443\u0434\u043e\u0431\u043d\u043e\u043c \u0441\u0442\u0438\u043b\u0435, \u043f\u043e\u0434\u043e\u0431\u043d\u043e\u043c <i>async\/await<\/i>, \u0438\u0437\u0431\u0435\u0433\u0430\u044f \u0432\u0441\u0435\u0445 \u0432\u043e\u0442 \u044d\u0442\u0438\u0445 \u0431\u0435\u0441\u043a\u043e\u043d\u0435\u0447\u043d\u044b\u0445 \u043a\u043e\u043b\u043b\u0431\u0435\u043a\u043e\u0432 \u0432 \u043a\u043e\u043b\u043b\u0431\u0435\u043a\u0430\u0445 \u0438 \u043a\u0438\u043b\u043e\u043c\u0435\u0442\u0440\u043e\u0432\u044b\u0445 \u0446\u0435\u043f\u043e\u0447\u0435\u043a <i>.then().then().then()<\/i>.<\/p>\n<p>  \u0422\u0430\u043a \u0447\u0442\u043e \u043f\u043e\u044d\u0442\u043e\u043c\u0443 \u0441\u0435\u0439\u0447\u0430\u0441, \u043a\u0430\u043a \u043c\u043d\u0435 \u043a\u0430\u0436\u0435\u0442\u0441\u044f, \u043f\u0440\u0430\u043a\u0442\u0438\u0447\u0435\u0441\u043a\u0438 \u043d\u0435\u0442 \u0442\u0435\u0445 \u0437\u0430\u0434\u0430\u0447 \u0438\u0437 \u043c\u0438\u0440\u0430 Node.js, \u043a\u043e\u0442\u043e\u0440\u044b\u0435 \u043d\u0435 \u043c\u043e\u0433 \u0431\u044b \u0440\u0435\u0448\u0438\u0442\u044c PHP. \u041d\u043e \u0435\u0441\u043b\u0438 \u0442\u0430\u043a\u043e\u0432\u044b\u0435 \u0435\u0449\u0435 \u043e\u0441\u0442\u0430\u043b\u0438\u0441\u044c, \u0442\u043e \u0432\u0441\u0435 \u0443\u043f\u0438\u0440\u0435\u0442\u0441\u044f \u0442\u043e\u043b\u044c\u043a\u043e \u0432 \u043d\u0430\u043b\u0438\u0447\u0438\u0435 \u043a\u0430\u043a\u0438\u0445-\u0442\u043e \u043e\u0442\u0434\u0435\u043b\u044c\u043d\u044b\u0445 \u0431\u0438\u0431\u043b\u0438\u043e\u0442\u0435\u043a, \u0430 \u043d\u0435 \u043e\u0442\u0441\u0443\u0442\u0441\u0442\u0432\u0438\u0435 \u0432\u043e\u0437\u043c\u043e\u0436\u043d\u043e\u0441\u0442\u0435\u0439 \u043a\u0430\u043a \u0442\u0430\u043a\u043e\u0432\u044b\u0445.   <\/p>\n<blockquote><p>It may surprise people to learn that the PHP standard library already has everything we need to write event-driven and non-blocking applications. We only reach the limits of native PHP\u2019s functionality in this area when we ask it to poll thousands of file descriptors for IO activity at the same time. Even in this case, though, the fault is not with PHP but the underlying system select() call which is linear in its performance degradation as load increases.<\/p>\n<p>  <i><a href=\"https:\/\/amphp.org\/amp\/event-loop\/\">amphp.org\/amp\/event-loop<\/a><\/i><\/p><\/blockquote>\n<p><a name=\"habracut\"><\/a><br \/>  \u041a\u043e\u043d\u0435\u0447\u043d\u043e, \u0432\u043e\u043f\u0440\u043e\u0441 \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u043d\u0438\u044f \u044d\u0442\u043e\u0433\u043e \u0432\u0441\u0435\u0433\u043e \u0432 production \u0435\u0449\u0435 \u043d\u0435 \u0437\u0430\u043a\u0440\u044b\u0442 \u0434\u043e \u043a\u043e\u043d\u0446\u0430, \u043d\u043e \u0435\u0441\u043b\u0438 \u043d\u0435 \u0434\u0435\u043b\u0430\u0442\u044c \u0437\u0430\u0432\u0435\u0434\u043e\u043c\u043e \u043e\u0448\u0438\u0431\u043e\u0447\u043d\u044b\u0445 \u0432\u0435\u0449\u0435\u0439, \u043a\u043e\u0442\u043e\u0440\u044b\u0445 \u0432\u0430\u043c \u043d\u0435 \u043f\u0440\u043e\u0441\u0442\u0438\u0442 \u0438 \u043b\u044e\u0431\u0430\u044f \u0434\u0440\u0443\u0433\u0430\u044f \u0430\u0441\u0438\u043d\u0445\u0440\u043e\u043d\u043d\u0430\u044f \u0441\u0440\u0435\u0434\u0430 \u0438\u0441\u043f\u043e\u043b\u043d\u0435\u043d\u0438\u044f, \u0442\u043e \u0432\u0441\u0435 \u0431\u0443\u0434\u0435\u0442 \u0445\u043e\u0440\u043e\u0448\u043e.<\/p>\n<h3>DVRIP<\/h3>\n<p>  \u041c\u044b \u0431\u0443\u0434\u0435\u043c \u0440\u0430\u0441\u0441\u043c\u0430\u0442\u0440\u0438\u0432\u0430\u0442\u044c \u043f\u0440\u043e\u0442\u043e\u043a\u043e\u043b, \u043f\u0440\u0435\u0434\u043f\u043e\u043b\u043e\u0436\u0438\u0442\u0435\u043b\u044c\u043d\u043e \u043f\u0440\u0438\u0434\u0443\u043c\u0430\u043d\u043d\u044b\u0439 \u043a\u0438\u0442\u0430\u0439\u0446\u0430\u043c\u0438, \u043a\u043e\u0442\u043e\u0440\u044b\u0439 \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u0443\u0435\u0442\u0441\u044f \u0434\u043b\u044f \u043e\u0431\u0449\u0435\u043d\u0438\u044f \u041f\u041e c \u043a\u0430\u043c\u0435\u0440\u0430\u043c\u0438 \u043d\u0430\u0431\u043b\u044e\u0434\u0435\u043d\u0438\u044f.<\/p>\n<p>  \u0420\u0430\u0431\u043e\u0442\u0430\u0435\u0442 \u044d\u0442\u043e \u0432\u0441\u0435 \u043f\u043e\u0432\u0435\u0440\u0445 TCP, \u043d\u0430\u0437\u044b\u0432\u0430\u0435\u0442\u0441\u044f DVRIP (\u0438\u043d\u043e\u0433\u0434\u0430 Sofia) \u0438 \u043a \u043c\u043e\u043c\u0435\u043d\u0442\u0443, \u043a\u043e\u0433\u0434\u0430 \u043c\u043d\u0435 \u044d\u0442\u043e \u0431\u044b\u043b\u043e \u043d\u0443\u0436\u043d\u043e, \u044f \u043d\u0430\u0448\u0435\u043b \u0442\u043e\u043b\u044c\u043a\u043e \u0434\u0432\u0435 \u0431\u043e\u043b\u0435\u0435-\u043c\u0435\u043d\u0435\u0435 \u0432\u043c\u0435\u043d\u044f\u0435\u043c\u044b\u0445 \u0431\u0438\u0431\u043b\u0438\u043e\u0442\u0435\u043a\u0438, \u043e\u0434\u043d\u0430 \u0438\u0437 \u043a\u043e\u0442\u043e\u0440\u044b\u0445 \u043e\u043f\u0438\u0441\u044b\u0432\u0430\u043b\u0430 \u0432\u043e\u043e\u0431\u0449\u0435 \u0442\u043e\u043b\u044c\u043a\u043e \u043f\u043e\u0434\u043a\u043b\u044e\u0447\u0435\u043d\u0438\u0435 \u043a \u043a\u0430\u043c\u0435\u0440\u0435 \u0438 \u043e\u0431\u043c\u0435\u043d \u043f\u0430\u0440\u043e\u0439-\u0442\u0440\u043e\u0439\u043a\u043e\u0439 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0439, \u043d\u043e \u0438\u043c\u0435\u043b\u0430 \u043e\u043f\u0438\u0441\u0430\u043d\u0438\u0435 \u0437\u0430\u0433\u043e\u043b\u043e\u0432\u043a\u0430 \u043f\u0430\u043a\u0435\u0442\u0430, \u043a\u043e\u0442\u043e\u0440\u043e\u0435 \u043c\u043d\u0435 \u043e\u0447\u0435\u043d\u044c \u043f\u043e\u043c\u043e\u0433\u043b\u043e.<\/p>\n<p>  \u0412\u0442\u043e\u0440\u0430\u044f \u0431\u044b\u043b\u0430 \u043d\u0430\u0439\u0434\u0435\u043d\u0430 \u0447\u0443\u0442\u044c \u043f\u043e\u0437\u0436\u0435, \u0432 \u043c\u043e\u043c\u0435\u043d\u0442 \u043e\u0431\u043e\u0441\u0442\u0440\u0435\u043d\u0438\u044f \u0443 \u043c\u0435\u043d\u044f not invented here \u0441\u0438\u043d\u0434\u0440\u043e\u043c\u0430, \u0434\u0430 \u0438 \u0440\u0430\u0431\u043e\u0442\u0430\u043b\u0430 \u043d\u0435\u043c\u043d\u043e\u0433\u043e \u043d\u0435 \u0442\u0430\u043a \u043a\u0430\u043a \u043c\u043d\u0435 \u0445\u043e\u0442\u0435\u043b\u043e\u0441\u044c \u0431\u044b.<\/p>\n<p>  \u0412 \u043e\u0431\u0449\u0435\u043c, \u0432\u043e\u043e\u0440\u0443\u0436\u0438\u0432\u0448\u0438\u0441\u044c \u0441\u043d\u0438\u0444\u0444\u0435\u0440\u043e\u043c \u0438 \u043e\u043f\u0438\u0441\u0430\u043d\u0438\u0435\u043c \u0437\u0430\u0433\u043e\u043b\u043e\u0432\u043a\u0430 \u043f\u0430\u043a\u0435\u0442\u0430 \u044f \u043a\u0440\u0430\u0442\u0435\u043d\u044c\u043a\u043e \u043d\u0430\u0431\u0440\u043e\u0441\u0430\u043b \u043d\u0435\u043a\u0438\u0439 \u0441\u043a\u0440\u0438\u043f\u0442, \u043a\u043e\u0442\u043e\u0440\u044b\u0439 \u0432 \u043e\u0434\u043d\u043e\u043c \u0432\u0438\u0434\u0435 \u043a\u0440\u0443\u0442\u0438\u0442\u0441\u044f \u0443 \u043c\u0435\u043d\u044f \u0433\u0434\u0435-\u0442\u043e \u043d\u0430 \u0441\u0435\u0440\u0432\u0435\u0440\u0435, \u0430 \u0432 \u0432\u0438\u0434\u0435 \u043d\u0435\u043a\u043e\u0435\u0433\u043e proof of concept \u0431\u0443\u0434\u0435\u0442 \u043f\u0440\u0435\u0434\u0441\u0442\u0430\u0432\u043b\u0435\u043d \u0432 \u044d\u0442\u043e\u0439 \u0441\u0442\u0430\u0442\u044c\u0435.<\/p>\n<p>  \u0421\u0430\u043c \u043f\u0440\u043e\u0442\u043e\u043a\u043e\u043b \u043d\u0435 \u0441\u043b\u043e\u0436\u0435\u043d \u0438 \u043f\u0430\u043a\u0435\u0442 \u0432\u044b\u0433\u043b\u044f\u0434\u0438\u0442 \u0441\u043b\u0435\u0434\u0443\u044e\u0449\u0438\u043c \u043e\u0431\u0440\u0430\u0437\u043e\u043c:<\/p>\n<ul>\n<li>\u0448\u0430\u043f\u043a\u0430 \u0440\u0430\u0437\u043c\u0435\u0440\u043e\u043c 20 \u0431\u0430\u0439\u0442, \u043a\u043e\u0442\u043e\u0440\u0443\u044e \u0432 PHP \u043c\u043e\u0436\u043d\u043e \u043e\u0431\u043e\u0437\u043d\u0430\u0447\u0438\u0442\u044c \u043a\u0430\u043a\n<pre><code class=\"php\">unpack('Chead\/Cversion\/x2\/IsessionId\/Isequence\/x2\/SmsgId\/Ilen', $buffer)<\/code><\/pre>\n<\/li>\n<li>\u0437\u0430 \u0448\u0430\u043f\u043a\u043e\u0439 \u0441\u043b\u0435\u0434\u0443\u0435\u0442 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 \u0434\u043b\u0438\u043d\u043d\u043e\u0439 len \u0438 \u043c\u043e\u0436\u0435\u0442 \u0441\u043e\u0434\u0435\u0440\u0436\u0430\u0442\u044c \u043b\u0438\u0431\u043e json, \u0434\u043e\u043f\u043e\u043b\u043d\u0435\u043d\u043d\u044b\u0439 \u0434\u0432\u0443\u043c\u044f \u0431\u0430\u0439\u0442\u0430\u043c\u0438 \\x0a\\x00, \u043b\u0438\u0431\u043e \u0431\u0438\u043d\u0430\u0440\u043d\u044b\u0435 \u0434\u0430\u043d\u043d\u044b\u0435.<\/li>\n<\/ul>\n<p>  \u041c\u044b \u0431\u0443\u0434\u0435\u043c \u043f\u0435\u0440\u0435\u0434\u0430\u0432\u0430\u0442\u044c \u0442\u043e\u043b\u044c\u043a\u043e json, \u0430 \u0432\u043e\u0442 \u043f\u043e\u043b\u0443\u0447\u0430\u0442\u044c \u0438 \u0442\u043e \u0438 \u0434\u0440\u0443\u0433\u043e\u0435.<\/p>\n<p>  \u041e\u0442\u0432\u0435\u0442 (\u0435\u0441\u043b\u0438 \u044d\u0442\u043e \u043f\u0430\u043a\u0435\u0442 \u0441 json) \u043e\u0431\u044b\u0447\u043d\u043e \u0441\u043e\u0434\u0435\u0440\u0436\u0438\u0442 \u043f\u043e\u043b\u0435 <b>Ret<\/b>, \u0443\u043a\u0430\u0437\u044b\u0432\u0430\u044e\u0449\u0435\u0435 \u043d\u0430 \u0443\u0441\u043f\u0435\u0448\u043d\u043e\u0441\u0442\u044c \u0432\u044b\u043f\u043e\u043b\u043d\u0435\u043d\u0438\u044f \u043d\u0430\u0448\u0435\u0433\u043e \u0437\u0430\u043f\u0440\u043e\u0441\u0430. \u041e\u0442\u0432\u0435\u0442\u044b, \u0441\u043e\u0434\u0435\u0440\u0436\u0430\u0449\u0438\u0435 \u043a\u043e\u0434 <b>Ret<\/b> \u043d\u0435 \u0440\u0430\u0432\u043d\u044b\u0439 <b>100<\/b> \u0438\u043b\u0438 <b>515<\/b>, \u043c\u044b \u0431\u0443\u0434\u0435\u043c \u0441\u0447\u0438\u0442\u0430\u0442\u044c \u0437\u0430\u0432\u0435\u0434\u043e\u043c\u043e \u043e\u0448\u0438\u0431\u043e\u0447\u043d\u044b\u043c\u0438.<\/p>\n<p>  \u0412\u043e\u043e\u0440\u0443\u0436\u0438\u0432\u0448\u0438\u0441\u044c \u044d\u0442\u0438\u043c\u0438 \u0431\u0430\u0437\u043e\u0432\u044b\u043c\u0438 \u0437\u043d\u0430\u043d\u0438\u044f\u043c\u0438 \u0434\u0430\u0432\u0430\u0439\u0442\u0435 \u043f\u043e\u0434\u043a\u043b\u044e\u0447\u0438\u043c\u0441\u044f \u043a \u043a\u0430\u043c\u0435\u0440\u0435 \u0438 \u0431\u0443\u0434\u0435\u043c \u0440\u0430\u0437\u0431\u0438\u0440\u0430\u0442\u044c\u0441\u044f.<br \/>  \u041d\u0430\u043c \u043f\u043e\u0442\u0440\u0435\u0431\u0443\u0435\u0442\u0441\u044f \u0434\u0432\u0435 \u0431\u0438\u0431\u043b\u0438\u043e\u0442\u0435\u043a\u0438 \u2014 <a href=\"https:\/\/github.com\/amphp\/socket\">amphp\/socket<\/a>, \u043a\u043e\u0442\u043e\u0440\u0430\u044f \u043f\u043e\u0434\u0442\u044f\u043d\u0435\u0442 \u0437\u0430 \u0441\u043e\u0431\u043e\u0439 \u043f\u0440\u0430\u043a\u0442\u0438\u0447\u0435\u0441\u043a\u0438 \u0432\u0441\u0435 \u043d\u0443\u0436\u043d\u043e\u0435, \u0438 <a href=\"https:\/\/packagist.org\/packages\/evenement\/evenement\">evenement\/evenement<\/a>, \u043a\u043e\u0442\u043e\u0440\u044b\u0435 \u0434\u043e\u0441\u0442\u0443\u043f\u043d\u044b \u0432 packagist \u0438 \u043d\u0435 \u0442\u0440\u0435\u0431\u0443\u044e\u0442 \u043d\u0438\u043a\u0430\u043a\u0438\u0445 \u0440\u0430\u0441\u0448\u0438\u0440\u0435\u043d\u0438\u0439.<\/p>\n<p>  \u0420\u0430\u0431\u043e\u0442\u0430 \u0441 TCP \u0432 Amp \u0432\u044b\u0433\u043b\u044f\u0434\u0438\u0442 \u043f\u0440\u0438\u043c\u0435\u0440\u043d\u043e \u0442\u0430\u043a:<\/p>\n<pre><code class=\"php\">Loop::run(function () {     $socket = yield connect(&quot;tcp:\/\/{$addr}:{$port}&quot;);          yield $socket-&gt;write('Hello');          while ($chunk = yield $socket-&gt;read()) {         echo $chunk;     }          $socket-&gt;close(); });<\/code><\/pre>\n<p>  DVRIP \u043e\u0431\u044b\u0447\u043d\u043e \u0440\u0430\u0431\u043e\u0442\u0430\u0435\u0442 \u043d\u0430 \u043f\u043e\u0440\u0442\u0443 34567, \u043f\u043e\u044d\u0442\u043e\u043c\u0443 \u0432 \u043d\u0430\u0448\u0435\u043c \u0441\u043b\u0443\u0447\u0430\u0435 \u044d\u0442\u043e \u0431\u0443\u0434\u0435\u0442 \u0447\u0442\u043e-\u0442\u043e \u0442\u0430\u043a\u043e\u0435: <\/p>\n<pre><code class=\"php\">$socket = yield connect('tcp:\/\/192.168.0.200:34567');<\/code><\/pre>\n<p>  \u0414\u0430\u043b\u044c\u0448\u0435 \u043c\u044b \u043b\u043e\u0433\u0438\u043d\u0438\u043c\u0441\u044f, \u043e\u0442\u043f\u0440\u0430\u0432\u043b\u044f\u044f \u043a\u0430\u043c\u0435\u0440\u0435 \u043d\u0430\u0448 \u043b\u043e\u0433\u0438\u043d \u0438 \u0445\u0435\u0448 \u043f\u0430\u0440\u043e\u043b\u044f, \u043a\u043e\u0442\u043e\u0440\u044b\u0439 \u0432\u044b\u0447\u0438\u0441\u043b\u044f\u0435\u0442\u0441\u044f \u0442\u0430\u043a:<\/p>\n<pre><code class=\"php\">function sofiaHash(string $password) : string {     $md5 = md5($password, true);         return implode('', array_map(function ($i) use ($md5) {         $c = (ord($md5[2 * $i]) + ord($md5[2 * $i + 1])) % 62;         $c += $c &gt; 9 ? ($c &gt; 35 ? 61 : 55) : 48;         return chr($c);     }, range(0, 7))); }<\/code><\/pre>\n<p>  \u0412 \u0441\u043b\u0443\u0447\u0430\u0435 \u0443\u0441\u043f\u0435\u0448\u043d\u043e\u0439 \u0430\u0432\u0442\u043e\u0440\u0438\u0437\u0430\u0446\u0438\u0438 \u043c\u044b \u0437\u0430\u043f\u0440\u0430\u0448\u0438\u0432\u0430\u0435\u043c \u0432\u0438\u0434\u0435\u043e \u0438, \u0435\u0441\u043b\u0438 \u043a\u0430\u043c\u0435\u0440\u0430 \u043c\u043e\u0436\u0435\u0442 \u043d\u0430\u043c \u0435\u0433\u043e \u043e\u0442\u0434\u0430\u0442\u044c, \u0442\u043e \u0437\u0430\u043f\u0443\u0441\u043a\u0430\u0435\u043c \u0435\u0433\u043e \u043f\u0435\u0440\u0435\u0434\u0430\u0447\u0443.<\/p>\n<p>  \u041a\u0430\u0436\u0434\u044b\u0439 \u0442\u0438\u043f \u043f\u0430\u043a\u0435\u0442\u0430 \u0438\u043c\u0435\u0435\u0442 \u0441\u0432\u043e\u0439 msgId, \u0431\u043b\u0430\u0433\u043e\u0434\u0430\u0440\u044f \u0447\u0435\u043c\u0443 \u043c\u044b \u043c\u043e\u0436\u0435\u043c \u043f\u043e\u043d\u0438\u043c\u0430\u0442\u044c \u043d\u0430 \u043a\u0430\u043a\u043e\u0439 \u0437\u0430\u043f\u0440\u043e\u0441 \u043d\u0430\u043c \u043f\u0440\u0438\u0448\u0435\u043b \u043e\u0442\u0432\u0435\u0442. \u0412 \u043e\u0431\u0449\u0435\u043c, \u043d\u0435 \u043f\u044b\u043b\u044c\u043d\u0430\u044f \u0440\u0430\u0431\u043e\u0442\u0451\u043d\u043a\u0430. <\/p>\n<p>  \u0414\u043b\u044f \u0443\u0434\u043e\u0431\u0441\u0442\u0432\u0430 \u0440\u0430\u0431\u043e\u0442\u044b \u0434\u0430\u0432\u0430\u0439\u0442\u0435 \u0434\u043b\u044f \u043d\u0430\u0447\u0430\u043b\u0430 \u043e\u043f\u0438\u0448\u0435\u043c \u043a\u043b\u0430\u0441\u0441 \u0434\u043b\u044f \u043d\u0430\u0448\u0435\u0433\u043e \u043f\u0430\u043a\u0435\u0442\u0430:<\/p>\n<pre><code class=\"php\">class Packet {     public const SUCCESS_CODES = [100, 515];         public const MESSAGE_CODES = [         'packet.request.login'      =&gt; 1000,         'packet.request.keepAlive'  =&gt; 1006,         'packet.request.claim'      =&gt; 1413,                  'packet.response.login'     =&gt; 1001,         'packet.response.keepAlive' =&gt; 1007,         'packet.response.claim'     =&gt; 1414,                  'packet.videoControl'       =&gt; 1410,         'packet.binary'             =&gt; 1412,     ];      protected int $head = 255;     protected int $version = 0;     protected int $sessionId;     protected int $sequence;     protected int $msgId;          protected ?string $rawData;     protected ?array $data;          public function __construct(int $msgId, ?array $data = null, int $sequence = 0, int $sessionId = 0)     {         $this-&gt;msgId = $msgId;         $this-&gt;data = $data;         $this-&gt;sequence = $sequence;         $this-&gt;sessionId = $sessionId;     }          public function __toString() : string     {         if ($this-&gt;data !== null) {             $this-&gt;rawData = json_encode($this-&gt;data, JSON_THROW_ON_ERROR) . &quot;\\x0a\\x00&quot;;         }         return pack('CCx2IIx2SI', $this-&gt;head, $this-&gt;version, $this-&gt;sessionId, $this-&gt;sequence, $this-&gt;msgId, strlen($this-&gt;rawData))             . $this-&gt;rawData;     }          public function getData() : ?array     {         return $this-&gt;data;     }          public function getRawData() : ?string     {         return $this-&gt;rawData;     }          public function getSession() : int     {         return $this-&gt;sessionId;     }          public function getSequence() : int     {         return $this-&gt;sequence;     }          public function getMessageType() : string     {         $types = array_flip(static::MESSAGE_CODES);         if (!isset($types[$this-&gt;msgId])) {             throw new \\Exception('Unknown message type: ' . $this-&gt;msgId);         }                  return $types[$this-&gt;msgId];     } }<\/code><\/pre>\n<p>  \u0438 \u043f\u043e\u043f\u0440\u043e\u0431\u0443\u0435\u043c \u043e\u0442\u043f\u0440\u0430\u0432\u0438\u0442\u044c \u0437\u0430\u043f\u0440\u043e\u0441 \u043d\u0430 \u0430\u0432\u0442\u043e\u0440\u0438\u0437\u0430\u0446\u0438\u044e<\/p>\n<pre><code class=\"php\">yield $socket-&gt;write((string) new Packet(Packet::MESSAGE_CODES['packet.request.login'], [     'EncryptType' =&gt; 'MD5',     'LoginType'   =&gt; 'DVRIP-Web',     'PassWord'    =&gt; sofiaHash('admin'),     'UserName'    =&gt; 'admin', ]));<\/code><\/pre>\n<p>  \u0410\u0433\u0430, \u043e\u0442\u043b\u0438\u0447\u043d\u043e. \u041c\u044b \u043f\u043e\u0434\u043a\u043b\u044e\u0447\u0438\u043b\u0438\u0441\u044c \u0438 \u043e\u0442\u043f\u0440\u0430\u0432\u0438\u043b\u0438 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435, \u043d\u043e \u043c\u044b \u0434\u0430\u0436\u0435 \u043d\u0435 \u0437\u043d\u0430\u0435\u043c, \u043f\u0440\u0430\u0432\u0438\u043b\u044c\u043d\u043e\u0435 \u043b\u0438 \u0438 \u043e\u0442\u0440\u0435\u0430\u0433\u0438\u0440\u043e\u0432\u0430\u043b\u0430 \u043b\u0438 \u043a\u0430\u043c\u0435\u0440\u0430 \u043d\u0430 \u043d\u0435\u0433\u043e \u0445\u043e\u0442\u044c \u043a\u0430\u043a-\u0442\u043e. \u041d\u0430\u043c \u043d\u0443\u0436\u043d\u043e \u043a\u0430\u043a-\u0442\u043e \u043f\u0440\u043e\u0447\u0438\u0442\u0430\u0442\u044c \u043e\u0442\u0432\u0435\u0442 (\u0434\u0430\u0432\u0430\u0439\u0442\u0435 \u0441\u0434\u0435\u043b\u0430\u0435\u043c \u044d\u0442\u043e \u0430\u0441\u0438\u043d\u0445\u0440\u043e\u043d\u043d\u043e), \u0432\u044b\u0434\u0435\u043b\u0438\u0442\u044c \u0432 \u043d\u0435\u043c \u043a\u043e\u043d\u043a\u0440\u0435\u0442\u043d\u044b\u0435 \u043f\u0430\u043a\u0435\u0442\u044b \u0438 \u0434\u0435\u043a\u043e\u0434\u0438\u0440\u043e\u0432\u0430\u0442\u044c \u0438\u0445.<\/p>\n<p>  \u0427\u0442\u043e\u0431 \u043a\u0430\u043a-\u0442\u043e \u0440\u0430\u0437\u0434\u0435\u043b\u0438\u0442\u044c \u043b\u043e\u0433\u0438\u043a\u0443 \u043e\u0431\u0440\u0430\u0431\u043e\u0442\u043a\u0438 \u043f\u0430\u043a\u0435\u0442\u043e\u0432, \u043f\u0440\u0438\u0445\u043e\u0434\u044f\u0449\u0438\u0445 \u0432 \u043e\u0442\u0432\u0435\u0442, \u044f \u0440\u0435\u0448\u0438\u043b \u0432\u043e\u0441\u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u044c\u0441\u044f \u0431\u0438\u0431\u043b\u0438\u043e\u0442\u0435\u043a\u043e\u0439 <b>evenement<\/b> \u0438 \u043d\u0430\u0431\u0440\u043e\u0441\u0430\u043b \u043d\u0430 \u0435\u0435 \u043e\u0441\u043d\u043e\u0432\u0435 \u043a\u043b\u0430\u0441\u0441, \u043a\u043e\u0442\u043e\u0440\u044b\u0439 \u0431\u0443\u0434\u0435\u0442 \u0432\u044b\u0431\u0440\u0430\u0441\u044b\u0432\u0430\u0442\u044c \u0443\u0436\u0435 \u0434\u0435\u043a\u043e\u0434\u0438\u0440\u043e\u0432\u0430\u043d\u043d\u044b\u0435 \u043f\u0430\u043a\u0435\u0442\u044b<\/p>\n<pre><code class=\"php\">class Reader extends EventEmitter {     protected InputStream $socket;          public function __construct(InputStream $socket)     {         $this-&gt;socket = $socket;     }          public function start() : \\Generator     {         $buffer = '';         while (!$this-&gt;socket-&gt;isClosed() &amp;&amp; $result = yield Packet::read($this-&gt;socket, $buffer)) {             [$packet, $chunk] = $result;             $buffer = $chunk;             $chunk = null;             $this-&gt;emit('packet', [$packet]);             $this-&gt;emit($packet-&gt;getMessageType(), [$packet]);         }                  $buffer = null;     } }<\/code><\/pre>\n<p>  \u0430 \u0442\u0430\u043a \u0436\u0435 \u0434\u043e\u0431\u0430\u0432\u0438\u043b \u043f\u0430\u0440\u0443 \u0441\u0442\u0430\u0442\u0438\u0447\u0435\u0441\u043a\u0438\u0445 \u043c\u0435\u0442\u043e\u0434\u043e\u0432 \u043d\u0430\u0448\u0435\u043c\u0443 \u043a\u043b\u0430\u0441\u0441\u0443 Packet, \u043a\u043e\u0442\u043e\u0440\u044b\u0435 \u0431\u0443\u0434\u0443\u0442, \u0441\u043e\u0431\u0441\u0442\u0432\u0435\u043d\u043d\u043e \u0433\u043e\u0432\u043e\u0440\u044f, \u0432\u044b\u0434\u0435\u043b\u044f\u0442\u044c \u0438 \u0434\u0435\u043a\u043e\u0434\u0438\u0440\u043e\u0432\u0430\u0442\u044c \u043f\u0430\u043a\u0435\u0442\u044b \u0438\u0437 \u043f\u043e\u0442\u043e\u043a\u0430 \u0434\u0430\u043d\u043d\u044b\u0445<\/p>\n<pre><code class=\"php\">public static function read(InputStream $socket, string $buffer = '') : Promise {     return call(function () use ($socket, $buffer) {         $header = null;                  do {             if ($header === null &amp;&amp; strlen($buffer) &gt; 20) {                 $header = unpack('Chead\/Cversion\/x2\/IsessionId\/Isequence\/x2\/SmsgId\/Ilen', substr($buffer, 0, 20));                 $buffer = substr($buffer, 20);             }                          if ($header !== null &amp;&amp; strlen($buffer) &gt;= (int) $header['len']) {                 return [                     static::fromRaw($header, (int) $header['len'] &gt; 0 ? substr($buffer, 0, (int) $header['len']) : null),                     substr($buffer, (int) $header['len'])                 ];             }                          $buffer .= yield $socket-&gt;read();                         } while (!$socket-&gt;isClosed());     }); }  protected static function fromRaw(array $header, ?string $rawData) : self {     $packet = new static($header['msgId'], null, $header['sequence'], $header['sessionId']);     $packet-&gt;rawData = $rawData;          $packet-&gt;data = (int) $packet-&gt;msgId === static::MESSAGE_CODES['packet.binary'] || $rawData === null         ? null         : json_decode(substr($rawData, 0, -2), true, 512, JSON_THROW_ON_ERROR);          return $packet; } <\/code><\/pre>\n<p>  \u0422\u0435\u043f\u0435\u0440\u044c, \u0431\u043b\u0430\u0433\u043e\u0434\u0430\u0440\u044f \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u043d\u0438\u044e <b>Evenement <\/b>, \u043c\u044b \u043c\u043e\u0436\u0435\u043c \u0432 \u043e\u043f\u0438\u0441\u0430\u0442\u044c \u043d\u0430\u0448\u0443 \u043b\u043e\u0433\u0438\u043a\u0443 \u0432 \u0432\u0438\u0434\u0435 <\/p>\n<pre><code class=\"php\">$reader-&gt;on($packetType, $handler);<\/code><\/pre>\n<p>  \u0418 \u0432\u043e\u0442 \u0442\u0430\u043a\u0430\u044f \u0432\u043e\u0442 \u0446\u0435\u043f\u043e\u0447\u043a\u0430 \u0443 \u043c\u0435\u043d\u044f \u043f\u043e\u043b\u0443\u0447\u0438\u043b\u0430\u0441\u044c, \u0433\u0434\u0435 \u044f \u0434\u043e\u0431\u0430\u0432\u0438\u043b \u0435\u0449\u0435 Keep Alive \u0438 \u043e\u0431\u0440\u0430\u0431\u043e\u0442\u043a\u0443 SIGINT \/ SIGTERM:<\/p>\n<pre><code class=\"php\">$reader = new Reader($socket = yield connect('tcp:\/\/10.0.5.100:49152'));   $reader-&gt;on('packet.response.login', asyncCoroutine(function (Packet $packet) use ($socket) {     if (empty($packet-&gt;getData()['Ret']) || !in_array($packet-&gt;getData()['Ret'], Packet::SUCCESS_CODES)) {         throw new \\Exception('Wrong login data');     }          yield $socket-&gt;write((string) new Packet(Packet::MESSAGE_CODES['packet.request.claim'], [         'Name' =&gt; 'OPMonitor',         'OPMonitor' =&gt; ['Action' =&gt; 'Claim', 'Parameter' =&gt; ['Channel' =&gt; 0, 'CombinMode' =&gt; 'NONE', 'StreamType' =&gt; 'Main', 'TransMode'  =&gt; 'TCP']],     ], 1, $packet-&gt;getSession())); }));  $reader-&gt;once('packet.response.login', function (Packet $packet) use ($socket) {     Loop::unreference(Loop::repeat($packet-&gt;getData()['AliveInterval'] * 1000, function ($watcherId) use ($socket, $packet) {         if ($socket-&gt;getResource() === null) {             return Loop::cancel($watcherId);            }                  yield $socket-&gt;write((string) new Packet(Packet::MESSAGE_CODES['packet.request.keepAlive'], [             'Name' =&gt; 'KeepAlive', 'SessionID' =&gt; $packet-&gt;getData()['SessionID']         ], 0, $packet-&gt;getSession()));     })); });  $reader-&gt;on('packet.response.claim', asyncCoroutine(function (Packet $packet) use ($socket) {     yield $socket-&gt;write((string) new Packet(Packet::MESSAGE_CODES['packet.videoControl'], [         'Name' =&gt; 'OPMonitor',         'OPMonitor' =&gt; ['Action' =&gt; 'Start', 'Parameter' =&gt; ['Channel' =&gt; 0, 'CombinMode' =&gt; 'NONE', 'StreamType' =&gt; 'Main', 'TransMode'  =&gt; 'TCP']],     ], $packet-&gt;getSequence() + 1, $packet-&gt;getSession())); }));  $emitter = new Emitter();     $reader-&gt;on('packet.binary', function ($packet) use ($emitter) {     $emitter-&gt;emit($packet-&gt;getRawData()); });  $reader-&gt;once('packet.binary', function (Packet $packet) use ($socket) {     $signalHandler = function () use ($socket, $packet) {         yield $socket-&gt;write((string) new Packet(Packet::MESSAGE_CODES['packet.videoControl'], [             'Name' =&gt; 'OPMonitor',             'OPMonitor' =&gt; ['Action' =&gt; 'Stop', 'Parameter' =&gt; ['Channel' =&gt; 0, 'CombinMode' =&gt; 'NONE', 'StreamType' =&gt; 'Main', 'TransMode'  =&gt; 'TCP']],         ], 0, $packet-&gt;getSession()));                  $socket-&gt;close();     };     Loop::unreference(Loop::onSignal(defined('SIGINT')  ? SIGINT  : 2,  $signalHandler, 'SIGINT'));     Loop::unreference(Loop::onSignal(defined('SIGTERM') ? SIGTERM : 15, $signalHandler, 'SIGTERM')); });  asyncCall([$reader, 'start']);  yield $socket-&gt;write((string) new Packet(Packet::MESSAGE_CODES['packet.request.login'], [     'EncryptType' =&gt; 'MD5',     'LoginType'   =&gt; 'DVRIP-Web',     'PassWord'    =&gt; sofiaHash('123qwea'),     'UserName'    =&gt; 'admin', ]));  yield pipe(new IteratorStream($emitter-&gt;iterate()), getStdout());<\/code><\/pre>\n<p>  \u0421\u0430\u043c\u043e \u0441\u043e\u0431\u043e\u0439, \u0447\u0442\u043e \u0432\u043c\u0435\u0441\u0442\u043e stdout \u043c\u044b \u043c\u043e\u0436\u0435\u043c \u043f\u0435\u0440\u0435\u043d\u0430\u043f\u0440\u0430\u0432\u0438\u0442\u044c \u043f\u043e\u0442\u043e\u043a \u0432\u0438\u0434\u0435\u043e \u043a\u0443\u0434\u0430 \u0434\u0443\u0448\u0435 \u0443\u0433\u043e\u0434\u043d\u043e.<\/p>\n<div class=\"spoiler\"><b class=\"spoiler_title\">\u0418\u0442\u043e\u0433\u043e\u0432\u044b\u0439 \u0441\u043a\u0440\u0438\u043f\u0442<\/b><\/p>\n<div class=\"spoiler_text\">\n<pre><code class=\"php\">&lt;?php  ini_set('display_errors', 'stderr');  use Amp\\Emitter; use Amp\\Loop; use Amp\\Promise; use Amp\\ByteStream\\InputStream; use Amp\\ByteStream\\IteratorStream; use Evenement\\EventEmitter;  use function Amp\\call; use function Amp\\asyncCall; use function Amp\\asyncCoroutine; use function Amp\\ByteStream\\getStderr; use function Amp\\ByteStream\\getStdout; use function Amp\\ByteStream\\pipe; use function Amp\\Socket\\connect;  require 'vendor\/autoload.php';  function sofiaHash(string $password) : string {     $md5 = md5($password, true);         return implode('', array_map(function ($i) use ($md5) {         $c = (ord($md5[2 * $i]) + ord($md5[2 * $i + 1])) % 62;         $c += $c &gt; 9 ? ($c &gt; 35 ? 61 : 55) : 48;         return chr($c);     }, range(0, 7))); }  class Reader extends EventEmitter {     protected InputStream $socket;          public function __construct(InputStream $socket)     {         $this-&gt;socket = $socket;     }          public function start() : \\Generator     {         $buffer = '';         while (!$this-&gt;socket-&gt;isClosed() &amp;&amp; $result = yield Packet::read($this-&gt;socket, $buffer)) {             [$packet, $chunk] = $result;             $buffer = $chunk;             $chunk = null;             $this-&gt;emit('packet', [$packet]);             $this-&gt;emit($packet-&gt;getMessageType(), [$packet]);         }                  $buffer = null;     } }  class Packet {     public const SUCCESS_CODES = [100, 515];         public const MESSAGE_CODES = [         'packet.request.login'      =&gt; 1000,         'packet.request.keepAlive'  =&gt; 1006,         'packet.request.claim'      =&gt; 1413,                  'packet.response.login'     =&gt; 1001,         'packet.response.keepAlive' =&gt; 1007,         'packet.response.claim'     =&gt; 1414,                  'packet.videoControl'       =&gt; 1410,         'packet.binary'             =&gt; 1412,     ];          public static function read(InputStream $socket, string $buffer = '') : Promise     {         return call(function () use ($socket, $buffer) {             $header = null;                          do {                 if ($header === null &amp;&amp; strlen($buffer) &gt; 20) {                     $header = unpack('Chead\/Cversion\/x2\/IsessionId\/Isequence\/x2\/SmsgId\/Ilen', substr($buffer, 0, 20));                     $buffer = substr($buffer, 20);                 }                                  if ($header !== null &amp;&amp; strlen($buffer) &gt;= (int) $header['len']) {                     return [                         static::fromRaw($header, (int) $header['len'] &gt; 0 ? substr($buffer, 0, (int) $header['len']) : null),                         substr($buffer, (int) $header['len'])                     ];                 }                                  $buffer .= yield $socket-&gt;read();                             } while (!$socket-&gt;isClosed());         });     }          protected static function fromRaw(array $header, ?string $rawData) : self     {         $packet = new static($header['msgId'], null, $header['sequence'], $header['sessionId']);         $packet-&gt;rawData = $rawData;                  $packet-&gt;data = (int) $packet-&gt;msgId === static::MESSAGE_CODES['packet.binary'] || $rawData === null             ? null             : json_decode(substr($rawData, 0, -2), true, 512, JSON_THROW_ON_ERROR);                  return $packet;     }          protected int $head = 255;     protected int $version = 0;     protected int $sessionId;     protected int $sequence;     protected int $msgId;          protected ?string $rawData;     protected ?array $data;          public function __construct(int $msgId, ?array $data = null, int $sequence = 0, int $sessionId = 0)     {         $this-&gt;msgId = $msgId;         $this-&gt;data = $data;         $this-&gt;sequence = $sequence;         $this-&gt;sessionId = $sessionId;     }          public function __toString() : string     {         if ($this-&gt;data !== null) {             $this-&gt;rawData = json_encode($this-&gt;data, JSON_THROW_ON_ERROR) . &quot;\\x0a\\x00&quot;;         }         return pack('CCx2IIx2SI', $this-&gt;head, $this-&gt;version, $this-&gt;sessionId, $this-&gt;sequence, $this-&gt;msgId, strlen($this-&gt;rawData))             . $this-&gt;rawData;     }          public function getData() : ?array     {         return $this-&gt;data;     }          public function getRawData() : ?string     {         return $this-&gt;rawData;     }          public function getSession() : int     {         return $this-&gt;sessionId;     }          public function getSequence() : int     {         return $this-&gt;sequence;     }          public function getMessageType() : string     {         $types = array_flip(static::MESSAGE_CODES);         if (!isset($types[$this-&gt;msgId])) {             throw new \\Exception('Unknown message type: ' . $this-&gt;msgId);         }                  return $types[$this-&gt;msgId];     } }  Loop::run(function () : \\Generator {     $reader = new Reader($socket = yield connect('tcp:\/\/10.0.5.100:49152'));           $reader-&gt;on('packet.response.login', asyncCoroutine(function (Packet $packet) use ($socket) {         if (empty($packet-&gt;getData()['Ret']) || !in_array($packet-&gt;getData()['Ret'], Packet::SUCCESS_CODES)) {             throw new \\Exception('Wrong login data');         }                  yield $socket-&gt;write((string) new Packet(Packet::MESSAGE_CODES['packet.request.claim'], [             'Name' =&gt; 'OPMonitor',             'OPMonitor' =&gt; ['Action' =&gt; 'Claim', 'Parameter' =&gt; ['Channel' =&gt; 0, 'CombinMode' =&gt; 'NONE', 'StreamType' =&gt; 'Main', 'TransMode'  =&gt; 'TCP']],         ], 1, $packet-&gt;getSession()));     }));          $reader-&gt;once('packet.response.login', function (Packet $packet) use ($socket) {         Loop::unreference(Loop::repeat($packet-&gt;getData()['AliveInterval'] * 1000, function ($watcherId) use ($socket, $packet) {             if ($socket-&gt;getResource() === null) {                 return Loop::cancel($watcherId);                }                          yield $socket-&gt;write((string) new Packet(Packet::MESSAGE_CODES['packet.request.keepAlive'], [                 'Name' =&gt; 'KeepAlive', 'SessionID' =&gt; $packet-&gt;getData()['SessionID']             ], 0, $packet-&gt;getSession()));         }));     });          $reader-&gt;on('packet.response.claim', asyncCoroutine(function (Packet $packet) use ($socket) {         yield $socket-&gt;write((string) new Packet(Packet::MESSAGE_CODES['packet.videoControl'], [             'Name' =&gt; 'OPMonitor',             'OPMonitor' =&gt; ['Action' =&gt; 'Start', 'Parameter' =&gt; ['Channel' =&gt; 0, 'CombinMode' =&gt; 'NONE', 'StreamType' =&gt; 'Main', 'TransMode'  =&gt; 'TCP']],         ], $packet-&gt;getSequence() + 1, $packet-&gt;getSession()));     }));          $emitter = new Emitter();         $reader-&gt;on('packet.binary', function ($packet) use ($emitter) {         $emitter-&gt;emit($packet-&gt;getRawData());     });          $reader-&gt;once('packet.binary', function (Packet $packet) use ($socket) {         $signalHandler = function () use ($socket, $packet) {             yield $socket-&gt;write((string) new Packet(Packet::MESSAGE_CODES['packet.videoControl'], [                 'Name' =&gt; 'OPMonitor',                 'OPMonitor' =&gt; ['Action' =&gt; 'Stop', 'Parameter' =&gt; ['Channel' =&gt; 0, 'CombinMode' =&gt; 'NONE', 'StreamType' =&gt; 'Main', 'TransMode'  =&gt; 'TCP']],             ], 0, $packet-&gt;getSession()));                          $socket-&gt;close();         };         Loop::unreference(Loop::onSignal(defined('SIGINT')  ? SIGINT  : 2,  $signalHandler, 'SIGINT'));         Loop::unreference(Loop::onSignal(defined('SIGTERM') ? SIGTERM : 15, $signalHandler, 'SIGTERM'));     });          asyncCall([$reader, 'start']);          yield $socket-&gt;write((string) new Packet(Packet::MESSAGE_CODES['packet.request.login'], [         'EncryptType' =&gt; 'MD5',         'LoginType'   =&gt; 'DVRIP-Web',         'PassWord'    =&gt; sofiaHash('123qwea'),         'UserName'    =&gt; 'admin',     ]));          yield pipe(new IteratorStream($emitter-&gt;iterate()), getStdout()); });<\/code><\/pre>\n<\/div>\n<\/div>\n<p>  \u0422\u0435\u043f\u0435\u0440\u044c \u043c\u043e\u0436\u0435\u043c \u043f\u043e\u043f\u0440\u043e\u0431\u043e\u0432\u0430\u0442\u044c \u0437\u0430\u043f\u0438\u0441\u0430\u0442\u044c \u043a\u0443\u0441\u043e\u0447\u0435\u043a \u0432\u0438\u0434\u0435\u043e \u0442\u0430\u043a\u0438\u043c \u0432\u043e\u0442 \u043e\u0431\u0440\u0430\u0437\u043e\u043c<\/p>\n<pre><code class=\"bash\">$ php recorder.php &gt; output.h264<\/code><\/pre>\n<p>  \u041c\u044b \u0434\u043e\u0431\u0430\u0432\u0438\u043b\u0438 \u043e\u0431\u0440\u0430\u0431\u043e\u0442\u0447\u0438\u043a SIGINT, \u0442\u0430\u043a \u0447\u0442\u043e \u043a\u043e\u0433\u0434\u0430 \u043d\u0430\u0434\u043e\u0435\u0441\u0442, \u043f\u0440\u043e\u0441\u0442\u043e \u043d\u0430\u0436\u043c\u0438\u0442\u0435 Ctrl+C \u0438 \u0441\u043a\u0440\u0438\u043f\u0442 \u043e\u0441\u0442\u0430\u043d\u043e\u0432\u0438\u0442 \u043f\u0435\u0440\u0435\u0434\u0430\u0447\u0443 \u0432\u0438\u0434\u0435\u043e \u0438 \u043d\u043e\u0440\u043c\u0430\u043b\u044c\u043d\u043e \u0437\u0430\u043a\u0440\u043e\u0435\u0442 \u0441\u043e\u0435\u0434\u0438\u043d\u0435\u043d\u0438\u0435. <\/p>\n<p>  \u0410 \u0435\u0449\u0435 \u043c\u044b \u043c\u043e\u0436\u0435\u043c, \u043d\u0430\u043f\u0440\u0438\u043c\u0435\u0440, \u043f\u0435\u0440\u0435\u043d\u0430\u043f\u0440\u0430\u0432\u0438\u0442\u044c \u043f\u043e\u0442\u043e\u043a \u0432 ffmpeg \u0438 \u043f\u0435\u0440\u0435\u043a\u043e\u0434\u0438\u0440\u043e\u0432\u0430\u0442\u044c \u043d\u0430 \u043b\u0435\u0442\u0443.<\/p>\n<pre><code class=\"bash\">$ php recorder.php | ffmpeg -nostdin -y -hide_banner -loglevel verbose -f h264 -i pipe:0 -pix_fmt yuv420p -c copy -movflags +frag_keyframe+empty_moov+default_base_moof -reset_timestamps 1 -f mpegts output.mpegts<\/code><\/pre>\n<p>  \u0410 \u043c\u043e\u0436\u043d\u043e \u0433\u043e\u0440\u043e\u0434\u0438\u0442\u044c \u0432\u043e\u043e\u0431\u0449\u0435 \u043d\u0435\u0438\u0441\u0442\u043e\u0432\u044b\u0435 \u0446\u0435\u043f\u043e\u0447\u043a\u0438 \u0432\u0438\u0434\u0430 <\/p>\n<pre><code class=\"bash\">$ php recorder.php | ffmpeg ... | curl -d @- ... <\/code><\/pre>\n<p>  \u0437\u0430\u043f\u0443\u0441\u043a\u0430\u044f \u0432\u0441\u0435 \u044d\u0442\u043e \u043a\u0430\u043a\u0438\u043c-\u043d\u0438\u0431\u0443\u0434\u044c \u0441\u043a\u0440\u0438\u043f\u0442\u043e\u043c, \u043a\u043e\u0442\u043e\u0440\u044b\u0439 \u0431\u0443\u0434\u0435\u0442 \u043f\u0435\u0440\u0435\u0437\u0430\u043f\u0443\u0441\u043a\u0430\u0442\u044c \u043a\u0430\u0436\u0434\u044b\u0439 \u0447\u0430\u0441, \u0442\u0430\u043a\u0438\u043c \u043e\u0431\u0440\u0430\u0437\u043e\u043c \u043c\u044b \u043f\u043e\u043b\u0443\u0447\u0438\u043c \u0440\u043e\u0432\u043d\u044b\u0435 \u043a\u0443\u0441\u043e\u0447\u043a\u0438 \u043f\u0440\u043e\u0434\u043e\u043b\u0436\u0438\u0442\u0435\u043b\u044c\u043d\u043e\u0441\u0442\u044c\u044e \u0432 1 \u0447\u0430\u0441, \u043d\u0430 \u043b\u0435\u0442\u0443 \u0437\u0430\u043b\u0438\u0432\u0430\u0435\u043c\u044b\u0435 \u043a\u0443\u0434\u0430 \u043d\u0430\u043c \u043d\u0430\u0434\u043e.<\/p>\n<h3>\u0417\u0430\u0447\u0435\u043c?<\/h3>\n<p>  \u042f \u0441\u043a\u043b\u043e\u043d\u0435\u043d \u043f\u043e\u043b\u0430\u0433\u0430\u0442\u044c, \u0447\u0442\u043e \u044d\u0442\u0430 \u0441\u0442\u0430\u0442\u044c\u044f \u0432\u044b\u0437\u043e\u0432\u0435\u0442 \u0443 \u043c\u043d\u043e\u0433\u0438\u0445 \u0432\u043e\u043f\u0440\u043e\u0441 \u00ab\u0410 \u0437\u0430\u0447\u0435\u043c?\u00bb. \u0415\u0441\u0442\u044c \u0433\u043e\u0442\u043e\u0432\u044b\u0435 \u0440\u0435\u0448\u0435\u043d\u0438\u044f \u0434\u043b\u044f \u0440\u0435\u0433\u0438\u0441\u0442\u0440\u0430\u0446\u0438\u0438 \u0441 \u043a\u0430\u043c\u0435\u0440, \u043a\u0430\u043c\u0435\u0440\u044b \u0432 \u0446\u0435\u043b\u043e\u043c \u0441\u0430\u043c\u0438 \u043c\u043d\u043e\u0433\u043e \u0447\u0435\u0433\u043e \u0443\u043c\u0435\u044e\u0442, \u043a\u0430\u043a \u0441\u043f\u0440\u0430\u0432\u0435\u0434\u043b\u0438\u0432\u043e \u0432\u043e\u0437\u0440\u0430\u0437\u0438\u043b\u0438 \u0432 \u043a\u043e\u043c\u043c\u0435\u043d\u0442\u0430\u0440\u0438\u044f\u0445 \u043a \u043f\u0440\u043e\u0448\u043b\u043e\u0439 \u0441\u0442\u0430\u0442\u044c\u0435, \u0438 \u0432\u043e\u043e\u0431\u0449\u0435 \u043c\u043e\u0436\u043d\u043e \u0431\u044b\u043b\u043e \u0441\u0434\u0435\u043b\u0430\u0442\u044c \u0432\u0441\u0435 \u043a\u0443\u0434\u0430 \u043f\u0440\u043e\u0449\u0435.<\/p>\n<p>  \u041f\u0440\u043e\u0441\u0442\u043e \u0443 \u043c\u0435\u043d\u044f \u0431\u044b\u043b\u043e \u0441\u0432\u043e\u0431\u043e\u0434\u043d\u043e\u0435 \u0432\u0440\u0435\u043c\u044f, \u043a\u043e\u0442\u043e\u0440\u043e\u0435 \u043d\u0443\u0436\u043d\u043e \u0431\u044b\u043b\u043e \u043a\u0443\u0434\u0430-\u0442\u043e \u0434\u0435\u0432\u0430\u0442\u044c, \u0436\u0435\u043b\u0430\u043d\u0438\u0435 \u0441\u0434\u0435\u043b\u0430\u0442\u044c \u043f\u043e-\u0441\u0432\u043e\u0435\u043c\u0443 \u0438 \u043d\u0435\u0443\u0435\u043c\u043d\u0430\u044f \u0442\u044f\u0433\u0430 \u043a \u044d\u043a\u0441\u043f\u0435\u0440\u0438\u043c\u0435\u043d\u0442\u0430\u043c.<\/p>\n<p>  \u0418 \u044d\u0442\u043e \u0440\u0430\u0431\u043e\u0442\u0430\u0435\u0442.<\/p>\n<p>  \u041a\u043e\u043d\u0435\u0447\u043d\u043e, \u0441\u043a\u0440\u0438\u043f\u0442, \u043f\u0440\u0435\u0434\u0441\u0442\u0430\u0432\u043b\u0435\u043d\u043d\u044b\u0439 \u0432 \u0441\u0442\u0430\u0442\u044c\u0435, \u0442\u0440\u0435\u0431\u0443\u0435\u0442 \u043d\u0435\u043a\u043e\u0442\u043e\u0440\u044b\u0445 \u0434\u043e\u0434\u0435\u043b\u044b\u0432\u0430\u043d\u0438\u0439, \u0438 \u0432 \u0442\u0430\u043a\u043e\u043c \u0432\u0438\u0434\u0435 \u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u044c\u0441\u044f \u0438\u043c \u043d\u0435 \u0441\u0442\u043e\u0438\u0442 \u2014 \u043f\u043e\u0432\u0442\u043e\u0440\u044e\u0441\u044c, \u044d\u0442\u043e proof of concept. \u0418 \u0432\u043e\u043e\u0431\u0449\u0435, \u044f \u0432\u0430\u0441 \u0432\u0441\u044f\u0447\u0435\u0441\u043a\u0438 \u043f\u0440\u0435\u0434\u043e\u0441\u0442\u0435\u0440\u0435\u0433\u0430\u044e \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u044c \u043d\u0430\u043a\u043e\u043b\u0435\u043d\u043d\u044b\u0435 \u0441\u0430\u043c\u043e\u0434\u0435\u043b\u043a\u0438 \u0432 \u043e\u0431\u0435\u0441\u043f\u0435\u0447\u0435\u043d\u0438\u0438 \u0431\u0435\u0437\u043e\u043f\u0430\u0441\u043d\u043e\u0441\u0442\u0438 \u0441\u0432\u043e\u0435\u0433\u043e \u0434\u043e\u043c\u0430. <br \/>  \u0412 \u043c\u043e\u0435\u043c \u0441\u043b\u0443\u0447\u0430\u0435 \u043d\u0430\u0434\u0435\u0436\u043d\u043e\u0441\u0442\u044c \u043d\u0435 \u043d\u0430\u0441\u0442\u043e\u043b\u044c\u043a\u043e \u043a\u0440\u0438\u0442\u0438\u0447\u043d\u0430, \u0442\u0430\u043a \u0447\u0442\u043e \u0441\u0440\u0430\u0431\u043e\u0442\u0430\u0435\u0442 \u0438 \u0442\u0430\u043a\u043e\u0439 \u0432\u0430\u0440\u0438\u0430\u043d\u0442. \u041d\u0430\u0434 \u044d\u0442\u0438\u043c \u0441\u043a\u0440\u0438\u043f\u0442\u043e\u043c \u043a\u0440\u0443\u0442\u0438\u0442\u0441\u044f \u0441\u043a\u0440\u0438\u043f\u0442-\u0432\u043e\u0442\u0447\u0435\u0440, \u043a\u043e\u0442\u043e\u0440\u044b\u0439 \u043f\u0435\u0440\u0435\u0434\u0430\u0435\u0442 \u043f\u043e\u0442\u043e\u043a \u0432 ffmpeg, \u0437\u0430\u043f\u0438\u0441\u044b\u0432\u0430\u044f \u043a\u0443\u0441\u043a\u0438 \u043f\u043e \u0447\u0430\u0441\u0443 \u0438 \u0437\u0430\u043b\u0438\u0432\u0430\u0435\u0442 \u0438\u0445 \u0432 \u0432\u043a, \u043f\u0435\u0440\u0435\u0437\u0430\u043f\u0443\u0441\u043a\u0430\u044f \u0441\u043a\u0440\u0438\u043f\u0442 \u0432 \u0441\u043b\u0443\u0447\u0430\u0435 \u043e\u0431\u0440\u044b\u0432\u0430 \u0441\u0432\u044f\u0437\u0438 \u0438\u043b\u0438 \u043a\u0430\u043a\u0438\u0445-\u0442\u043e \u043d\u0435\u043f\u0440\u0435\u0434\u0432\u0438\u0434\u0435\u043d\u043d\u043e\u0441\u0442\u0435\u0439.<\/p>\n<p>  \u0410 \u0432\u043e\u043e\u0431\u0449\u0435 \u0432\u0441\u0435\u0433\u043e \u044d\u0442\u043e\u0433\u043e \u043c\u043e\u0436\u043d\u043e \u0431\u044b\u043b\u043e \u0431\u044b \u0438\u0437\u0431\u0435\u0436\u0430\u0442\u044c, \u043f\u0440\u043e\u0441\u0442\u043e \u0432\u044b\u0442\u0430\u0441\u043a\u0438\u0432\u0430\u044f \u0432\u0438\u0434\u0435\u043e \u043f\u043e RTSP over TCP, \u043a\u0430\u043a \u044f \u043f\u0440\u0435\u0434\u043b\u0430\u0433\u0430\u043b \u0432 \u043a\u043e\u043d\u0446\u0435 \u043f\u0440\u0435\u0434\u044b\u0434\u0443\u0449\u0435\u0439 \u0441\u0442\u0430\u0442\u044c\u0438, \u043d\u043e ffmpeg \u043b\u044e\u0431\u0438\u043b \u043f\u0440\u0435\u0434\u0430\u0442\u0435\u043b\u044c\u0441\u043a\u0438 \u0437\u0430\u0433\u043b\u043e\u0445\u043d\u0443\u0442\u044c \u0432 \u0441\u043b\u0443\u0447\u0430\u0439\u043d\u044b\u0439 \u043c\u043e\u043c\u0435\u043d\u0442 \u0432\u0440\u0435\u043c\u0435\u043d\u0438 \u0438 \u043d\u0430\u0447\u0430\u0442\u044c \u0440\u0435\u0430\u0433\u0438\u0440\u043e\u0432\u0430\u0442\u044c \u0442\u043e\u043b\u044c\u043a\u043e \u043d\u0430 SIGKILL.<\/p>\n<p>  \u042f \u043d\u0430\u0447\u0430\u043b \u043f\u043e\u0434\u043e\u0437\u0440\u0435\u0432\u0430\u0442\u044c, \u0447\u0442\u043e \u0432\u0441\u0435 \u044d\u0442\u043e \u043f\u043e\u0442\u043e\u043c\u0443 \u0447\u0442\u043e \u0440\u043e\u0434\u0438\u0442\u0435\u043b\u044c\u0441\u043a\u0438\u0439 \u0441\u043a\u0440\u0438\u043f\u0442-\u0432\u043e\u0442\u0447\u0435\u0440 \u0437\u0430\u043f\u0443\u0441\u043a\u0430\u043b\u0441\u044f \u043a\u0440\u043e\u043d\u043e\u043c \u0438 \u043f\u043e\u043b\u0443\u0447\u0430\u043b \u043f\u043e\u043d\u0438\u0436\u0435\u043d\u043d\u044b\u0439 \u043f\u0440\u0438\u043e\u0440\u0438\u0442\u0435\u0442, \u043d\u043e \u0443\u0432\u0435\u043b\u0438\u0447\u0435\u043d\u0438\u0435 \u043f\u0440\u0438\u043e\u0440\u0438\u0442\u0435\u0442\u0430 \u043b\u0438\u0448\u044c \u0441\u043d\u0438\u0437\u0438\u043b\u043e \u0447\u0430\u0441\u0442\u043e\u0442\u0443 \u043f\u043e\u044f\u0432\u043b\u0435\u043d\u0438\u044f \u043f\u0440\u043e\u0431\u043b\u0435\u043c\u044b. <\/p>\n<p>  \u0412 \u0441\u043b\u0443\u0447\u0430\u0435 \u0436\u0435 \u0441 \u0432\u044b\u0448\u0435\u0438\u0437\u043b\u043e\u0436\u0435\u043d\u043d\u044b\u043c \u0441\u043a\u0440\u0438\u043f\u0442\u043e\u043c \u0432\u0441\u0435 \u0440\u0430\u0431\u043e\u0442\u0430\u0435\u0442 \u043a\u0443\u0434\u0430 \u0441\u0442\u0430\u0431\u0438\u043b\u044c\u043d\u0435\u0439 \u0438 \u043f\u043e\u043a\u0430 \u043d\u0430\u0440\u0435\u043a\u0430\u043d\u0438\u0439 \u043d\u0435 \u0432\u044b\u0437\u044b\u0432\u0430\u043b\u043e.<\/p><\/div>\n<p> \u0441\u0441\u044b\u043b\u043a\u0430 \u043d\u0430 \u043e\u0440\u0438\u0433\u0438\u043d\u0430\u043b \u0441\u0442\u0430\u0442\u044c\u0438 <a href=\"https:\/\/habr.com\/ru\/post\/484518\/\"> https:\/\/habr.com\/ru\/post\/484518\/<\/a><\/p>\n","protected":false},"excerpt":{"rendered":"\n<div class=\"post__text post__text-html\" id=\"post-content-body\" data-io-article-url=\"https:\/\/habr.com\/ru\/post\/484518\/\">\u0412 <a href=\"https:\/\/habr.com\/ru\/post\/482864\/\">\u043f\u0440\u043e\u0448\u043b\u043e\u0439 \u0441\u0442\u0430\u0442\u044c\u0435<\/a> \u044f \u043e\u0431\u0435\u0449\u0430\u043b \u043f\u043e\u043a\u0430\u0437\u0430\u0442\u044c \u0441\u043a\u0440\u0438\u043f\u0442, \u043a\u043e\u0442\u043e\u0440\u044b\u043c \u0442\u044f\u043d\u0443 \u0432\u0438\u0434\u0435\u043e \u0441 \u043a\u0430\u043c\u0435\u0440\u044b \u0438, \u0445\u043e\u0442\u044f \u0441 \u0442\u0435\u0445 \u043f\u043e\u0440 \u043f\u0440\u043e\u0448\u043b\u043e \u0432\u0441\u0435 \u0436\u0435 \u043d\u0435\u043a\u043e\u0442\u043e\u0440\u043e\u0435 \u043a\u043e\u043b\u0438\u0447\u0435\u0441\u0442\u0432\u043e \u0432\u0440\u0435\u043c\u0435\u043d\u0438, \u043e\u0431\u0435\u0449\u0430\u043d\u0438\u044f \u0436\u0435 \u043d\u0443\u0436\u043d\u043e \u0432\u044b\u043f\u043e\u043b\u043d\u044f\u0442\u044c. \u0412\u043e\u0442 \u044f \u0438 \u0432\u044b\u043f\u043e\u043b\u043d\u044f\u044e.<\/p>\n<p>  \u0422\u0430\u043a \u0443\u0436 \u0432\u044b\u0448\u043b\u043e, \u0447\u0442\u043e \u0441 \u0430\u0441\u0438\u043d\u0445\u0440\u043e\u043d\u043d\u043e\u0441\u0442\u044c\u044e \u0432 \u043c\u0438\u0440\u0435 \u0441\u0435\u0440\u0432\u0435\u0440\u043d\u043e\u0433\u043e web \u0430\u0441\u0441\u043e\u0446\u0438\u0438\u0440\u0443\u0435\u0442\u0441\u044f \u0432\u0441\u0435 \u0447\u0442\u043e \u0443\u0433\u043e\u0434\u043d\u043e, \u043d\u043e \u043d\u0435 PHP.<\/p>\n<p>  \u041d\u0443 \u043f\u043e\u0442\u043e\u043c\u0443 \u0447\u0442\u043e, \u043d\u0443 \u0432\u044b \u0437\u043d\u0430\u0435\u0442\u0435, \u0432\u043e\u0442 \u044d\u0442\u0430 \u0443\u043c\u0438\u0440\u0430\u044e\u0449\u0430\u044f \u043c\u043e\u0434\u0435\u043b\u044c, \u0443\u0442\u0435\u0447\u043a\u0438 \u043f\u0430\u043c\u044f\u0442\u0438, \u0434\u0430 \u0438 \u0432\u043e\u043e\u0431\u0449\u0435 \u0432 PHP \u0438\u0437 \u043a\u043e\u0440\u043e\u0431\u043a\u0438 \u043d\u0435\u0442 \u043d\u0438\u0447\u0435\u0433\u043e, \u043a\u0440\u043e\u043c\u0435 <a href=\"https:\/\/www.php.net\/manual\/ru\/function.stream-select.php\">stream_select()<\/a> \u0438 <a href=\"https:\/\/www.php.net\/manual\/ru\/function.stream-select.php\">stream_set_blocking()<\/a>. <\/p>\n<p>  \u0413\u0434\u0435-\u0442\u043e \u0442\u0430\u043c, \u043d\u0430 PECL, \u0435\u0441\u0442\u044c \u043a\u0430\u043a\u043e\u0439-\u0442\u043e <a href=\"https:\/\/pecl.php.net\/package\/uv\">libuv<\/a>, \u043a\u043e\u0442\u043e\u0440\u044b\u0439 \u0432 \u043f\u0440\u0438\u043d\u0446\u0438\u043f\u0435 \u0432\u0441\u0435\u0433\u043e \u043b\u0438\u0448\u044c \u043e\u0431\u0435\u0440\u0442\u043a\u0430 \u0434\u043b\u044f \u0441\u0438\u0448\u043d\u044b\u0445 \u0444\u0443\u043d\u043a\u0446\u0438\u0439 \u043e\u0440\u0438\u0433\u0438\u043d\u0430\u043b\u044c\u043d\u043e\u0439 \u0431\u0438\u0431\u043b\u0438\u043e\u0442\u0435\u043a\u0438, \u043f\u043e\u044d\u0442\u043e\u043c\u0443 \u0435\u0433\u043e \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u043d\u0438\u0435 \u043a\u0430\u043a \u0435\u0441\u0442\u044c \u0431\u0440\u043e\u0441\u0430\u0435\u0442 \u0432\u0430\u043c \u043d\u0435\u043a\u043e\u0442\u043e\u0440\u044b\u0435 \u0432\u044b\u0437\u043e\u0432\u044b. \u0414\u0430 \u0438 \u0432\u043e\u043e\u0431\u0449\u0435, \u043a\u0442\u043e \u0432 \u0437\u0434\u0440\u0430\u0432\u043e\u043c \u0443\u043c\u0435 \u0431\u0443\u0434\u0435\u0442 \u044d\u0442\u0438\u043c \u0437\u0430\u043d\u0438\u043c\u0430\u0442\u044c\u0441\u044f?<\/p>\n<p>  \u041d\u043e \u0435\u0441\u043b\u0438 \u043c\u044b \u043f\u0435\u0440\u0435\u0441\u0442\u0430\u043d\u0435\u043c \u0436\u0438\u0442\u044c \u0432 \u043c\u0438\u0440\u0435 PHP4 \u0438 \u043d\u0435\u043c\u043d\u043e\u0433\u043e \u0432\u0435\u0440\u043d\u0435\u043c\u0441\u044f \u0432 \u0441\u043e\u0432\u0440\u0435\u043c\u0435\u043d\u043d\u044b\u0435 \u0440\u0435\u0430\u043b\u0438\u0438, \u0442\u043e \u0443\u0432\u0438\u0434\u0438\u043c, \u0447\u0442\u043e \u0437\u0430 \u043f\u043e\u0441\u043b\u0435\u0434\u043d\u0438\u0435 \u0433\u043e\u0434\u044b \u0434\u0435\u043b\u0430 \u043d\u0435\u0441\u043a\u043e\u043b\u044c\u043a\u043e \u0438\u0437\u043c\u0435\u043d\u0438\u043b\u0438\u0441\u044c. \u0423 \u043d\u0430\u0441 \u043f\u043e\u044f\u0432\u0438\u043b\u0438\u0441\u044c \u0442\u0430\u043a\u0438\u0435 \u0438\u043d\u0442\u0435\u0440\u0435\u0441\u043d\u044b\u0435 \u0438\u043d\u0441\u0442\u0440\u0443\u043c\u0435\u043d\u0442\u044b \u043a\u0430\u043a <b>ReactPHP<\/b> \u0438 <b>AmPHP<\/b>, \u043a\u043e\u043c\u043f\u043e\u043d\u0435\u043d\u0442\u044b \u043a\u043e\u0442\u043e\u0440\u044b\u0445 \u0445\u043e\u0440\u043e\u0448\u043e \u043f\u043e\u043a\u0440\u044b\u0432\u0430\u044e\u0442 \u0444\u0443\u043d\u043a\u0446\u0438\u043e\u043d\u0430\u043b Node.js, \u0430 \u043d\u0430\u043b\u0438\u0447\u0438\u0435 \u0433\u0435\u043d\u0435\u0440\u0430\u0442\u043e\u0440\u043e\u0432 \u043f\u043e\u0437\u0432\u043e\u043b\u044f\u0435\u0442 \u043f\u0438\u0441\u0430\u0442\u044c \u0430\u0441\u0438\u043d\u0445\u0440\u043e\u043d\u043d\u044b\u0439 \u043a\u043e\u0434 \u0432 \u0443\u0434\u043e\u0431\u043d\u043e\u043c \u0441\u0442\u0438\u043b\u0435, \u043f\u043e\u0434\u043e\u0431\u043d\u043e\u043c <i>async\/await<\/i>, \u0438\u0437\u0431\u0435\u0433\u0430\u044f \u0432\u0441\u0435\u0445 \u0432\u043e\u0442 \u044d\u0442\u0438\u0445 \u0431\u0435\u0441\u043a\u043e\u043d\u0435\u0447\u043d\u044b\u0445 \u043a\u043e\u043b\u043b\u0431\u0435\u043a\u043e\u0432 \u0432 \u043a\u043e\u043b\u043b\u0431\u0435\u043a\u0430\u0445 \u0438 \u043a\u0438\u043b\u043e\u043c\u0435\u0442\u0440\u043e\u0432\u044b\u0445 \u0446\u0435\u043f\u043e\u0447\u0435\u043a <i>.then().then().then()<\/i>.<\/p>\n<p>  \u0422\u0430\u043a \u0447\u0442\u043e \u043f\u043e\u044d\u0442\u043e\u043c\u0443 \u0441\u0435\u0439\u0447\u0430\u0441, \u043a\u0430\u043a \u043c\u043d\u0435 \u043a\u0430\u0436\u0435\u0442\u0441\u044f, \u043f\u0440\u0430\u043a\u0442\u0438\u0447\u0435\u0441\u043a\u0438 \u043d\u0435\u0442 \u0442\u0435\u0445 \u0437\u0430\u0434\u0430\u0447 \u0438\u0437 \u043c\u0438\u0440\u0430 Node.js, \u043a\u043e\u0442\u043e\u0440\u044b\u0435 \u043d\u0435 \u043c\u043e\u0433 \u0431\u044b \u0440\u0435\u0448\u0438\u0442\u044c PHP. \u041d\u043e \u0435\u0441\u043b\u0438 \u0442\u0430\u043a\u043e\u0432\u044b\u0435 \u0435\u0449\u0435 \u043e\u0441\u0442\u0430\u043b\u0438\u0441\u044c, \u0442\u043e \u0432\u0441\u0435 \u0443\u043f\u0438\u0440\u0435\u0442\u0441\u044f \u0442\u043e\u043b\u044c\u043a\u043e \u0432 \u043d\u0430\u043b\u0438\u0447\u0438\u0435 \u043a\u0430\u043a\u0438\u0445-\u0442\u043e \u043e\u0442\u0434\u0435\u043b\u044c\u043d\u044b\u0445 \u0431\u0438\u0431\u043b\u0438\u043e\u0442\u0435\u043a, \u0430 \u043d\u0435 \u043e\u0442\u0441\u0443\u0442\u0441\u0442\u0432\u0438\u0435 \u0432\u043e\u0437\u043c\u043e\u0436\u043d\u043e\u0441\u0442\u0435\u0439 \u043a\u0430\u043a \u0442\u0430\u043a\u043e\u0432\u044b\u0445.   <\/p>\n<blockquote><p>It may surprise people to learn that the PHP standard library already has everything we need to write event-driven and non-blocking applications. We only reach the limits of native PHP\u2019s functionality in this area when we ask it to poll thousands of file descriptors for IO activity at the same time. Even in this case, though, the fault is not with PHP but the underlying system select() call which is linear in its performance degradation as load increases.<\/p>\n<p>  <i><a href=\"https:\/\/amphp.org\/amp\/event-loop\/\">amphp.org\/amp\/event-loop<\/a><\/i><\/p><\/blockquote>\n","protected":false},"author":1,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[],"tags":[],"class_list":["post-297406","post","type-post","status-publish","format-standard","hentry"],"_links":{"self":[{"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=\/wp\/v2\/posts\/297406","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=%2Fwp%2Fv2%2Fcomments&post=297406"}],"version-history":[{"count":0,"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=\/wp\/v2\/posts\/297406\/revisions"}],"wp:attachment":[{"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=%2Fwp%2Fv2%2Fmedia&parent=297406"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=%2Fwp%2Fv2%2Fcategories&post=297406"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=%2Fwp%2Fv2%2Ftags&post=297406"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}