Google Cloud Messaging – пишем backend на PHP

class GcmPayload {
   public function __construct($regId, $jsons) {}
   public $regId;
   public $jsons;
}
class GcmSender {
   public function __construct($payloads) {}
   public function send() {}
   protected function getPackages() {}
   protected function isReadyToFlush($items, $json) {}
   public function onResponse($response, $info, RollingCurlRequest $request) {}
}

$recipients = $messagesRepository->getRecipientsWithNewMessages();
$payloads = array();
foreach ($recipients as $recipient) {
    $jsons = array();
    foreach ($recipient->messages as $message) {
        $jsons[] = json_encode($message);
    }
    $payloads[] = new GcmPayload($recipient[‘regId’], $jsons);
}

$gcm = new GcmSender();
$gcm->send($payloads);

    public function __construct() {
        $dataObj = '{"'.self::KEY_ITEMS.'": ['.self::ITEMS_PLACEHOLDER.']}';
        $this->_template = '{
            "'.self::KEY_REG_IDS.'": ["'.self::REGID_PLACEHOLDER.'"],
            "'.self::KEY_DATA.'": '.$dataObj.'
        }';
        $baseDataJson = str_replace(self::ITEMS_PLACEHOLDER, '', $dataObj);
        $this->_baseDataSize = strlen($baseDataJson);
    }

    /**
     * @param GcmPayload[] $payloads
     */
    public function send($payloads) {
        $packages = self::getPackages($payloads);
        if (!$packages || count($packages) == 0) return;

        $rc = new RollingCurl(array($this, 'onResponse'));
        $headers = array('Authorization: key='.self::GCM_API_KEY, 'Content-Type: application/json');
        $rc->__set('headers', $headers);
        $rc->options = array(
            CURLOPT_SSL_VERIFYPEER => false, //отключаем проверку сертификата
            CURLOPT_RETURNTRANSFER => true, //указываем, что хотим получить ответ в виде строки
            CURLOPT_CONNECTTIMEOUT => self::CURL_TIMEOUT, // сколько секунд пытаться установить соединение
            CURLOPT_TIMEOUT => self::CURL_TIMEOUT); //сколько времени должны выполняться функции curl

        foreach ($packages as $package) {
            $rc->request(self::GCM_SERVER_URL, 'POST', $package);
        }
        
        $rc->execute(self::GCM_MAX_CONNECTIONS); 

    /**
     * @param string $items
     * @param string $json
     * @return bool
     */
    protected function isReadyToFlush($items, $json) {
        $newPackageLen = $this->_baseDataSize + strlen($items) + strlen($json);
        return $newPackageLen > self::GCM_MAX_DATA_SIZE;
    }

    /**
     * @param GcmPayload[] $payloads
     * @return string[]
     */
    protected function getPackages($payloads) {
        $packages = array();
        foreach($payloads as $payload) {
            $template = str_replace(self::REGID_PLACEHOLDER, $payload->regId, $this->_template);
            $items = '';

            foreach($payload->jsons as $json) {
                if ($this->isReadyToFlush($items, $json)) {
                    $package = str_replace(self::ITEMS_PLACEHOLDER, $items, $template);
                    $packages[] = $package;
                    $items = '';
                }
                if ($items) $items .= ','.$json;
                else $items = $json;
            }

            if ($items) { //если есть остатки добавляем их в новый пакет
                $package = str_replace(self::ITEMS_PLACEHOLDER, $items, $template);
                $packages[] = $package;
            }
        }

        return $packages;
    }

    /**
     * @param string $response
     * @param array $info
     * @param RollingCurlRollingCurlRequest $request
     */
    public function onResponse($response, $info, RollingCurlRequest $request) {
       //Этот флаг показывает успешно ли отправлено сообщение
       $success = true;
//Декодирует json, который мы отправили в post
        $post = json_decode($request->post_data, true);
        if (json_last_error() != JSON_ERROR_NONE) {
            //анализируем json ошибку, возможно мы накосячили в синтаксисе.
            return;
        }
//Получаем RegistratonId и массив с данными 
        $regId = $post[self::KEY_REG_IDS][0];
        $items = $post[self::KEY_DATA][self::KEY_ITEMS];
//получаем код ответа
        $code = $info != null && isset($info['http_code']) ? $info['http_code'] : 0;
//Определяем группу кода: 2, 3, 4, 5
        $codeGroup = (int)($code / 100); 
        if ($codeGroup == 5) {
//Если код 5xx, это значит, что GCM сервер временно недоступен, сообщение не доставлено
//TODO Рекомендуется учитывать заголовок Retry-After
            $success = false;
        }
        if ($code !== 200) {
            //Ошибочный http код ответа, сообщение не доставлено
            //Если требуется более углубленный анализ кодов рекомендую прочитать описание формата ответа http://developer.android.com/google/gcm/gcm.html#response
            $success = false;
        }
        if (!$response || strlen(trim($response)) == null) {
            //пустой ответ, значит что-то пошло не так, считаем что сообщение не доставлено.
            $success = false;
        }

//анализируем ответ, см формат ответа http://developer.android.com/google/gcm/gcm.html#success
        if ($response) {
            $json = json_decode($response, true);
            if (json_last_error() != JSON_ERROR_NONE) {
                //ошибка парсинга json ответа, на всякий случай считаем что сообщение не доставлено
                $success = false;
                $json = array();
            }
        }
        else {
            $json = array();
            $success = false;
        }

// failure содержит количество недоставленных сообщений (в нашем случае получатель один, поэтому failure будет содержать либо 0 либо 1)
        $failure = isset($json['failure']) ? $json['failure'] : null;
// canonical_ids содержит количество получателей, для которых нужно обновить RegistrationId (как и в случае с failure - значение либо 0 либо 1). 
        $canonicalIds = isset($json['canonical_ids']) ? $json['canonical_ids'] : null;
//Если оба параметра равны нулю, то дальнейший анализ результата не требуется. При условии $success=true можно считать что сообщение успешно доставлено
        if ($failure || $canonicalIds) {
//results содержит массив объектов. Так как у нас получатель один, то результат тоже будет один (в случае ошибки или смены RegistrationId)
           $results = isset($json['results']) ? $json['results'] : array();
            foreach($results as $result) {
                $newRegId = isset($result['registration_id']) ? $result['registration_id'] : null;
                $error = isset($result['error']) ? $result['error'] : null;
                if ($newRegId) { 
// Заменяем $regId на $newRegId;
                }
                else if ($error) {
                    if ($error == self::GCM_ERROR_NOTREGISTERED) {
                        // Удаляем $regId из базы;
                    }
                    else {
                        //Произошла другая ошибка, логируем её
//Если нужно дифференцировать ошибки, то их описание можно найти здесь http://developer.android.com/google/gcm/gcm.html#error_codes
                    }
                    $success = false;
                }
            }
//Теперь мы знаем, доставлено ли сообщение для конкретного получателя или нет.
}