android中的C2DM

第一篇：

原文地址：

C2DM功能要求Android版本在2.2以上，同时设备中需要安装Android Market。整个架构包括3部分，手机端应用程序，支持手机端应用程序的服务器端程序，google的C2DM服务器。结构图如下：

先大概解释一下，在接下来的文档中会给出详细实现代码。

基本分为6步：

1. 手机端app带着google account向C2DM服务器注册；
2. C2DM服务器返回Register ID到手机端；
3. 手机端将获取的Register ID发送到第三方的服务器端；
4. 通过浏览器等其他方式将需要发送的data发送到第三方服务器端；
5. 第三方服务器将Register ID，data发送到C2DM服务器（要求第三方服务器需要有处理消息队列的能力）；
6. C2DM服务器将收到的data发送到手机端。

第二篇：

原文地址：http://cykoradise.com/blog/tag/c2dm/

从Android 2.2开始，提供了Cloud To Device Messaging（C2DM）的API。Android Developers上提供了一篇关于其实现机制的文章，作者是个华裔（google有很多………）

对于用户而言，C2DM的实现非常简单：

1. 应用程序对应的网站向google的C2DM Server发出一个1KB大小的消息，这个消息的主要目的是触发手机上应用程序的动作，而非直接传递信息。
2. C2DM Server将这个包转发给相应的手机。
3. 手机收到之后，触发C2DM的intent，调用相应的程序处理。

与竞争对手的方案比较，Android的实现有以下优点：

• BlackBerry的短信触发机制：Android不需要运营商支持，大大提高了应用的灵活性。
• iPhone的类似机制：由于Android天生的Intent机制，C2DM不需要应用程序聆听，系统收到消息后会自动启动应用程序，大大降低了对性能、耗电的要求，对用户而言也更加方便。

用户使用C2DM付出的代价主要有两点：

• 与google C2DM Server保持连接带来的电力和流量开销。事实上流量开销极小，可以不计。由于C2DM是内建在Android目前（用于同步联系人、日程表、gmail等）的同步机制中的，因此不会带来额外的电力开销。
• 应用程序启动后动作带来的电力和流量开销。这一点主要取决于应用程序自身的设计，还有就是网络条件带来的影响（如果网络质量不佳，会产生多次连接和连接不上的情况）。另外，由于应用程序安装后需要与C2DM服务器注册，因此客户可以选择关闭应用程序的C2DM功能。

总体而言，C2DM算是目前Push信息最佳的解决方案了。Google Code上的是第一个基于C2DM的实现，在桌面的Chrome浏览器安装相应的扩展，并在Android 2.2以上的手机上安装了chrometophone的apk之后，就可以在桌面浏览器上将当前网址或Google Maps的地址发送给手机，直接在手机上打开，而这一切只需要一键。

第三篇：

在中给出了C2DM的实现架构，这里写了一个最简单的客户端例子，项目目录如下：

说一下实现步骤：

• 编写manifest文件如下：

com.easymorse.myc2dm.permission.C2D_MESSAGE” android:protectionLevel=”signature” />
com.easymorse.myc2dm.permission.C2D_MESSAGE” />

android:label=”@string/app_name”>





=”.C2DMReceiver” />





com.easymorse.myc2dm” />




com.easymorse.myc2dm” />

红色标记的部分需要根据自己的情况修改为相应的包名。

• 引入google的C2DM java类包，如下：

• 注册service到客户端：

MainActivity中的主要代码如下：

public void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.main);
//    C2DMessaging.register(this, Config.C2DM_SENDER);

Intent registrationIntent = new Intent(”com.google.android.c2dm.intent.REGISTER”);
registrationIntent.putExtra(”app”, PendingIntent.getBroadcast(this, 0, new Intent(), 0)); // boilerplate
registrationIntent.putExtra(”sender”, DeviceRegistrar.SENDER_ID);

startService(registrationIntent);
}

其中sender对应的值是通过连接申请过的gmail帐号。

• 通过IntentService接受Register id和C2DM服务器push的消息。

public class C2DMReceiver extends C2DMBaseReceiver {
public C2DMReceiver() {

super(DeviceRegistrar.SENDER_ID);
Log.v(”tag”,”c2dm>>>>>C2DMReceiver”);
}

@Override
public void onRegistered(Context context, String registration) {
DeviceRegistrar.registerWithServer(context, registration);
Log.v(”tag”,”c2dm>>>>>C2DMReceiver>>>>>>>onRegistered and the id is : “+registration);
}

@Override
public void onUnregistered(Context context) {

String deviceRegistrationID = null;
DeviceRegistrar.unregisterWithServer(context, deviceRegistrationID);
Log.v(”tag”,”c2dm>>>>>C2DMReceiver>>>>>>>onUnregistered”);
}

@Override
public void onError(Context context, String errorId) {
context.sendBroadcast(new Intent(”com.google.ctp.UPDATE_UI”));
}

@Override
public void onMessage(Context context, Intent intent) {
Log.v(”tag”,”c2dm>>>>>C2DMReceiver>>>>>>>onMessage”);
Bundle extras = intent.getExtras();
if (extras != null) {
String url = (String) extras.get(”url”);
Log.v(”tag”,”c2dm>>>>>C2DMReceiver>>>>>>>onMessage>>>>url is “+url);
Editor sharedata = getSharedPreferences(
“myc2dm”, 0).edit();
sharedata.putString(”serverdata”,url);

NotificationManager manager = (NotificationManager) getSystemService(Context.NOTIFICATION_SERVICE);
Notification notification = new Notification(R.drawable.icon,
“收到消息”, System.currentTimeMillis());
notification.setLatestEventInfo(getApplicationContext(), “消息内容”,
url, PendingIntent.getActivity(
C2DMReceiver.this, 0,
new Intent(C2DMReceiver.this,MainActivity.class), 0));
notification.flags|=Notification.FLAG_AUTO_CANCEL;
notification.defaults |= Notification.DEFAULT_SOUND;
manager.notify(1, notification);

}
}
}

onRegistered接受C2DM发送的Register id，onMessage接受C2DM发送的data数据，这里可以根据自己情况做出相应的处理，这里给出简单的信息提示。

例子比较简单，需要完善的功能是在DeviceRegistar中将收到的Register id发送到自己的服务器端。

项目源码见：

第四篇：

原文地址：http://blog.csdn.net/ichliebephone/article/details/6635913

Android C2DM学习——服务器端代码开发

一．基础知识

        在前一部分，我们使用curl命令来代替了服务器端的实现，虽然在测试时使用curl命令是一个很是简单方便的模拟方式，但实际使用中我们需要把C2DM相关的服务器部分功能结合到已有的框架中，因此需要使用具体的代码来实现。

        第三方服务器端部分的功能主要是通过C2DM服务器向客户端发送要推送的数据。

        为了发送数据，第三方服务器需要向这个地址发送一个POST请求，其中POST的内容包含：

        registration_id：是客户端发送过来的registration_id值。必须包含。

        collapse_key：一个任意的字符串，用来表示一组相似的消息。当Android设备由离线到上线时，之前使用相同collapse_key推 送的消息，只有最后一条才会推送给Android设备。设置这个值用来避免Android设备上线时收到太多已经过时的消息。必须包含。

        data.：要推送的数据内容，以键值对的方式组织。当客户端程序接收时，就通过键值来获取对应的内容。一条推送消息中包含的键值对数目没有限制，虽然整体的数据大小有限制。可选。

        delay_while_idle：如果包含这项，则表明当Android设备idle时，C2DM服务不会立即把消息推送给设备而是等到设备重新变回active。可选。

        Authorization: GoogleLogin auth=[AUTH_TOKEN]：HTTP头部要包含的信息，是为SenderID申请的C2DM（服务代码为ac2dm）服务权限，这个需要提前获取。必须包含。

        因此第三方服务器就是构造这样的POST请求，然后向C2DM服务器发送。

        在这部分中，我们就使用java代码的方式实现之前使用curl模拟的第三方服务器功能。

二．实例开发

        创建一个Java工程，工程名为C2DMMessageServer，新建包名com.ichliebephone.server.c2dmmessage，并新建一个类C2DMMessageServer。

        第三方服务器端的和C2DM相关的功能可以分为两个，第一个是获取注册使用C2DM功能的用户账号的ClientLogin权限Auth值；第二个是按格式给C2DM服务器发送要Push的数据。

        我们先来看下获取Auth权限的方法实现：

//获取Auth权限值
    public static String getAuthToken(String url, String params) throws IOException{
        String auth = null;
        //要POST的数据
        byte[] postData = params.getBytes();
        //构造POST请求
        URL requestUrl = new URL(url);
        HttpURLConnection connection = (HttpURLConnection)requestUrl.openConnection();
        connection.setDoOutput(true);
        connection.setUseCaches(false);
        connection.setRequestMethod("POST");
        connection.setRequestProperty("Content-Type", "application/x-www-form-urlencoded;charset=UTF-8");
        connection.setRequestProperty("Content-Length", Integer.toString(postData.length));
        //写入POST数据
        OutputStream out = connection.getOutputStream();
        out.write(postData);
        out.flush();
        out.close();
        //获取并处理请求返回的数据
        BufferedReader reader = new BufferedReader(new InputStreamReader(connection.getInputStream()));
        String responseLine;
        StringBuilder responseDataBuidler = new StringBuilder();
        while((responseLine=reader.readLine())!=null){
            responseDataBuidler.append(responseLine);
        }
        int responseCode = connection.getResponseCode();
        System.out.println("auth responseCode = "+responseCode);
        if(responseCode == 200){
            //如果请求成功，提取Auth值
            int authStartIndex = responseDataBuidler.indexOf("Auth=");
            auth = responseDataBuidler.substring(authStartIndex+5);
            //System.out.println(auth);
        } else{
            //如果失败，打印出失败的结果
            System.out.println(responseDataBuidler);
        }
        return auth;
    }

         关于获取ClientLogin的说明参考谷歌的，方法的第一个参数url为请求的地址：， 第二个参数params为POST时带的内容，包括accountType（申请权限的账户类型），Email（账户邮箱地址），Passwd（账户邮箱 密码），service（申请权限的服务类型，这里申请C2DM服务，值为ac2dm），source（表示我们应用程序的一个简短字符串）。这里我传入 的值为"accountType=HOSTED_OR_GOOGLE&Email=[e-mail]& amp;Passwd=androidc2dmdemo&service=ac2dm&source=bupt-c2dmdemo-1.0";

        在getAuthToken方法中首先新建HttpURLConnection连接，构造POST请求，设置好参数，写入POST数据，然后获取并处理请求返回的内容。根据ClientLogin的官方文档，成功返回的response形式为：

HTTP/1.0 200 OK

Server: GFE/1.3

Content-Type: text/plain

 

SID=DQAAAGgA...7Zg8CTN

LSID=DQAAAGsA...lk8BBbG

Auth=DQAAAGgA...dk3fA5N

        没有成功请求返回的response形式为：

HTTP/1.0 403 Access Forbidden

Server: GFE/1.3

Content-Type: text/plain

 

Url=

Error=CaptchaRequired

CaptchaToken=DQAAAGgA...dkI1LK9

CaptchaUrl=Captcha?ctoken=HiteT4b0Bk5Xg18_AcVoP6-yFkHPibe7O9EqxeiI7lUSN

        因此这里我们根据返回的responseCode判断，如果是200则表明请求成功，从返回的数据中提取我们需要的Auth值。如果不是200则表明请 求出错，这里只是简单的打印出出错的信息。实际使用中需要更加错误的信息做相应的处理，比如是服务器端没响应的话那就等待一段时间重新尝试，等等。

获取了Auth权限值，接了下来我们就可以给C2DM服务器发送我们想要其Push的数据了，实现向C2DM服务器发送数据的方法为：

//向C2DM服务器发送需要Push的数据
    public static boolean sendPushMessage(String url, String registration_id, String collapse_key, String auth, Map data) throws IOException{
        boolean flag = false;
        //构造POST的数据
        StringBuilder postDataBuidler = new StringBuilder();
        postDataBuidler.append("registration_id").append("=").append(registration_id);
        postDataBuidler.append("&").append("collapse_key").append("=").append(collapse_key);
        for(Object keyObject:data.keySet()){
            String key = (String)keyObject;
            if(key.startsWith("data.")){
                String value = data.get(key);
                postDataBuidler.append("&").append(key).append("=").append(value);
            }

        }
        byte[] postData = postDataBuidler.toString().getBytes();
        //构造POST请求
        URL requestUrl = new URL(url);
        HttpURLConnection connection = (HttpURLConnection)requestUrl.openConnection();
        connection.setDoOutput(true);
        connection.setUseCaches(false);
        connection.setRequestMethod("POST");
        connection.setRequestProperty("Content-Type", "application/x-www-form-urlencoded;charset=UTF-8");
        connection.setRequestProperty("Content-Length", Integer.toString(postData.length));
        connection.setRequestProperty("Authorization", "GoogleLogin auth="+auth);
        //写入POST数据
        OutputStream out = connection.getOutputStream();
        out.write(postData);
        out.flush();
        out.close();
        //获取并处理请求返回的数据
        int responseCode = connection.getResponseCode();
        System.out.println("c2dm responseCode = "+responseCode);
        if(responseCode == 200){
            BufferedReader reader = new BufferedReader(new InputStreamReader(connection.getInputStream()));
            String responseLine;
            StringBuilder responseDataBuidler = new StringBuilder();
            while((responseLine=reader.readLine())!=null){
                responseDataBuidler.append(responseLine);
            }
            if(responseDataBuidler.toString().startsWith("id=")){
                flag = true;
            }
            System.out.println(responseDataBuidler);
        } else if(responseCode == 503){
            System.out.println("The server is temporarily unavailable, please try later");
        } else if(responseCode == 401){
            System.out.println(" the ClientLogin AUTH_TOKEN used to validate the sender is invalid");
        }
        return flag;
    }

        关于第三方服务器向C2DM发送数据的说明可以查看C2DM的，其中发送的URL为，因为使用https的方式会提示出错，因此使用http的方式，URL为， 使用POST方式提交要包含的内容有registration_id（Android应用程序注册获得的id），collapse_key（用任意一个字符传表示一组类似的消息，如果Android设备离线了，那等其上线后这组消息中只有最后一条消息才会被Push给Android设备，这样重新上线后的Android设备不会收到太多之前过时的消息），ClientLogin auth（上 一步获取的使用C2DM功能的账户权限），data（这是一个键值对形式表示的数据，形式比如为data.msg=ichliebejiajia，其中键 值需要和Android设备上的程序统一化，以便其可以获取解析，这是真正需要Push给Android设备的数据）。

        在sendPushMessage方法中，首先构造POST的数据，然后创建HttpURLConnection连接，以POST的方式发送请求，最后 接收并处理请求返回的数据。根据官方文档的说明，当返回的responseCode为200，并且返回的数据以id=开头时，才算数据发送成功。

图1 C2DM服务器返回的结果

        当responseCode为200，但返回的数据不是以id=开头时，则表明向C2DM发送数据错误，返回的数据包含错误代码，Error=[错误代码]。错误代码可能为：

        QuotaExceeded：超过发送的配额了，等待一会后重新尝试。在C2DM服务注册页面，我们可以看到有两项是填写和配额相关的内容：一项是估计 每天发送的总条数（Estimated total number of messages per day?）；另一项是每秒钟发送的峰值条数（Estimated peak queries per second (QPS)）。

        DeviceQuotaExceeded：给某一个特定的设备发送了太多的信息，等待一会后重新尝试。

        InvalidRegistration：缺少或者是错误的registration_id。如果是这个错误，那服务器应该停止给这个registration_id对应的设备发送信息。

        NotRegistered：registration_id值不再有效，比如客户端程序的使用者关闭了推送通知接收功能或者卸载了客户端程序时。此时服务器也应该停止给这个registration_id对应的设备发送信息。

       MessageTooBig：发送的信息太大了，因为信息的长度限制为不大于1024字节。需要减少信息的长度。

       MissingCollapseKey：POST的内容中缺少collapse_key值。

        当responseCode是503时，表示C2DM服务器没有响应，此时可以等待一段时间后重新尝试。

        当responseCode为401时，表示ClientLogin的Auth值无效。

        除了发送成功外，其他情况我们打印出对应的错误说明。在实际使用时，我们需要更加具体的错误情况来做具体的处理，比如当提示超过配额（如果为峰值配额）时，等待一段时间重新尝试；当服务器没有响应时，等待一个回退时间再重新尝试，等等。

        实现了获取ClientLogin的Auth值和向C2DM服务器发送需要Push的数据两个功能后，接下来我们就可以使用代码的方式来完成下之前用curl命令模拟的第三方服务器功能。C2DMMessageServer的main方法为：

public static String ClientLoginURL = "";
    public static String AuthTokenParams = "accountType=HOSTED_OR_GOOGLE&Email=[e-mail]&Passwd=androidc2dmdemo&service=ac2dm&source=bupt-c2dmdemo-1.0";
    public static String C2DMServerURL = "";
    public static String Registration_ID = "APA91bGUBoSvt3G5Ny9t0IGLmIKAKYX6G6VHwSQHh3tP2fqcaQ0N4GPdKh5B3RDUHFCFF06YwT8ifOP_cOy5BAWyCLHL8d8NpuIW9AqXt9h2JSBVF2MitZA";
    /**
     * @param args
     */
    public static void main(String[] args) {
        // TODO Auto-generated method stub
        System.out.println("The C2DMMessageServer is started...");
        try {
            String authToken = getAuthToken(ClientLoginURL, AuthTokenParams);
            if(authToken==null){
                System.out.println("Can not get the Auth");
                return;
            }
            BufferedReader reader = new BufferedReader(new InputStreamReader(System.in));
            while(true){
                System.out.println("Please input the message to push:(Exit with q)");
                String message = reader.readLine();
                if(message.equalsIgnoreCase("q")){
                    break;
                }
                Map data = new HashMap();
                data.put("data.msg", message);//这里和客户端代码统一，使用的key为msg，并且只push一组数据
                if(sendPushMessage(C2DMServerURL, Registration_ID, "1", authToken, data)){
                    System.out.println("Send Successfully");
                }else{
                    System.out.println("Send Failed");
                }

            }
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }

"text-align: left;">

"text-align: left;">   }