一提到高并发，就没有办法绕开I/O复用，再细致到特定的平台linux, 就没办法绕开epoll. epoll为啥高效的道理就不讲了，感兴致的同砚能够自行搜刮研究一下。
php怎样玩epoll？起首得装置个libevent库，再装个event扩大或许libevent扩大就能够愉快地游玩了.
有些人搞不清楚libevent库跟libevent扩大的区分，简朴来讲，libevent库是C言语对epoll的封装，跟PHP毛关联都没有；libevent扩大就是PHP跟libevent库的沟通桥梁。实际上PHP的许多扩大就是干这个事的，有一些优异的C言语库，PHP想直接拿来用，就经由过程PHP扩大的体式格局接入到PHP。
libevent扩大和event扩大随意选一个装，我个人更喜好event扩大，由于更面向对象一点。自身去http://pecl.php.net内里搜跟自身PHP版本对应的扩大，下好编译装置一下就OK了.电脑装了多个版本的PHP编译的时刻注重一下，phpize的版本要对应上，别搞错了，典范的五步曲:
phpize ./configure make make install php -m | grep event #看看装上了没
我们要完成的服务器，传输层是TCP协定，应用层协定太多太庞杂，限于篇幅，会简朴地以HTTP服务器举个例子，HTTP协定自身就很庞杂，要完成起来细节上有许多精细精美，我们也不会完整完成HTTP协定。
起首，建立一个socket，三步曲，socket_create、socket_bind、socket_listen，为何是这三步曲呢？很简朴，不论你传输层协定是啥，你下面的收集层协定你得选个版本吧，IPV4照样IPV6，传输层事情体式格局你得选一个吧，全双工、半双工照样单工，TCP照样UDP你也得选一个吧，socket_create就是这三个选项；肯定了收集层和传输层，你得告诉我监听哪一个端口吧，这就对应了socket_bind；然后你得开启监听，并指定一个客户端的行列长度吧，这就是socket_listen干的事。
建立完了，同步壅塞咱就不引见了，一个历程同时最多hold处一个衔接，多几个衔接同时要求，就得等呗，超过了socket_listen指定的行列长度，就得返回504了。多历程也一样，几个历程就有几个并发，历程又是高贵资本，而且历程的上下文切换费时辛苦，致使全部体系效力低下。
没紧要，咱有epoll，hold住万千要求不是梦，先完成一个Reactor。libevent库就是Reactor形式，直接挪用函数就是在运用Reactor形式，所以无需纠结究竟php怎样完成Reactor形式。
<?php
use Event;
use EventBase;
class Reactor
{
protected $reactor;
protected $events;
public static $instance = null;
const READ = Event::READ | Event::PERSIST;
const WRITE = Event::WRITE | Event::PERSIST;
public static function getInstance()
{
if (is_null(self::$instance)) {
self::$instance = new self();
self::$instance->reactor = new EventBase;
}
return self::$instance;
}
public function add($fd, $what, $cb, $arg = null)
{
switch ($what) {
case self::READ:
$event = new Event($this->reactor, $fd, self::READ, $cb, $arg);
break;
case self::WRITE:
$event = new Event($this->reactor, $fd, self::WRITE, $cb, $arg);
break;
default:
$event = new Event($this->reactor, $fd, $what, $cb, $arg);
break;
}
$event->add();
$this->events[(int) $fd][$what] = $event;
}
public function del($fd, $what = 'all')
{
$events = $this->events[(int) $fd];
if ($what == 'all') {
foreach ($events as $event) {
$event->free();
}
} else {
if ($what != self::READ && $what != self::WRITE) {
throw new \Exception('不存在的事宜');
}
$events[$what]->free();
}
}
public function run()
{
$this->reactor->loop();
}
public function stop()
{
foreach ($this->events as $events) {
foreach ($events as $event) {
$event->free();
}
}
$this->reactor->stop();
}
}
上面的代码很简朴，简朴解释一下观点，EventBase就是个容器，内里装的Event实例，这么一说，上面的代码就非常好懂了。 然后一个Server.
<?php use Throwable;use Monolog\Handler\StreamHandler;class Server{ protected $ip; protected $port; protected $socket; protected $reactor; public function __construct($ip, $port)
{ $this->ip = $ip; $this->port = $port;
} public function start()
{
$socket = $this->createTcpConnection();
stream_set_blocking($socket, false);
Reactor::getInstance()->add($socket, Reactor::READ, function($socket) {
$conn = stream_socket_accept($socket);
stream_set_blocking($conn, false);
(new Connection($conn))->handle();
});
Reactor::getInstance()->run();
} public function createTcpConnection()
{
$schema = sprintf("tcp://%s:%d", $this->ip, $this->port);
$socket = stream_socket_server($schema, $errno, $errstr); if ($errno) { throw new \Exception($errstr);
} return $socket;
}
}
Connection
<?phpclass Connection{ protected $conn; protected $read_buffer = ''; protected $write_buffer = ''; public function __construct($conn)
{ $this->conn = $conn;
} public function handle()
{
Reactor::getInstance()->add($this->conn, Reactor::READ, \Closure::fromCallable([$this, 'read']));
} private function read($conn)
{ $this->read_buffer = ''; if (is_resource($conn)) { while ($content = fread($conn, 65535)) { $this->read_buffer .= $content;
}
} if ($this->read_buffer) {
Reactor::getInstance()->add($conn, Reactor::WRITE, \Closure::fromCallable([$this, 'write']));
} else {
Reactor::getInstance()->del($conn);
fclose($conn);
}
} private function write($conn)
{ if (is_resource($conn)) {
fwrite($conn, "HTTP/1.1 200 OK\r\nContent-Type: text/html;charset=utf8\r\nContent-Length:11\r\nConnection: keep-alive\r\n\r\nHello!world");
}
}
}
先建立Socket的三步曲，设置成非壅塞形式。然后把socket加到Reactor中监听可读事宜，可读的意义就是，缓冲区有数据了，才可读。可读事宜发作，申明有新衔接来了，用stream_socket_accept吸收新衔接Conn，把Conn放到Reactor中监听可读事宜，可读事宜发作，申明客户端有数据发送过来了，轮回读直到没数据，然后把Conn放到Reactor中监听可写事宜，可写事宜发作，申明客户端数据发送完了，把协定组装一下写入相应。
应用层如果是HTTP协定要注重一下Connection: keep-alive头，由于要复用衔接，不要一写完就封闭衔接。
撸完收工，用ab测一下并发，加-k参数复用衔接，i5+8G，3W的并发没啥题目，固然我们这儿没有磁盘I/O，实际情况要从磁盘读取文件，读文件要经由过程linux的体系挪用，而且有频频的文件拷贝操纵，花消比较大，经常使用的处理思绪是sendfile，零拷贝直接从一个FD到另一个FD，效力比较高，瑕玷就是PHP没有现成的已完成sendfile的扩大，得自身着手，开辟本钱有点高。
ab测试PO图：
这就是PHP完成高并发服务器的思绪了，只如果用EPOLL处理的，思绪都一样，都是三步曲，放到Reactor下监听FD事宜。固然这个只是最简朴的模子，另有许多能够革新的处所，比如说多历程，剽窃一下nginx，一个主历程+N个事情历程，多历程的目标照样想应用多核并行事情。C言语完成也是如许，只是你能够不必libevent库，自身封装EPOLL,毕竟libevent库有点重，你也用不到libevent的许多东西；固然了，C言语有一堆的数据结构以及定义在数据结构上的操纵要写，没有GC，自身治理内存，还要有优越的设想，上多历程还得搞一搞IPC历程间通讯的东西，开辟难度比PHP要大地多，开辟周期也很长，有兴致的同砚能够自身撸一个玩。
更多PHP相干技术文章，请接见PHP教程栏目举行进修！
以上就是用PHP完成高并发服务器的细致内容，更多请关注ki4网别的相干文章！
