關(guān)于異步tcp的問(wèn)題

小陽(yáng)光 更新于2020-04-13

異步tcp我認(rèn)為的是，tcp請(qǐng)求會(huì)做到異步化，tcp發(fā)起請(qǐng)求后，程序自己可以處理其他業(yè)務(wù)，tcp有結(jié)果了就執(zhí)行回調(diào)函數(shù)，但是通過(guò)我的實(shí)驗(yàn)并不是。不知道是我代碼有問(wèn)題還是怎么回事，求解答。

$task = new Worker();
$task->onWorkerStart = function ($task) {
$connection_to_baidu = new AsyncTcpConnection('tcp://xx.xx.xx.xxx:80');
$connection_to_baidu->onConnect = function ($connection_to_baidu) {
    echo "connect success\n";
    $connection_to_baidu->send("GET /Mapi/v3/Test/test HTTP/1.1\r\nHost: xx.xx.xx.xxx\r\nConnection: keep-alive\r\n\r\n");
};
$connection_to_baidu->onMessage = function ($connection_to_baidu, $http_buffer) {
    echo $http_buffer;
};
$connection_to_baidu->onClose = function ($connection_to_baidu) {
    echo "connection closed\n";
};
$connection_to_baidu->onError = function ($connection_to_baidu, $code, $msg) {
    echo "Error code:$code msg:$msg\n";
};
$connection_to_baidu->connect(); //通過(guò)抓包分析，此處會(huì)與服務(wù)器三次握手

//模擬處理正常其他業(yè)務(wù) 此處業(yè)務(wù)耗時(shí)大于3秒
for ($i = 0; $i < 30000; $i++) {
    echo $i . PHP_EOL;
    file_get_contents('workerman.log'); //為了防止此處，一直占用cpu資源，做io操作，讓cpu有機(jī)會(huì)去執(zhí)行回調(diào)函數(shù)
}
//此時(shí)會(huì)打印connect success， 抓包此處才會(huì)發(fā)起http請(qǐng)求   發(fā)送$connection_to_baidu->send("GET /Mapi/v3/Test/test HTTP/1.1\r\nHost: xx.xx.xx.xxx\r\nConnection: keep-alive\r\n\r\n");
//因?yàn)榻涌趕leep睡眠了三秒返回，此處會(huì)有大概三秒等待，然后會(huì)執(zhí)行onMessage回調(diào)函數(shù) 打印結(jié)果到控制臺(tái)
};
// 運(yùn)行worker
Worker::runAll();

 2998  2 1

2個(gè)回答

walkor 2020-04-13

打賞

workerman運(yùn)行可以認(rèn)為分為2個(gè)狀態(tài)，一個(gè)是執(zhí)行業(yè)務(wù)狀態(tài)，一個(gè)是workerman內(nèi)核態(tài)狀態(tài)，2個(gè)狀態(tài)是串行的，并不會(huì)并發(fā)執(zhí)行。

執(zhí)行業(yè)務(wù)狀態(tài)也就是進(jìn)程在運(yùn)行業(yè)務(wù)代碼時(shí)的狀態(tài)，這時(shí)候workerman內(nèi)核沒(méi)有控制權(quán)；
workerman內(nèi)核狀態(tài)是業(yè)務(wù)執(zhí)行完畢后交出控制權(quán)后workerman內(nèi)核運(yùn)行的狀態(tài)；

workerman內(nèi)核狀態(tài)實(shí)際上就是一個(gè)event-loop，會(huì)監(jiān)聽(tīng)操作系統(tǒng)發(fā)送給workerman的連接事件、連接可讀可寫(xiě)、關(guān)閉事件，并觸發(fā)onConnect、onMessage、onClose等。只有在workerman內(nèi)核態(tài)才能接收到這些事件，在執(zhí)行業(yè)務(wù)狀態(tài)無(wú)法接收并觸發(fā)這些事件。

這就很好的解釋了為什么上面的代碼為什么在業(yè)務(wù)代碼執(zhí)行完畢后才真正發(fā)出了請(qǐng)求。

如果你想要在執(zhí)行業(yè)務(wù)邏輯的時(shí)候通知其它進(jìn)程同步處理業(yè)務(wù)邏輯，你應(yīng)該用同步的方式發(fā)起連接和數(shù)據(jù)，然后在需要數(shù)據(jù)的時(shí)候讀取它。代碼類(lèi)似這樣：

$task = new Worker();
$task->onWorkerStart = function ($task) {
    $socket = stream_socket_client('tcp://xx.xx.xx.xxx:80');
    fwrite($socket, "GET /Mapi/v3/Test/test HTTP/1.1\r\nHost: xx.xx.xx.xxx\r\nConnection: keep-alive\r\n\r\n");

    //模擬處理正常其他業(yè)務(wù) 此處業(yè)務(wù)耗時(shí)大于3秒
    for ($i = 0; $i < 30000; $i++) {
        echo $i . PHP_EOL;
        file_get_contents('workerman.log'); //為了防止此處，一直占用cpu資源，做io操作，讓cpu有機(jī)會(huì)去執(zhí)行回調(diào)函數(shù)
    }

    echo fread($socket, 8192);
};
// 運(yùn)行worker
Worker::runAll();

這樣在你處理業(yè)務(wù)的時(shí)候，遠(yuǎn)處的進(jìn)程也在處理。當(dāng)你需要獲得結(jié)果的時(shí)候，用fread阻塞等待獲得結(jié)果即可。

如果你想同步的方式發(fā)起請(qǐng)求，異步的方式獲得結(jié)果，可以用下面的方法。

use Workerman\Connection\TcpConnection;
$task = new Worker();
$task->onWorkerStart = function ($task) {
    $socket = stream_socket_client('tcp://xx.xx.xx.xxx:80');
     fwrite($socket, "GET /Mapi/v3/Test/test HTTP/1.1\r\nHost:xx.xx.xx.xxx\r\nConnection: keep-alive\r\n\r\n");
    $connection = new TcpConnection($socket);
    $connection->onMessage = function($connection, $http_buffer){
        echo $http_buffer;
        $connection->close(); // 連接不用了要記得關(guān)閉
    }
    //模擬處理正常其他業(yè)務(wù) 此處業(yè)務(wù)耗時(shí)大于3秒
    for ($i = 0; $i < 30000; $i++) {
        echo $i . PHP_EOL;
        file_get_contents('workerman.log'); //為了防止此處，一直占用cpu資源，做io操作，讓cpu有機(jī)會(huì)去執(zhí)行回調(diào)函數(shù)
    }
};
// 運(yùn)行worker
Worker::runAll();