Google Cloud Messaging-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 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 \RollingCurl\RollingCurlRequest $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; //  ,  Update 1 } else if ($error) { if ($error == self::GCM_ERROR_NOTREGISTERED) { // $regId  ; } else { //  ,   //   ,       http://developer.android.com/google/gcm/gcm.html#error_codes } $success = false; } } } //  ,        . }