關(guān)于AsyncTcpConnection，異步阻塞問(wèn)題

h8h8 更新于2019-10-30

$socket     = new AsyncTcpConnection($tcp); 

$socket->onConnect = function($socket) use($db)
        {
           //在這里循環(huán)發(fā)送消息，發(fā)現(xiàn)全部循環(huán)完畢后，才接收到返回結(jié)果，在循環(huán)過(guò)程中，全部是阻塞的嗎？
            for($i = 0; $i < 1000; $i++)
            {
                 $request = send_datas1($db);
                 //print_r($request);
                 $socket->send($request);                  
            }                                  
        };

        //服務(wù)器響應(yīng)，接收返回結(jié)果
        $socket->onMessage = function($socket, $result) use($db)
        {
            try
            {
                print_r($result);
                $db->update($table)->cols($result)->where()->query();
            }
            catch(\Exception $e)
            {
                print_r($e->getMessage());              
            }                                                    
        };

        $socket->onClose = function($socket) {
            // 如果連接斷開(kāi)，則在1秒后重連
            $socket->reConnect(1);
        };

        $socket->onError = function($socket, $err_code, $err_msg)
        {

        };
        // 執(zhí)行異步鏈接
        $socket->connect();

 5000  5 0

5個(gè)回答

walkor 2017-05-23

打賞

循環(huán)過(guò)程中，代碼執(zhí)行環(huán)境一直在這個(gè)循環(huán)里，workerman一直沒(méi)有得到運(yùn)行控制權(quán)，workerman就不會(huì)接收到數(shù)據(jù)，不會(huì)觸發(fā)onmessage。你這里只有當(dāng)onConnect里所有代碼執(zhí)行完畢，workerman才會(huì)獲得控制權(quán)，才會(huì)接收數(shù)據(jù)。

暫無(wú)評(píng)論

h8h8 2017-05-23

如果做到實(shí)時(shí)接時(shí)，改成這樣嗎？

for($i = 0; $i < 1000; $i++)
{
    $socket = new AsyncTcpConnection($tcp);

    $socket->onConnect = function($socket) use($db)
    {
        $request = send_datas1($db, $i);
        $socket->send($request);
    };

    $socket->onMessage = function($socket, $result) use($db)
    {
        print_r($result);
    };
    // 執(zhí)行異步鏈接
    $socket->connect();
}

這樣會(huì)不會(huì)建立1000個(gè)鏈接，導(dǎo)致性能下降？