使用PHP处理Apple推送通知服务的设备令牌的方法

这个网站上有很多关于如何用PHP处理Apple推送通知服务异步返回的错误的信息。我在PHP中提出了一个方法，它似乎运行得很好，但我希望得到一些反馈。

1. fflush（）的用法正确吗？我在一些例子中看到过，但不是全部
2. 我无法让它为故意损坏的设备令牌提供错误。为什么
3. 此解决方案是否可扩展到数千台设备（假设PHP最大内存已充分增加）
4. 其他问题

备注：
-通知的设备令牌在开始时存储在阵列中
-它不是异步的，但它在发送每个通知后检查（过去的）错误，并在最后一个通知后整整一秒再检查一次
-它使用较新的"现代"通知格式，而不是原始或扩展格式
-它将令牌阵列的索引作为标识符发送给APNS
-它使用checkAppleErrorResponse（）函数，该函数读取前6个字节并返回false或失败的标识符（索引），以便备份并继续使用下一个令牌。（故障后发送的所有令牌均无效。）

$ctx = stream_context_create();
stream_context_set_option($ctx, 'ssl', 'passphrase', $iosCertPassphrase);
stream_context_set_option($ctx, "ssl", "local_cert", $iosCertKey);
$fp = NULL;
$errno = NULL;
$errstr = NULL;
// same payload for all
$item2 = chr(2) . pack("n", strlen($payload)) . $payload; // payload item has id 2, a 2-byte length ("n") containing length of payload, then payload
$errorID = -1;
while ($errorID !== false) {
    $fp = stream_socket_client($iosHost . ':' . $iosPort, $errno, $errstr, 60, STREAM_CLIENT_CONNECT|STREAM_CLIENT_PERSISTENT, $ctx);        
    if ($fp === FALSE) {
        echo('Failed to create socket');
        break;
    }
    stream_set_blocking($fp, 0);
    for ($id = $errorID + 1 ; $id < sizeof($iosTokens); $id++) {
        $errorID = false;
        $item1 = chr(1) . pack('n', 32) . pack("H*", $iosTokens[$id]['device_token']); // device token item has 1-byte id 1, 2-byte length ("n") containing 32, then 32-byte device token
        $item3 = chr(3) . pack('n', 4) . pack('N', $id); // notification identifier has 1-byte id 3, 2-byte length ("n") containing 4, then 4-byte identifier
        $frame = $item1 . $item2 . $item3;
        $msg = chr(2) . pack("N", strlen($frame)) . $frame; // for "modern" push notification format, msg has 1-byte id 2, 4-byte length ("N") containing the length of the frame, then frame
        fwrite($fp, $msg);
        $errorID = checkAppleErrorResponse($fp);
        fflush($fp);
        if ($errorID !== false) // if there's an error, stop now
            break;
    }
    // if done with for loop and no errors, pause for a sec and check one last time
    if ($errorID === false) {
        $read = array($fp);
        $null = null;
        $changedStreams = stream_select($read, $null, $null, 0, 1000000);
        //check if it is actually false
        if ($changedStreams === false) 
            {    
            //close stream when done.
            socket_close($fp);
            fclose($fp);
            }
        elseif ($changedStreams > 0) 
            {
            // set the error and redo starting after errorID index
            $errorID = checkAppleErrorResponse($fp);
            }
        }
    }
}