這篇文章主要介紹了如何用PHP實現(xiàn)高并發(fā)服務(wù)器，具有一定借鑒價值，需要的朋友可以參考下。希望大家閱讀完這篇文章后大有收獲。下面讓小編帶著大家一起了解一下。

為花垣等地區(qū)用戶提供了全套網(wǎng)頁設(shè)計制作服務(wù)，及花垣網(wǎng)站建設(shè)行業(yè)解決方案。主營業(yè)務(wù)為成都網(wǎng)站建設(shè)、成都網(wǎng)站制作、花垣網(wǎng)站設(shè)計，以傳統(tǒng)方式定制建設(shè)網(wǎng)站，并提供域名空間備案等一條龍服務(wù)，秉承以專業(yè)、用心的態(tài)度為用戶提供真誠的服務(wù)。我們深信只要達到每一位用戶的要求，就會得到認可，從而選擇與我們長期合作。這樣，我們也可以走得更遠！

php怎么玩epoll？首先得安裝個libevent庫，再裝個event擴展或者libevent擴展就可以愉快地玩耍了.

有些人搞不清楚libevent庫跟libevent擴展的區(qū)別，簡單來說，libevent庫是C語言對epoll的封裝，跟PHP毛關(guān)系都沒有；libevent擴展就是PHP跟libevent庫的溝通橋梁。實際上PHP的很多擴展就是干這個事的，有一些優(yōu)秀的C語言庫，PHP想直接拿來用，就通過PHP擴展的方式接入到PHP。

libevent擴展和event擴展隨便選一個裝，我個人更喜歡event擴展，因為更面向?qū)ο笠稽c。自己去http://pecl.php.net里面搜跟自己PHP版本對應(yīng)的擴展，下好編譯安裝一下就OK了.電腦裝了多個版本的PHP編譯的時候注意一下，phpize的版本要對應(yīng)上，別搞錯了，典型的五步曲:

phpize
./configure
make
make install
php -m | grep event #看看裝上了沒

我們要實現(xiàn)的服務(wù)器，傳輸層是TCP協(xié)議，應(yīng)用層協(xié)議太多太復(fù)雜，限于篇幅，會簡單地以HTTP服務(wù)器舉個例子，HTTP協(xié)議本身就很復(fù)雜，要實現(xiàn)起來細節(jié)上有很多考究，我們也不會完全實現(xiàn)HTTP協(xié)議。

首先，創(chuàng)建一個socket，三步曲，socket_create、socket_bind、socket_listen，為什么是這三步曲呢？很簡單，不管你傳輸層協(xié)議是啥，你下面的網(wǎng)絡(luò)層協(xié)議你得選個版本吧，IPV4還是IPV6，傳輸層工作方式你得選一個吧，全雙工、半雙工還是單工，TCP還是UDP你也得選一個吧，socket_create就是這三個選項；確定了網(wǎng)絡(luò)層和傳輸層，你得告訴我監(jiān)聽哪個端口吧，這就對應(yīng)了socket_bind；然后你得開啟監(jiān)聽，并指定一個客戶端的隊列長度吧，這就是socket_listen干的事。

創(chuàng)建完了，同步阻塞咱就不介紹了，一個進程同時最多hold處一個連接，多幾個連接同時請求，就得等唄，超過了socket_listen指定的隊列長度，就得返回504了。多進程也一樣，幾個進程就有幾個并發(fā)，進程又是昂貴資源，而且進程的上下文切換費時費力，導(dǎo)致整個系統(tǒng)效率低下。

沒關(guān)系，咱有epoll，hold住萬千請求不是夢，先實現(xiàn)一個Reactor。libevent庫就是Reactor模式，直接調(diào)用函數(shù)就是在使用Reactor模式，所以無需糾結(jié)到底php怎么實現(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就是個容器，里面裝的Event實例，這么一說，上面的代碼就非常好懂了。 然后一個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ù)了，才可讀。可讀事件發(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頭，因為要復(fù)用連接，不要一寫完就關(guān)閉連接。

擼完收工，用ab測一下并發(fā)，加-k參數(shù)復(fù)用連接，i5+8G，3W的并發(fā)沒啥問題，當(dāng)然我們這兒沒有磁盤I/O，實際情況要從磁盤讀取文件，讀文件要通過linux的系統(tǒng)調(diào)用，而且有幾次的文件拷貝操作，花銷比較大，常用的解決思路是sendfile，零拷貝直接從一個FD到另一個FD，效率比較高，缺點就是PHP沒有現(xiàn)成的已經(jīng)實現(xiàn)sendfile的擴展，得自己動手，開發(fā)成本有點高。

ab測試PO圖：

cdn.xitu.io/2019/3/25/169b2469004a3a7e?imageView2/0/w/1280/h/960/format/webp/ignore-error/1">

這就是PHP實現(xiàn)高并發(fā)服務(wù)器的思路了，只要是用EPOLL解決的，思路都一樣，都是三步曲，放到Reactor下監(jiān)聽FD事件。當(dāng)然這個只是最簡單的模型，還有很多可以改進的地方，比如說多進程，抄襲一下nginx，一個主進程+N個工作進程，多進程的目的還是想利用多核并行工作。C語言實現(xiàn)也是這樣，只是你可能不用libevent庫，自己封裝EPOLL,畢竟libevent庫有點重，你也用不到libevent的很多東西；當(dāng)然了，C語言有一堆的數(shù)據(jù)結(jié)構(gòu)以及定義在數(shù)據(jù)結(jié)構(gòu)上的操作要寫，沒有GC，自己管理內(nèi)存，還要有良好的設(shè)計，上多進程還得搞一搞IPC進程間通信的東西，開發(fā)難度比PHP要大地多，開發(fā)周期也很長，有興趣的同學(xué)可以自己擼一個玩。

感謝你能夠認真閱讀完這篇文章，希望小編分享如何用PHP實現(xiàn)高并發(fā)服務(wù)器內(nèi)容對大家有幫助，同時也希望大家多多支持創(chuàng)新互聯(lián)，關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道，遇到問題就找創(chuàng)新互聯(lián)，詳細的解決方法等著你來學(xué)習(xí)!