循环给Taskworker发任务Taskworker接到的数据不完整

foreach ($data as $key => $value) {
    $socket = stream_socket_client("tcp://127.0.0.1:7272", $errno, $errmsg, 5);
    if(!$socket) echo $errmsg;
    $mail_data = array("phone"=>$value,"user_id"=>$value,);
    // 注意，Text协议后面"\n"换行符是必须的
    $mail_buffer = json_encode($mail_data)."\n";
    // 发送给Taskworker
    fwrite($socket, $mail_buffer);
}