Android编程实现google消息通知功能示例

public class GcmBroadcastReceiver extends WakefulBroadcastReceiver {  private static final String TAG = "GcmBroadcastReceiver";  @Override  public void onReceive(Context context, Intent intent) {    Log.v(TAG, "onReceive start");    ComponentName comp = new ComponentName(context.getPackageName(),        GcmIntentService.class.getName());    startWakefulService(context, (intent.setComponent(comp)));    setResultCode(Activity.RESULT_OK);    Log.v(TAG, "onReceive end");  }}

public class GcmIntentService extends IntentService {  private static final String TAG = "GcmIntentService";  public static final int NOTIFICATION_ID = 1;  private NotificationManager mNotificationManager;  NotificationCompat.Builder builder;  private Intent mIntent;  public GcmIntentService() {    super("GcmIntentService");    Log.v(TAG, "GcmIntentService start");    Log.v(TAG, "GcmIntentService end");  }  @Override  protected void onHandleIntent(Intent intent) {    Log.v(TAG, "onHandleIntent start");    Bundle extras = intent.getExtras();    GoogleCloudMessaging gcm = GoogleCloudMessaging.getInstance(this);    String messageType = gcm.getMessageType(intent);    if (!extras.isEmpty()) {      if (GoogleCloudMessaging.MESSAGE_TYPE_SEND_ERROR          .equals(messageType)) {        sendNotification(extras.getString("from"), "Send error",            extras.toString(), "", null, null);      } else if (GoogleCloudMessaging.MESSAGE_TYPE_DELETED          .equals(messageType)) {        sendNotification(extras.getString("from"),            "Deleted messages on server", extras.toString(), "",            null, null);      } else if (GoogleCloudMessaging.MESSAGE_TYPE_MESSAGE          .equals(messageType)) {        Log.v(TAG, "BUNDLE SIZE = " + extras.size());        boolean sendreply = false;        String msgid = null;        for (String key : extras.keySet()) {          if ("gcm.notification.title".equals(key)              || "gcm.notification.body".equals(key)              || "gcm.notification.click_action".equals(key)              || "gcm.notification.orderNumber".equals(key)) {            Log.v(TAG,                "KEY=" + key + " DATA=" + extras.getString(key));          } else if ("gcm.notification.messageId".equals(key)) {            sendreply = true;            msgid = extras.getString(key);            Log.v(TAG, "KEY=" + key + " DATA=" + msgid);          } else {            Log.v(TAG, "KEY=" + key);          }        }        sendNotification(extras.getString("from"),            extras.getString("gcm.notification.title"),            extras.getString("gcm.notification.body"),            extras.getString("gcm.notification.click_action"),            extras.getString("gcm.notification.orderNumber"), msgid);        Log.i(TAG, "Received: " + extras.toString());        mIntent = intent;        if (sendreply) {          new SendReceivedReply().execute(msgid);        } else {          GcmBroadcastReceiver.completeWakefulIntent(intent);        }      }    } else {      GcmBroadcastReceiver.completeWakefulIntent(intent);    }    Log.v(TAG, "onHandleIntent end");  }  private void sendNotification(String from, String title, String msg,      String action, String ordernumber, String msgid) {    Log.v(TAG, "sendNotification start");    Log.v(TAG, "FROM=" + from + " TITLE=" + title + " MSG=" + msg        + " ACTION=" + action + " ORDERNUMBER=" + ordernumber);    mNotificationManager = (NotificationManager) this        .getSystemService(Context.NOTIFICATION_SERVICE);    NotificationCompat.Builder mBuilder = new NotificationCompat.Builder(        this).setSmallIcon(R.drawable.ic_launcher)        .setContentTitle(title)        .setStyle(new NotificationCompat.BigTextStyle().bigText(msg))        .setContentText(msg)        .setSound(Settings.System.DEFAULT_NOTIFICATION_URI);    PendingIntent contentIntent = PendingIntent.getActivity(this, 0,        new Intent(this, ActivitySplash.class), 0);    mBuilder.setContentIntent(contentIntent);    if (ordernumber == null) {      mNotificationManager.notify(NOTIFICATION_ID, mBuilder.build());    } else {      int n = ordernumber.charAt(0);      String s = String.format(Locale.ENGLISH, "%d%s", n,          ordernumber.substring(1));      n = Integer.valueOf(s);      Log.v(TAG, "NOTIF ID=" + n);      mNotificationManager.notify(n, mBuilder.build());    }    GregorianCalendar c = new GregorianCalendar();    UtilDb.msgAdd(c.getTimeInMillis(), title, msg, msgid);    Intent intent = new Intent(UtilConst.BROADCAST_MESSAGE);    LocalBroadcastManager.getInstance(this).sendBroadcast(intent);    Log.v(TAG, "sendNotification end");  }  /*************************************************************/  /************************** ASYNCTASK ************************/  /*************************************************************/  private class SendReceivedReply extends AsyncTask<String, Void, Void> {    @Override    protected Void doInBackground(String... params) {      if (params[0] != null) {        ArrayList<NameValuePair> nvp = new ArrayList<NameValuePair>();        nvp.add(new BasicNameValuePair("MessageId", params[0]));        UtilApp.doHttpPost(getString(R.string.url_base)            + getString(R.string.url_msg_send_received), nvp, null);      }      return null;    }    @Override    protected void onPostExecute(Void result) {      GcmBroadcastReceiver.completeWakefulIntent(mIntent);    }  }}

public class GoogleNotificationRequestObj{  public IList<string> registration_ids { get; set; }  public Dictionary<string, string> notification { get; set; }}private static ILog _log = LogManager.GetLogger(typeof(GoogleNotification));public static string CallGoogleAPI(string receiverList, string title, string message, string messageId = "-1"){  string result = "";  string applicationId = ConfigurationManager.AppSettings["GcmAuthKey"];  WebRequest wRequest;  wRequest = WebRequest.Create("https://gcm-http.googleapis.com/gcm/send");  wRequest.Method = "post";  wRequest.ContentType = " application/json;charset=UTF-8";  wRequest.Headers.Add(string.Format("Authorization: key={0}", applicationId));  string postData;  var obj = new GoogleNotificationRequestObj()  {    registration_ids = new List<string>() { receiverList },    notification = new Dictionary<string, string>    {      {"body", message},      {"title", title}    }  };  if (messageId != "-1")  {    obj.notification.Add("messageId", messageId);  }  postData = JsonConvert.SerializeObject(obj);  _log.Info(postData);  Byte[] bytes = Encoding.UTF8.GetBytes(postData);  wRequest.ContentLength = bytes.Length;  Stream stream = wRequest.GetRequestStream();  stream.Write(bytes, 0, bytes.Length);  stream.Close();  WebResponse wResponse = wRequest.GetResponse();  stream = wResponse.GetResponseStream();  StreamReader reader = new StreamReader(stream);  String response = reader.ReadToEnd();  HttpWebResponse httpResponse = (HttpWebResponse)wResponse;  string status = httpResponse.StatusCode.ToString();  reader.Close();  stream.Close();  wResponse.Close();  if (status != "OK")  {    result = string.Format("{0} {1}", httpResponse.StatusCode, httpResponse.StatusDescription);  }  return result;}