recv data before handshake. Buffer 这是什么情况咧，找了半天没找到原因，求帮助。

zoofei 更新于2019-10-30

$client = new AsyncTcpConnection('ws://xxx.com:80');
$client->onConnect = function($con) {
            $rid = time();
            $lang = "kor";
            $con->send('xxx');
};
$client->onMessage = function($con, $data) use($ids,$orates,$client) {
....
}
$client->connect();

代码如上，日志隔三差五就报下面错误，找不到有原因，求帮助...
recv data before handshake. Buffer:890c31303a34333a35332e373833
error package. package_length=false

 7328  4 0

4个回答

walkor 2018-02-22

打赏

检查下代码里是否有 new Worker('ws://...') 或者 new Gateway('ws://...')，
改成 new Worker('websocket://...') 或者 new Gateway('websocket://...')，

暂无评论

zoofei 2018-02-22

感谢walkor回复
代码没有new ws://,
代码整体启动了
Gateway('Websocket://0.0.0.0:7272'),
Register('text://0.0.0.0:1236');
BusinessWorker();
然后单独在开个new Worker();做定时任务。

Timer::add($this->sec, array($this,'refresh'));
function refresh(){
    $client = new AsyncTcpConnection('ws://xxx:80');
    echo "start connect id:".$client->id;
    因为远端经常掉线或者踢人，所以没有保持长连接，每次定时开始都重新new一个连接，获取数据后立即destory，就是这个异步链接经常报错：

    start connet id:48
    connect id:48 buffer:05:37:00.426 recv data before handshake. Buffer:890c30353a33373a30302e343236
    error package. package_length=false
}

/*
* Websocket protocol for client.
*/
Class Ws{
    public static function input($buffer, $connection)
    {
        if (empty($connection->handshakeStep)) {
            echo "connect id:".$connection->id."  buffer".$buffer;
            echo "recv data before handshake. Buffer:" . bin2hex($buffer) . "\n";
            return false;
        }
}