从一台服务器推送多个应用程序的通知

我正在使用 RMSPushNotificationsBundle 来处理推送通知。我正在从一台服务器向多个应用程序发送推送通知。我正在使用setAPNSPemAsString方法,选择正确的证书。但推送通知仅在第一次发送。谁能告诉我为什么?谢谢!

public function sendIOS($appName){
    $notifications = $this->container->get('rms_push_notifications');

    $message = new iOSMessage();
    $message->setMessage($this->message);
    $message->setData($this->getData());
    $message->setAPSSound("default");
    $message->setDeviceIdentifier($this->pushToken);

    if ($appName !="appName") {
        $pemFile    = $this->container->getParameter("rms_push_notifications.ios.".$appName.".pem");
        $passphrase = $this->container->getParameter("rms_push_notifications.ios.".$appName.".passphrase");

            $pemContent = file_get_contents($pemFile);
            $notifications->setAPNSPemAsString($pemContent, $passphrase);
    }
    return $notifications->send($message);
}

答案 1

我不确定问题出在哪里,但遵循小代码对我有用。至少您可以使用它来测试与APNS服务器的连接。

<?php
// your private key's passphrase
$passphrase = $_POST('passphrase');

$pemFilesPath = 'path/to/pem/folder/';

// path to pem file
$appCert = $_POST('pemfile');

$pemFile = $pemFilePath.$appCert;

$notifications = $_POST('notifications');

////////////////////////////////////////////////////////////////////////////////

$ctx = stream_context_create();
stream_context_set_option($ctx, 'ssl', 'local_cert', $pemFile);
stream_context_set_option($ctx, 'ssl', 'passphrase', $passphrase);

// Open a connection to the APNS server
$fp = stream_socket_client(
    'ssl://gateway.sandbox.push.apple.com:2195', $err,
    $errstr, 60, STREAM_CLIENT_CONNECT|STREAM_CLIENT_PERSISTENT, $ctx);

if (!$fp)
    exit("Failed to connect: $err $errstr" . PHP_EOL);

echo 'Connected to APNS' . PHP_EOL;

$records = 0;

foreach ($notifications as $deviceToken => $message)
{
    // Create the payload body
    $body['aps'] = array(
        'alert' => $message,
        'sound' => 'default'
        );

    // Encode the payload as JSON
    $payload = json_encode($body);

    // Build the binary notification
    $msg = chr(0) . pack('n', 32) . pack('H*', $deviceToken) . pack('n', strlen($payload)) . $payload;

    if (!$fp) {
        exit("Connection intruptted " . E_USER_ERROR . PHP_EOL);
    }
    // Send it to the server
    $result = fwrite($fp, $msg, strlen($msg));
    if(!$result) {

                                print_r("Failed writing to stream.", E_USER_ERROR);
                                fclose($fp);
                                die;
                        }
                     /* uncomment this part for troubleshooting   
                        else {
                                $tv_sec = 1;
                                $tv_usec = null; // Timeout. 1 million micro seconds = 1 second
                                $read = array($fp); $we = null; // Temporaries. "Only variables can be passed as reference."
                                $numChanged = stream_select($read, $we, $we, $tv_sec, $tv_usec);
                                if(false===$numChanged) {
                                        print_r("Failed selecting stream to read.", E_USER_ERROR);
                                        fclose($fp);
                                        die;
                                }
                                else if($numChanged>0) {
                                        $command = ord(fread($fp, 1));
                                        $status = ord(fread($fp, 1));
                                        $identifier = implode('', unpack("N", fread($fp, 4)));
                                        $statusDesc = array(
                                                0 => 'No errors encountered',
                                                1 => 'Processing error',
                                                2 => 'Missing device token',
                                                3 => 'Missing topic',
                                                4 => 'Missing payload',
                                                5 => 'Invalid token size',
                                                6 => 'Invalid topic size',
                                                7 => 'Invalid payload size',
                                                8 => 'Invalid token',
                                                255 => 'None (unknown)',
                                        );
                                        print_r("APNS responded with command($command) status($status) pid($identifier).", E_USER_NOTICE);

                                        if($status>0) {
                                                $desc = isset($statusDesc[$status])?$statusDesc[$status]: 'Unknown';
                                                print_r("APNS responded with error for pid($identifier). status($status: $desc)", E_USER_ERROR);
                                                // The socket has also been closed. Cause reopening in the loop outside.
                                                fclose($fp);
                                                die;
                                        }
                                        else {
                                                // Apple docs state that it doesn't return anything on success though
                                               $records++;
                                        }
                                } else {
                                        $records++;
                                }
                        }
                        */  
    $records++;
    }

echo "Send notifications to $records devices";
// Close the connection to the server
fclose($fp);

?>

注意:很久以前写了这个小代码,它工作正常。我现在不记得源代码了,但有一个教程。最近没有测试过,所以你可能需要修改它。一些建议:

  1. 打开连接并将所有通知写入服务器,然后将其关闭。
  2. 读取服务器响应会降低功能,但有利于故障排除和启动。因此,请根据需要使用该部分。
  3. 请查看此文档,了解更多错误说明 APNs 提供程序 API

答案 2

推荐