workerman長(zhǎng)連接應(yīng)用剛啟動(dòng)時(shí)，Gateway于BusinessWorker之間會(huì)建立連接，在連接沒建立好時(shí)，會(huì)有數(shù)據(jù)丟失情況。workerman啟動(dòng)到建立連接完畢大概需要1-2秒的時(shí)間，也就是說目前長(zhǎng)連接應(yīng)用要等workerman啟動(dòng)后需要等待1-2秒才能正常工作，后面會(huì)針對(duì)這個(gè)問題做優(yōu)化

如果不是上述問題導(dǎo)致，可以嘗試或者檢查以下項(xiàng)目：

1、請(qǐng)確認(rèn)下配置是與線上一致，尤其是 persistent_connection ，max_requests
2、查看workerman/log/date/server.log 看是否有進(jìn)程異常退出的日志
3、檢查php日志是否有FatalError等致命錯(cuò)誤

您好，承上面的問題，我的程式是由 底下的 這個(gè)地方關(guān)閉鏈接，因?yàn)?$this->workerConnections 已經(jīng)清空了,導(dǎo)致後下一個(gè)命令無(wú)法送至Worker。

為什麼，會(huì)出現(xiàn) if('' == $buffer && '' == ($buffer = fread($connection, $this->recvBuffers))) 這個(gè)狀態(tài)，然後關(guān)閉連線呢?

謝謝，您的回覆。

public function recvTcp($connection, $flag, $fd = null)
{
    $this->currentDealFd = $fd;
    $buffer = stream_socket_recvfrom($connection, $this->recvBuffers);

    // 出錯(cuò)了         
    if('' == $buffer && '' == ($buffer = fread($connection, $this->recvBuffers)))
    {

        if(!feof($connection))
        {
            return;
        }

        // 如果該鏈接對(duì)應(yīng)的buffer有數(shù)據(jù)，說明發(fā)生錯(cuò)誤
        if(!empty($this->recvBuffers))
        {
            $this->statusInfo++;
            $this->notice("INNER_CLIENT_CLOSE\nCLIENT_IP:".$this->getRemoteIp()."\nBUFFER:\n");
        }

        // 關(guān)閉鏈接
        $this->closeInnerClient($fd);
        if($this->workerStatus == self::STATUS_SHUTDOWN)
        {
            $this->stop();
        }
        return;
    }

    $this->recvBuffers .= $buffer;

    $remain_len = $this->dealInnerInput($this->recvBuffers);
    // 包接收完畢
    if(0 === $remain_len)
    {
        // 執(zhí)行處理
        try{
            // 內(nèi)部通訊業(yè)務(wù)處理
            $this->innerDealProcess($this->recvBuffers);
        }
        catch(\Exception $e)
        {
            $this->notice('CODE:' . $e->getCode() . ' MESSAGE:' . $e->getMessage()."\n".$e->getTraceAsString()."\nCLIENT_IP:".$this->getRemoteIp()."\nBUFFER:\n");
            $this->statusInfo ++;
        }
        $this->recvBuffers = array('buf'=>'', 'remain_len'=>GatewayProtocol::HEAD_LEN);
    }
    // 出錯(cuò)
    else if(false === $remain_len)
    {
        // 出錯(cuò)
        $this->statusInfo++;
        $this->notice("INNER_PACKET_ERROR\nCLIENT_IP:".$this->getRemoteIp()."\nBUFFER:\n");
        $this->closeInnerClient($fd);
    }
    else
    {
        $this->recvBuffers = $remain_len;
    }

    // 檢查是否是關(guān)閉狀態(tài)或者是否到達(dá)請(qǐng)求上限
    if($this->workerStatus == self::STATUS_SHUTDOWN )
    {
        // 停止服務(wù)
        $this->stop();
        // EXIT_WAIT_TIME秒后退出進(jìn)程
        pcntl_alarm(self::EXIT_WAIT_TIME);
    }
}

當(dāng)對(duì)方主動(dòng)關(guān)閉連接時(shí)，本地對(duì)應(yīng)的socket會(huì)得到一個(gè)可讀狀態(tài)，但是讀取的數(shù)據(jù)是空的。
出現(xiàn)socket可讀并且讀到的數(shù)據(jù)為空時(shí)，還需要用feof判斷下是否對(duì)方真的關(guān)閉了連接，如果對(duì)方關(guān)閉了連接，則本地也需要執(zhí)行關(guān)閉操作。

我找到這個(gè)問題的原因，因?yàn)樵谧鰷y(cè)試 將啟動(dòng)行程數(shù)量改為1，您的BusinessWorker連接為
短連接，所以每處理一次命令就會(huì)中斷與 GateWay 的連線 ， 在發(fā)送連續(xù)命令時(shí)剛好碰到
$this->workerConnections 連線數(shù)為零，就沒將數(shù)據(jù)送出。
您是否能設(shè)計(jì)保險(xiǎn)一點(diǎn)，增加一個(gè)Queues，來(lái)保存沒有送出的命令。

protected function sendBufferToWorker($bin_data)
{ 
    if($this->currentDealFd = array_rand($this->workerConnections))
    {
        $this->sendToClient($bin_data);
    }else{
        // 加到 佇列 Queues 等候再發(fā)送。
    } 
}

謝謝您。

BusinessWorker必須設(shè)置為長(zhǎng)連接，除了listen選項(xiàng)，其他配置最好和線上版本的配置一致。

了解，謝謝您的回答。

不客氣