zoukankan      html  css  js  c++  java
  • Android基于XMPP Smack Openfire下学习开发IM(五)连接断开重连

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


    首先要创建连接监听器,用来监听连接状态,这里我写了一个类

    继承了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);
    

    先介绍到这里~


  • 相关阅读:
    vue前端使用JsonViewer进行json展示
    vue代理服务器proxy配置
    'vue-cli-service' 不是内部或外部命令,也不是可运行的程序 或批处理文件。
    Python中的高阶函数和内置高阶函数(abs,map,reduce,sorted,filter)
    Ant Design Vue 通过v-decorator实现数据绑定
    Vue脚手架(vue-cli)搭建和目录结构详解
    如何使用Postman从XML提取变量
    【已解决】Vue格式化js自动加上冒号和分号
    vue.js安装与搭建
    Python函数中如何返回多个值?
  • 原文地址:https://www.cnblogs.com/keanuyaoo/p/3359976.html
Copyright © 2011-2022 走看看