這篇文章主要介紹了如何用PHP實(shí)現(xiàn)高并發(fā)服務(wù)器，具有一定借鑒價(jià)值，需要的朋友可以參考下。希望大家閱讀完這篇文章后大有收獲。下面讓小編帶著大家一起了解一下。
php怎么玩epoll？首先得安裝個(gè)libevent庫，再裝個(gè)event擴(kuò)展或者libevent擴(kuò)展就可以愉快地玩耍了.
有些人搞不清楚libevent庫跟libevent擴(kuò)展的區(qū)別，簡單來說，libevent庫是C語言對epoll的封裝，跟PHP毛關(guān)系都沒有；libevent擴(kuò)展就是PHP跟libevent庫的溝通橋梁。實(shí)際上PHP的很多擴(kuò)展就是干這個(gè)事的，有一些優(yōu)秀的C語言庫，PHP想直接拿來用，就通過PHP擴(kuò)展的方式接入到PHP。
libevent擴(kuò)展和event擴(kuò)展隨便選一個(gè)裝，我個(gè)人更喜歡event擴(kuò)展，因?yàn)楦嫦驅(qū)ο笠稽c(diǎn)。自己去http://pecl.php.net里面搜跟自己PHP版本對應(yīng)的擴(kuò)展，下好編譯安裝一下就OK了.電腦裝了多個(gè)版本的PHP編譯的時(shí)候注意一下，phpize的版本要對應(yīng)上，別搞錯(cuò)了，典型的五步曲:
phpize ./configure make make install php -m | grep event #看看裝上了沒
我們要實(shí)現(xiàn)的服務(wù)器，傳輸層是TCP協(xié)議，應(yīng)用層協(xié)議太多太復(fù)雜，限于篇幅，會簡單地以HTTP服務(wù)器舉個(gè)例子，HTTP協(xié)議本身就很復(fù)雜，要實(shí)現(xiàn)起來細(xì)節(jié)上有很多考究，我們也不會完全實(shí)現(xiàn)HTTP協(xié)議。
首先，創(chuàng)建一個(gè)socket，三步曲，socket_create、socket_bind、socket_listen，為什么是這三步曲呢？很簡單，不管你傳輸層協(xié)議是啥，你下面的網(wǎng)絡(luò)層協(xié)議你得選個(gè)版本吧，IPV4還是IPV6，傳輸層工作方式你得選一個(gè)吧，全雙工、半雙工還是單工，TCP還是UDP你也得選一個(gè)吧，socket_create就是這三個(gè)選項(xiàng)；確定了網(wǎng)絡(luò)層和傳輸層，你得告訴我監(jiān)聽哪個(gè)端口吧，這就對應(yīng)了socket_bind；然后你得開啟監(jiān)聽，并指定一個(gè)客戶端的隊(duì)列長度吧，這就是socket_listen干的事。
創(chuàng)建完了，同步阻塞咱就不介紹了，一個(gè)進(jìn)程同時(shí)最多hold處一個(gè)連接，多幾個(gè)連接同時(shí)請求，就得等唄，超過了socket_listen指定的隊(duì)列長度，就得返回504了。多進(jìn)程也一樣，幾個(gè)進(jìn)程就有幾個(gè)并發(fā)，進(jìn)程又是昂貴資源，而且進(jìn)程的上下文切換費(fèi)時(shí)費(fèi)力，導(dǎo)致整個(gè)系統(tǒng)效率低下。
沒關(guān)系，咱有epoll，hold住萬千請求不是夢，先實(shí)現(xiàn)一個(gè)Reactor。libevent庫就是Reactor模式，直接調(diào)用函數(shù)就是在使用Reactor模式，所以無需糾結(jié)到底php怎么實(shí)現(xiàn)Reactor模式。
重慶分公司
重慶分公司
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就是個(gè)容器，里面裝的Event實(shí)例，這么一說，上面的代碼就非常好懂了。 然后一個(gè)Server.
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
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");
}
}
}先創(chuàng)建Socket的三步曲，設(shè)置成非阻塞模式。然后把socket加到Reactor中監(jiān)聽可讀事件，可讀的意思就是，緩沖區(qū)有數(shù)據(jù)了，才可讀?？勺x事件發(fā)生，說明有新連接來了，用stream_socket_accept接收新連接Conn，把Conn放到Reactor中監(jiān)聽可讀事件，可讀事件發(fā)生，說明客戶端有數(shù)據(jù)發(fā)送過來了，循環(huán)讀直到?jīng)]數(shù)據(jù)，然后把Conn放到Reactor中監(jiān)聽可寫事件，可寫事件發(fā)生，說明客戶端數(shù)據(jù)發(fā)送完了，把協(xié)議組裝一下寫入響應(yīng)。
應(yīng)用層如果是HTTP協(xié)議要注意一下Connection: keep-alive頭，因?yàn)橐獜?fù)用連接，不要一寫完就關(guān)閉連接。
擼完收工，用ab測一下并發(fā)，加-k參數(shù)復(fù)用連接，i5+8G，3W的并發(fā)沒啥問題，當(dāng)然我們這兒沒有磁盤I/O，實(shí)際情況要從磁盤讀取文件，讀文件要通過linux的系統(tǒng)調(diào)用，而且有幾次的文件拷貝操作，花銷比較大，常用的解決思路是sendfile，零拷貝直接從一個(gè)FD到另一個(gè)FD，效率比較高，缺點(diǎn)就是PHP沒有現(xiàn)成的已經(jīng)實(shí)現(xiàn)sendfile的擴(kuò)展，得自己動手，開發(fā)成本有點(diǎn)高。
ab測試PO圖：
這就是PHP實(shí)現(xiàn)高并發(fā)服務(wù)器的思路了，只要是用EPOLL解決的，思路都一樣，都是三步曲，放到Reactor下監(jiān)聽FD事件。當(dāng)然這個(gè)只是最簡單的模型，還有很多可以改進(jìn)的地方，比如說多進(jìn)程，抄襲一下nginx，一個(gè)主進(jìn)程+N個(gè)工作進(jìn)程，多進(jìn)程的目的還是想利用多核并行工作。C語言實(shí)現(xiàn)也是這樣，只是你可能不用libevent庫，自己封裝EPOLL,畢竟libevent庫有點(diǎn)重，你也用不到libevent的很多東西；當(dāng)然了，C語言有一堆的數(shù)據(jù)結(jié)構(gòu)以及定義在數(shù)據(jù)結(jié)構(gòu)上的操作要寫，沒有GC，自己管理內(nèi)存，還要有良好的設(shè)計(jì)，上多進(jìn)程還得搞一搞IPC進(jìn)程間通信的東西，開發(fā)難度比PHP要大地多，開發(fā)周期也很長，有興趣的同學(xué)可以自己擼一個(gè)玩。
感謝你能夠認(rèn)真閱讀完這篇文章，希望小編分享如何用PHP實(shí)現(xiàn)高并發(fā)服務(wù)器內(nèi)容對大家有幫助，同時(shí)也希望大家多多支持創(chuàng)新互聯(lián)成都網(wǎng)站設(shè)計(jì)公司，關(guān)注創(chuàng)新互聯(lián)成都網(wǎng)站設(shè)計(jì)公司行業(yè)資訊頻道，遇到問題就找創(chuàng)新互聯(lián)成都網(wǎng)站設(shè)計(jì)公司，詳細(xì)的解決方法等著你來學(xué)習(xí)!
另外有需要云服務(wù)器可以了解下創(chuàng)新互聯(lián)scvps.cn，海內(nèi)外云服務(wù)器15元起步，三天無理由+7*72小時(shí)售后在線，公司持有idc許可證，提供“云服務(wù)器、裸金屬服務(wù)器、網(wǎng)站設(shè)計(jì)器、香港服務(wù)器、美國服務(wù)器、虛擬主機(jī)、免備案服務(wù)器”等云主機(jī)租用服務(wù)以及企業(yè)上云的綜合解決方案，具有“安全穩(wěn)定、簡單易用、服務(wù)可用性高、性價(jià)比高”等特點(diǎn)與優(yōu)勢，專為企業(yè)上云打造定制，能夠滿足用戶豐富、多元化的應(yīng)用場景需求。
