Smack+OpenFire搭建IM通信，包含心跳和自動重連（Android實現）

Smack是一個開源，易於使用的XMPP（jabber）客戶端類庫。優點：簡單的，功能強大，給用戶發送信息只需三行代碼便可完成。缺點：API並非為大量並發用戶設計，每個客戶要1個線程，占用資源大。
OpenFire是開源的、基於可拓展通訊和表示協議(XMPP)、采用Java編程語言開發的實時協作服務器。 Openfire安裝和使用都非常簡單，並利用Web進行管理。單台服務器可支持上萬並發用戶。
1、首先到網址 http://www.igniterealtime.org 下載OpenFire服務器和Smack jar包

2、安裝OpenFire登陸到控制台

　  這里設置多長時間關閉閑置連接，可以判斷用戶是否在線的最長反應時間

3、創建兩個測試賬號，先用Spark登陸一個賬號

4、手機端登陸，使用Service保持連接，並與spark端發送消息，實現雙向通信（代碼和程序在后面）

5、關鍵代碼

配置連接OpenFire服務器，連接成功后設置響應Linstener和Receiver，這里因業務需求設置ping間隔為10s

    public void connect() {
        Log.i(TAG, "connect()");
        XMPPTCPConnectionConfiguration.Builder configBuilder = XMPPTCPConnectionConfiguration.builder();
        configBuilder.setHost(SmackConst.XMPP_HOST);
        configBuilder.setServiceName(SmackConst.SERVICE_NAME);
        configBuilder.setUsernameAndPassword(mUsername, mPassword);
        configBuilder.setSecurityMode(SecurityMode.disabled);
        mConnection = new XMPPTCPConnection(configBuilder.build());
        //Set ConnectionListener here to catch initial connect();
        mConnection.addConnectionListener(this);
        try {
            mConnection.connect();
            mConnection.login();
            if(mConnection.isAuthenticated()){//登錄成功
                MyPingManager.setDefaultPingInterval(10);//Ping every 10 seconds
                MyPingManager myPingManager = MyPingManager.getInstanceFor(mConnection);
                //Set PingListener here to catch connect status
                myPingManager.registerPingFailedListener(SmackConnection.this);
                setupSendMessageReceiver();
                //Set ChatListener here to catch receive message and send NEW_MESSAGE broadcast
                ChatManager.getInstanceFor(mConnection).addChatListener(this);
                //Set ChatListener here to catch roster change and rebuildRoster
                //Roster.getInstanceFor(mConnection).addRosterListener(this);
                sendLoginBroadcast(true);
            }else{
                mConnection.disconnect();
                Log.i(TAG, "Authentication failure");
                sendLoginBroadcast(false);
            }
        } catch (Exception e) {
            e.printStackTrace();
            sendLoginBroadcast(false);
            Intent intent = new Intent(mService, mService.getClass());
            mService.stopService(intent);
        }

    }

 自動重連TimerTask，Ping失敗后啟動，重連成功后關閉

    private Timer reConnectTimer;
    private int delay = 10000;
    //pingFailed時啟動重連線程
    class ReConnectTimer extends TimerTask {  
        @Override  
        public void run() {
            // 無網絡連接時,直接返回
            if (getNetworkState(mService) == NETWORN_NONE) {
                Log.i(TAG, "無網絡連接，"+delay/1000+"s后重新連接");
                reConnectTimer.schedule(new ReConnectTimer(), delay);
                //reConnectTimer.cancel();
                return;
            }
            // 連接服務器 
            try {
                mConnection.connect();
                if(!mConnection.isAuthenticated()){
                    mConnection.login();
                    reConnectTimer.cancel();
                }
                Log.i(TAG, "重連成功");
                Intent intent = new Intent(SmackConst.ACTION_RECONNECT_SUCCESS);
                mService.sendBroadcast(intent);
            } catch (Exception e) {
                Log.i(TAG, "重連失敗，"+delay/1000+"s后重新連接");
                e.printStackTrace();
                reConnectTimer.schedule(new ReConnectTimer(), delay);
            } 
            
        }  
    }

資源地址：https://github.com/liuhaijin/Smack-Openfire

菜鳥一枚，共同學習~~