Android信息推送—AndroidPN的学习(上)

         就最近的形势来看，似乎是不差的。变革即意味着机遇，确实如此。我觉得我似乎在朝着自己的计划慢慢靠近。我想很快就会有确切的答案吧。我静静地等着。

         

        最近两天一直在研究Android 信息推送的事情。学习了AndroidPN这个框架，虽然最后不会用这个，项目还是要自己搭，但终究有值得借鉴的地方，特此把学习的内容总结在这里。

 

        AndroidPN(Android Push Notification)是韩国人思密达共享的一个简单的框架，基于XMPP协议，实现了信息推送服务。

        一：安装测试运行

        1，下载客户端和服务器端程序。http://sourceforge.net/projects/androidpn/files/  程序10年11月上传后就没有再更改过，可能已经被原分享者放弃了思密达。

        2，打开客户端程序下的raw/androidpn.properties文件，配置客户端信息，将xmppHost配置成10.0.2.2，xmppPort=5222，5222 是服务器的xmpp服务监听端口。

        3，运行androidpn-server-0.5.0\bin\run.bat启动服务器，从浏览器访问http://127.0.0.1:7070/

在模拟器中运行客户端。

        4，从Web端向客户端发消息。

        效果如下：

       

        友情提示：

        1，如果出现运行run.bat一闪而过，无法访问http://127.0.0.1:7070/的情况，请配置好Java环境变量。

        2，客户端运行后后提示“Application unfortunately Stopped”，有可能是引用的asmack.jar包的问题，重新引用，然后Clean，重新Build Project。祝大家好运。

         二：源代码学习

        在项目中我是写客户端的，所以我主要学习了客户端的源码。现总结如下：
 
         1，程序入口DemoAppActivity开启服务：

 // Start the service
ServiceManager serviceManager = new ServiceManager(this);
serviceManager.setNotificationIcon(R.drawable.notification);//设置消息的图标
serviceManager.startService();

 在实例化ServiceManage的过程中，做了以下工作，加载 res/raw/androidpn.properties 配置文件中的参数信息，并将其保存在SharedPreferences中。然后调用startService()开启服务。

 

 

public void startService() {
        Thread serviceThread = new Thread(new Runnable() {
            @Override
            public void run() {
                Intent intent = NotificationService.getIntent();
                context.startService(intent);
            }
        });
        serviceThread.start();
}

 startService()方法开启了一个子线程去启动真正的信息推送服务NotificationService。对于Service，作者思密达在OnCreate()的时候做了很多工作，OnCreate()方法在服务被创建时调用，且只会被调用一次。因此多次的start()并不会产生多个实例。在OnCreate()方法中，作者获取了一个很重要的参数deviceId设备ID。可是后面并没有使用它。

 

 

telephonyManager = (TelephonyManager) getSystemService(Context.TELEPHONY_SERVICE);
// Get deviceId
deviceId = telephonyManager.getDeviceId();

 获得设备ID后，

 

 

xmppManager = new XmppManager(this);
taskSubmitter.submit(new Runnable() {
public void run() {
   NotificationService.this.start();
   }
});

 实例化XmappManager，并且调用taskSubmitter，在taskSubmitter方法里实例化NotificationService类，并且调用其start()方法。实例化NotificationService类时会做以下工作：

 

public NotificationService() {
        notificationReceiver = new NotificationReceiver();
        connectivityReceiver = new ConnectivityReceiver(this);
        phoneStateListener = new PhoneStateChangeListener(this);
        executorService = Executors.newSingleThreadExecutor();
        taskSubmitter = new TaskSubmitter(this);
        taskTracker = new TaskTracker(this);
}

 实例化notificationReceiver，NotificationReceiver继承了BroadcastReceiver类。BroadcastReceiver （广播接收者）用于接收广播 Intent 。ConnectivityReceiver同样继承了BroadcastReceiver类。PhoneStateChangeListener继承了PhoneStateListener，用于监听手机状态变化。Executors.newSingleThreadExecutor()返回一个线程池（这个线程池只有一个线程）,这个线程池可以在线程死后（或发生异常时）重新启动一个线程来替代原来的线程继续执行下去。

 

NotificationService.start()方法

private void start() {
        Log.d(LOGTAG, "start()...");
        registerNotificationReceiver();
        registerConnectivityReceiver();
        // Intent intent = getIntent();
        // startService(intent);
        xmppManager.connect();
}

 registerNotificationReceiver()方法注册了notificationReceiver来接收广播，registerConnectivityReceiver()方法注册了connectivityReceiver来监听网络连接状况。然后调用xmappManager的connect方法。

 

继续跟踪xmappManager的connect方法又执行了哪些工作

 

public void connect() {
        Log.d(LOGTAG, "connect()...");
        submitLoginTask();
}

 调用了submitLoginTask()方法，顾名思义，提交登录任务。

 

private void submitLoginTask() {
        Log.d(LOGTAG, "submitLoginTask()...");
        submitRegisterTask();
        addTask(new LoginTask());
}

 提交登录任务中，又提交了一个注册任务，同时将新建的登录任务添加到任务集合中并交由 TaskTracker 来对添加的任务进行监视。继续根据在登录任务中执行的工作：

（1）如果连接没有经过身份验证，根据username和password执行登录操作，然后为连接添加各种监听机制。执行刚刚添加的任务runTask()（2）如果连接通过身份验证，直接执行任务runTask();

 

private LoginTask() {
            this.xmppManager = XmppManager.this;
        }

        public void run() {
            Log.i(LOGTAG, "LoginTask.run()...");

            if (!xmppManager.isAuthenticated()) {
                Log.d(LOGTAG, "username=" + username);
                Log.d(LOGTAG, "password=" + password);

                try {
                    xmppManager.getConnection().login(
                            xmppManager.getUsername(),
                            xmppManager.getPassword(), XMPP_RESOURCE_NAME);
                    Log.d(LOGTAG, "Loggedn in successfully");

                    // connection listener
                    if (xmppManager.getConnectionListener() != null) {
                        xmppManager.getConnection().addConnectionListener(
                                xmppManager.getConnectionListener());
                    }

                    // packet filter
                    PacketFilter packetFilter = new PacketTypeFilter(
                            NotificationIQ.class);
                    // packet listener
                    PacketListener packetListener = xmppManager
                            .getNotificationPacketListener();
                    connection.addPacketListener(packetListener, packetFilter);

                    xmppManager.runTask();

                } catch (XMPPException e) {
                    Log.e(LOGTAG, "LoginTask.run()... xmpp error");
                    Log.e(LOGTAG, "Failed to login to xmpp server. Caused by: "
                            + e.getMessage());
                    String INVALID_CREDENTIALS_ERROR_CODE = "401";
                    String errorMessage = e.getMessage();
                    if (errorMessage != null
                            && errorMessage
                                    .contains(INVALID_CREDENTIALS_ERROR_CODE)) {
                        xmppManager.reregisterAccount();
                        return;
                    }
                    xmppManager.startReconnectionThread();

                } catch (Exception e) {
                    Log.e(LOGTAG, "LoginTask.run()... other error");
                    Log.e(LOGTAG, "Failed to login to xmpp server. Caused by: "
                            + e.getMessage());
                    xmppManager.startReconnectionThread();
                }

            } else {
                Log.i(LOGTAG, "Logged in already");
                xmppManager.runTask();
            }

        }
    }

 

 

 

 

具体的监听和接下来的操作会在下篇进行分析。