是阻塞引起的嗎？

hoasem 更新于2019-10-30

請(qǐng)教個(gè)問(wèn)題
fwrite($client, $data_string."\n");
// 讀取推送結(jié)果
$resp = fread($client, 8192);
fwrite 在服務(wù)端沒(méi)接收到內(nèi)容， fread也沒(méi)接收到回應(yīng)，這種情況會(huì)不會(huì)是阻塞造成的？

 3191  5 0

5個(gè)回答

hoasem 2017-08-25

補(bǔ)充：
用的單進(jìn)程，并且客戶端設(shè)備大約在700左右

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

walkor 2017-08-25

打賞

只有這兩行客戶端代碼看不出什么問(wèn)題的

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

hoasem 2017-08-25

// 建立socket連接到內(nèi)部推送端口
$client = stream_socket_client($this->config, $errno, $errmsg,  5, STREAM_CLIENT_ASYNC_CONNECT|STREAM_CLIENT_CONNECT);
if(!$client)
{
    Helper::logger('Jpush_error.log', 'WMERR-->'."erreur : $errno - $errstr<br />n");
    return false;
} else {
    // 推送的數(shù)據(jù)，包含uid字段，表示是給這個(gè)uid推送
    $data = 'push';
    $data =  $alias;
    $data_string = json_encode($data);
    // 發(fā)送數(shù)據(jù)，注意3212端口是Text協(xié)議的端口，Text協(xié)議需要在數(shù)據(jù)末尾加上換行符
    //var_dump($data_string);exit;
    fwrite($client, $data_string."\n");
    // 讀取推送結(jié)果
    $resp = fread($client, 8192);
    return self::handleResult(str_replace("\n", "", $resp),$data_string,"WM");
}

基本是取的demo里面的，稍微調(diào)整了一點(diǎn)點(diǎn)

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

hoasem 2017-08-25

另外，這里是不是設(shè)置成 socket_set_nonblock 會(huì)好些，不過(guò)想問(wèn)下非阻塞情況下，fread也能獲取到返回值吧？

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

walkor 2017-08-26

打賞

上面的意思是說(shuō)信息量太少了，只貼客戶端代碼無(wú)法定位是什么問(wèn)題。

請(qǐng)描述下要做什么？期待結(jié)果以及實(shí)際結(jié)果（詳細(xì)的說(shuō)明）？客戶端連接的端口是？以及服務(wù)端是否是workerman？如果是workerman的話對(duì)應(yīng)的啟動(dòng)腳本代碼是什么？以及業(yè)務(wù)處理邏輯是什么都要貼出來(lái)