关于workerman/http-client的一个疑问

问题描述

$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;//将上次不完整数据和本次不完整数据拼接
                    $http->incompleteData='';//重置不完整数据
                }

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

                $content=$result['content'];

                $incompleteData=$result['incompleteData'];//不完整数据
                if ($incompleteData!=""){
                    $http->incompleteData.=$incompleteData;//设置不完整数据
                }
                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);

                // 扣费
                if ($response->getStatusCode() == 200&&!is_array($error)) {
                  //响应200且不能是json格式，因为有时候响应200但是时间是不是正常回复
                   call_user_func($deduction_callback);
                   Redis::incr($model);//记录相应模型使用次数
                 }
                //更新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);
        }
        ]);

上述代码无法正常发送chunk响应给客户端，但是如果加一个print打印，那么客户端就能收到响应

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

            print_r($buffer);//这里打印一下，前端就可以接受到chunk响应

                if ($http->incompleteData!=""){
                    $buffer=$http->incompleteData.$buffer;//将上次不完整数据和本次不完整数据拼接
                    $http->incompleteData='';//重置不完整数据
                }
                $result = $this->parsedData($buffer);
                $content=$result['content'];
                $incompleteData=$result['incompleteData'];//不完整数据
                if ($incompleteData!=""){
                    $http->incompleteData.=$incompleteData;//设置不完整数据
                }
                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);
                // 扣费
                if ($response->getStatusCode() == 200&&!is_array($error)) {
                  //响应200且不能是json格式，因为有时候响应200但是时间是不是正常回复
                   call_user_func($deduction_callback);
                   Redis::incr($model);//记录相应模型使用次数
                 }
                //更新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);
        }
        ]);

这是什么原因呢？

破案了与程序无关，是第三方接口的问题...