Android基於XMPP Smack Openfire下學習開發IM(五)鏈接斷開重連

學習過程當中你們都碰到過鏈接被斷開的問題給困擾吧，下面教你們如何作到鏈接斷開後，從新鏈接

首先要建立鏈接監聽器，用來監聽鏈接狀態，這裏我寫了一個類

繼承了ConnectionListener，重寫了裏面5個方法，最重要的兩個方法connectionClosed()和connectionClosedOnError()

前者爲鏈接正常斷開，後者是鏈接異常斷開，無論是正常仍是異常，咱們都要監聽到

這裏寫了一個定時器，兩秒進行鏈接一次，註釋寫的也很清楚，不作太多介紹

要注意的是我把用戶名和密碼都存到sharePreferences中了

[java] view plaincopyprint? package com.techrare.listener;

import java.util.Timer;
import java.util.TimerTask;

import org.jivesoftware.smack.ConnectionListener;

import android.util.Log;

import com.techrare.taxicall.MainActivity;
import com.techrare.utils.Utils;
import com.techrare.utils.XmppConnection;

/**

• 鏈接監聽類
• @author Administrator

*/
public class TaxiConnectionListener implements ConnectionListener {
private Timer tExit;
private String username;
private String password;
private int logintime = 2000;

@Override  
public void connectionClosed() {  
    Log.i("TaxiConnectionListener", "連接關閉");  
    // 關閉連接   
    XmppConnection.getInstance().closeConnection();  
    // 重連服務器   
    tExit = new Timer();  
    tExit.schedule(new timetask(), logintime);  
}  

@Override  
public void connectionClosedOnError(Exception e) {  
    Log.i("TaxiConnectionListener", "連接關閉異常");  
    // 判斷為帳號已被登錄   
    boolean error = e.getMessage().equals("stream:error (conflict)");  
    if (!error) {  
        // 關閉連接   
        XmppConnection.getInstance().closeConnection();  
        // 重連服務器   
        tExit = new Timer();  
        tExit.schedule(new timetask(), logintime);  
    }  
}  

class timetask extends TimerTask {  
    @Override  
    public void run() {  
        username = Utils.getInstance().getSharedPreferences("taxicall",  
                "account", MainActivity.context);  
        password = Utils.getInstance().getSharedPreferences("taxicall",  
                "password", MainActivity.context);  
        if (username != null && password != null) {  
            Log.i("TaxiConnectionListener", "嘗試登錄");  
            // 鏈接服務器   
            if (XmppConnection.getInstance().login(username, password)) {  
                Log.i("TaxiConnectionListener", "登錄成功");  
            } else {  
                Log.i("TaxiConnectionListener", "從新登錄");  
                tExit.schedule(new timetask(), logintime);  
            }  
        }  
    }  
}  

@Override  
public void reconnectingIn(int arg0) {  
}  

@Override  
public void reconnectionFailed(Exception arg0) {  
}  

@Override  
public void reconnectionSuccessful() {  
}

}

package com.techrare.listener;

import java.util.Timer; import java.util.TimerTask;

import org.jivesoftware.smack.ConnectionListener;

import android.util.Log;

import com.techrare.taxicall.MainActivity; import com.techrare.utils.Utils; import com.techrare.utils.XmppConnection;

/**

• 鏈接監聽類
• @author Administrator

*/ public class TaxiConnectionListener implements ConnectionListener { private Timer tExit; private String username; private String password; private int logintime = 2000;

@Override
public void connectionClosed() {
	Log.i("TaxiConnectionListener", "連接關閉");
	// 關閉連接
	XmppConnection.getInstance().closeConnection();
	// 重連服務器
	tExit = new Timer();
	tExit.schedule(new timetask(), logintime);
}

@Override
public void connectionClosedOnError(Exception e) {
	Log.i("TaxiConnectionListener", "連接關閉異常");
	// 判斷為帳號已被登錄
	boolean error = e.getMessage().equals("stream:error (conflict)");
	if (!error) {
		// 關閉連接
		XmppConnection.getInstance().closeConnection();
		// 重連服務器
		tExit = new Timer();
		tExit.schedule(new timetask(), logintime);
	}
}

class timetask extends TimerTask {
	@Override
	public void run() {
		username = Utils.getInstance().getSharedPreferences("taxicall",
				"account", MainActivity.context);
		password = Utils.getInstance().getSharedPreferences("taxicall",
				"password", MainActivity.context);
		if (username != null && password != null) {
			Log.i("TaxiConnectionListener", "嘗試登錄");
			// 鏈接服務器
			if (XmppConnection.getInstance().login(username, password)) {
				Log.i("TaxiConnectionListener", "登錄成功");
			} else {
				Log.i("TaxiConnectionListener", "從新登錄");
				tExit.schedule(new timetask(), logintime);
			}
		}
	}
}

@Override
public void reconnectingIn(int arg0) {
}

@Override
public void reconnectionFailed(Exception arg0) {
}

@Override
public void reconnectionSuccessful() {
}

}

其次就是給鏈接設置監聽器了，最好放在登陸方法裏，關閉鏈接方法裏移除監聽

[java] view plaincopyprint? // 添加連接監聽
TaxiConnectionListener connectionListener = new TaxiConnectionListener();
getConnection().addConnectionListener(connectionListener);

// 添加連接監聽 TaxiConnectionListener connectionListener = new TaxiConnectionListener(); getConnection().addConnectionListener(connectionListener);[java] view plaincopyprint? connection.removeConnectionListener(connectionListener);

connection.removeConnectionListener(connectionListener);