欢迎来到Doc100.Net免费学习资源知识分享平台!
您的位置:首页 > 程序异常 >

android 基于xmpp smack openfire 联接断开重连

更新时间: 2014-01-05 02:35:11 责任编辑: Author_N1

 

Android 基于XMPP Smack Openfire 连接断开重连
学习过程中大家都碰到过连接被断开的问题给困扰吧,下面教大家如何做到连接断开后,重新连接

首先要创建连接监听器,用来监听连接状态,这里我写了一个类
继承了ConnectionListener,重写了里面5个方法,最重要的两个方法connectionClosed()和connectionClosedOnError()
前者为连接正常断开,后者是连接异常断开,不管是正常还是异常,我们都要监听到
这里写了一个定时器,两秒进行连接一次,注释写的也很清楚,不做太多介绍
要注意的是我把用户名和密码都存到sharePreferences中了
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);

先介绍到这里~
上一篇:上一篇
下一篇:下一篇

 

随机推荐程序问答结果

 

 

如对文章有任何疑问请提交到问题反馈,或者您对内容不满意,请您反馈给我们DOC100.NET论坛发贴求解。
DOC100.NET资源网,机器学习分类整理更新日期::2014-01-05 02:35:11
如需转载,请注明文章出处和来源网址:http://www.doc100.net/bugs/t/11738/
本文WWW.DOC100.NET DOC100.NET版权所有。