問題描述

$http->request($host.$url, [
            'method' => 'POST',
            'data' => json_encode($data),
            'headers' => $header,
            'progress' => function ($buffer) use ($userConnection, $http) {

                if ($http->incompleteData!=""){
                    $buffer=$http->incompleteData.$buffer;//將上次不完整數(shù)據(jù)和本次不完整數(shù)據(jù)拼接
                    $http->incompleteData='';//重置不完整數(shù)據(jù)
                }

                $result = $this->parsedData($buffer);

                $content=$result['content'];

                $incompleteData=$result['incompleteData'];//不完整數(shù)據(jù)
                if ($incompleteData!=""){
                    $http->incompleteData.=$incompleteData;//設(shè)置不完整數(shù)據(jù)
                }
                if ($content!="") {
                        $userConnection->send(new Chunk($content));
                        $http->buffer .= $content;
                        $http->incompleteData='';
                }

            },
            'success' => function ($response) use ($userConnection, $http,$model,$saveMessage_callback, $deduction_callback,$updateKey_callback) {
                $userConnection->send(new Chunk(''));
                call_user_func($saveMessage_callback, $http->buffer);
                $error=json_decode($http->buffer,true);

                // 扣費(fèi)
                if ($response->getStatusCode() == 200&&!is_array($error)) {
                  //響應(yīng)200且不能是json格式，因?yàn)橛袝r候響應(yīng)200但是時間是不是正常回復(fù)
                   call_user_func($deduction_callback);
                   Redis::incr($model);//記錄相應(yīng)模型使用次數(shù)
                 }
                //更新key的使用時間
                call_user_func($updateKey_callback);

            },'error' => function ($exception)use($userConnection,$updateKey_callback,$http,$saveMessage_callback) {
                $userConnection->send(new Chunk(''));
                call_user_func($updateKey_callback);
                //錯誤或者超時也保存聊天記錄
                call_user_func($saveMessage_callback, $http->buffer);
        }
        ]);

上述代碼無法正常發(fā)送chunk響應(yīng)給客戶端，但是如果加一個print打印，那么客戶端就能收到響應(yīng)

$http->request($host.$url, [
            'method' => 'POST',
            'data' => json_encode($data),
            'headers' => $header,
            'progress' => function ($buffer) use ($userConnection, $http) {

            print_r($buffer);//這里打印一下，前端就可以接受到chunk響應(yīng)

                if ($http->incompleteData!=""){
                    $buffer=$http->incompleteData.$buffer;//將上次不完整數(shù)據(jù)和本次不完整數(shù)據(jù)拼接
                    $http->incompleteData='';//重置不完整數(shù)據(jù)
                }
                $result = $this->parsedData($buffer);
                $content=$result['content'];
                $incompleteData=$result['incompleteData'];//不完整數(shù)據(jù)
                if ($incompleteData!=""){
                    $http->incompleteData.=$incompleteData;//設(shè)置不完整數(shù)據(jù)
                }
                if ($content!="") {
                        $userConnection->send(new Chunk($content));
                        $http->buffer .= $content;
                        $http->incompleteData='';
                }
            },
            'success' => function ($response) use ($userConnection, $http,$model,$saveMessage_callback, $deduction_callback,$updateKey_callback) {
                $userConnection->send(new Chunk(''));
                call_user_func($saveMessage_callback, $http->buffer);
                $error=json_decode($http->buffer,true);
                // 扣費(fèi)
                if ($response->getStatusCode() == 200&&!is_array($error)) {
                  //響應(yīng)200且不能是json格式，因?yàn)橛袝r候響應(yīng)200但是時間是不是正?；貜?fù)
                   call_user_func($deduction_callback);
                   Redis::incr($model);//記錄相應(yīng)模型使用次數(shù)
                 }
                //更新key的使用時間
                call_user_func($updateKey_callback);
            },'error' => function ($exception)use($userConnection,$updateKey_callback,$http,$saveMessage_callback) {
                $userConnection->send(new Chunk(''));
                call_user_func($updateKey_callback);
                //錯誤或者超時也保存聊天記錄
                call_user_func($saveMessage_callback, $http->buffer);
        }
        ]);

這是什么原因呢？

破案了與程序無關(guān)，是第三方接口的問題...