學習過程中大家都碰到過連線被斷開的問題給困擾吧，下面教大家如何做到連線斷開後，重新連線

首先要建立連線監聽器，用來監聽連線狀態，這裡我寫了一個類

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

前者為連線正常斷開，後者是連線異常斷開，不管是正常還是異常，我們都要監聽到

這裡寫了一個定時器，兩秒進行連線一次，註釋寫的也很清楚，不做太多介紹

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

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() {
	}

}
 

// 新增連線監聽
TaxiConnectionListener connectionListener = new TaxiConnectionListener();
getConnection().addConnectionListener(connectionListener);

connection.removeConnectionListener(connectionListener);

先介紹到這裡~