Swoole4.x探究之多進(jìn)程TCP協(xié)程服務(wù)實(shí)現(xiàn)

ad6623 發(fā)布于2019-07-01 13:56 / 3074人閱讀

摘要：有研究過框架的同學(xué)就會發(fā)現(xiàn)，其實(shí)最核心的，就是用了拓展加上拓展來實(shí)現(xiàn)其底層的網(wǎng)絡(luò)服務(wù)和多進(jìn)程調(diào)度。我們在模式下，測試起五個(gè)進(jìn)程主進(jìn)程要等待回收我們，這樣就很簡單的實(shí)現(xiàn)了一個(gè)多進(jìn)程的協(xié)程服務(wù)。

有研究過Workman框架的同學(xué)就會發(fā)現(xiàn)，其實(shí)workman最核心的，就是用了php socket拓展加上pcntl拓展來實(shí)現(xiàn)其底層的網(wǎng)絡(luò)服務(wù)和多進(jìn)程調(diào)度。那我們今天就來探討如何使用Swoole的CoroutineSocket模塊來實(shí)現(xiàn)自己的tcp服務(wù)。
我們先編寫一段小的測試代碼，test.php 代碼如下

$socket = new CoSocket(AF_INET, SOCK_STREAM, 0);
$socket->bind("127.0.0.1", 9601);
$socket->listen(128);

go(function () use ($socket) {
    while(true) {
        $client = $socket->accept(-1);
        $data = $client->recv(64,10);
        var_dump("Recv:".$data);
        $client->sendAll("reply at ".time());
        $client->close();
    }
});

我們執(zhí)行

php test.php

并新建一個(gè)cmd控制臺，用telnet模擬tcp客戶端，可以看到如下結(jié)果：

telnet 127.0.0.1 9601
Trying 127.0.0.1...
Connected to localhost.
Escape character is "^]".
asd
reply at 1559713416
Connection closed by foreign host

以上說明我們已經(jīng)成功建立了一個(gè)簡單的TCP服務(wù)器。而有細(xì)心的同學(xué)就會發(fā)現(xiàn)，以上代碼如果我在recv后，有一些數(shù)據(jù)庫行為發(fā)生，那我該TCP服務(wù)器在同一時(shí)間就僅僅只能accept鏈接并處理一個(gè)鏈接的事情，并發(fā)能力接近于1。因此我們可以做一點(diǎn)小小的改進(jìn)，如下：

$socket = new CoSocket(AF_INET, SOCK_STREAM, 0);
$socket->bind("127.0.0.1", 9601);
$socket->listen(128);

go(function () use ($socket) {
    while(true) {
        $client = $socket->accept(-1);
        go(function () use ($client){
            $data = $client->recv(64,10);
            var_dump("Recv:".$data);
            //模擬數(shù)據(jù)庫耗時(shí),假定我們的數(shù)據(jù)庫也是用協(xié)程api
            co::sleep(1);
            $client->sendAll("reply at ".time());
            $client->close();
        });
    }
});

我們利用協(xié)程，把連接accept后的邏輯，全部放到另外一個(gè)子協(xié)程當(dāng)中處理，讓我們的TCP服務(wù)器可以繼續(xù)accept連接，也就提高了我們的并發(fā)能力。然而，在實(shí)際的編程中，我們不可能做到完全的百分百協(xié)程API,而且我的機(jī)器也是多核心的處理器，那么此刻我如何盡可能的利用我的CPU呢？因此我們可以利用端口復(fù)用的特性和Swoole的Process來構(gòu)建一個(gè)多進(jìn)程TCP協(xié)程服務(wù)器。

引入Process

因?yàn)樵诒菊鹿?jié)中，對Swoole Process的封裝不是我們關(guān)心的，因此我們這里直接使用EasySwoole封裝好的進(jìn)程組件。

composer require easyswoole/component

實(shí)現(xiàn)我的Process Class，代碼如下

use CoSocket;
use EasySwooleComponentProcessAbstractProcess;

class Server extends AbstractProcess
{
    protected function run($arg)
    {
        $socket = new Socket(AF_INET, SOCK_STREAM, 0);
        //關(guān)鍵在這里，允許復(fù)用
        $socket->setOption(SOL_SOCKET,SO_REUSEPORT,true);
        $socket->setOption(SOL_SOCKET,SO_REUSEADDR,true);
        $socket->bind("127.0.0.1", 9601);
        $socket->listen(128);
        go(function () use ($socket) {
            while(true) {
                $client = $socket->accept(-1);
                go(function () use ($client){
                    $data = $client->recv(64,10);
                    var_dump("Recv:".$data);
                    //模擬數(shù)據(jù)庫耗時(shí),假定我們的數(shù)據(jù)庫也是用協(xié)程api
                    co::sleep(1);
                    $client->sendAll("reply at ".time());
                    $client->close();
                });
            }
        });
    }
}

我們在以上代碼中，加入了允許端口復(fù)用的選項(xiàng)，否則在多進(jìn)程模式下，會導(dǎo)致監(jiān)聽失敗。我們在cli模式下，測試起五個(gè)進(jìn)程

for ($i = 1;$i < 5;$i++){
    $p = new Server("TcpServer.{$i}");
    $p->getProcess()->start();
}
//主進(jìn)程要等待回收
while($ret = SwooleProcess::wait()) {
    echo "PID={$ret["pid"]}
";
}

我們，這樣就很簡單的實(shí)現(xiàn)了一個(gè)多進(jìn)程的TCP協(xié)程服務(wù)。總而言之，Swoole 4.x的協(xié)程能力，還是很強(qiáng)大的，讓PHPer可以以最小的代價(jià)來實(shí)現(xiàn)一個(gè)高性能的TCP服務(wù)，而不是需要去學(xué)習(xí)新的一門語言，若需要更多的完善代碼，可以參考http://easyswoole.com/ 這個(gè)框架的項(xiàng)目代碼，如果有喜歡的同學(xué)，可以隨意點(diǎn)個(gè) star ,github地址 https://github.com/easy-swool...