Android基于XMPP Smack Openfire下学习开发IM(五)连接断开重连

2023-11-22 14:18

本文主要是介绍Android基于XMPP Smack Openfire下学习开发IM(五)连接断开重连,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

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


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

继承了ConnectionListener,重写了里面5个方法,最重要的两个方法connectionClosed()和connectionClosedOnError()

前者为连接正常断开,后者是连接异常断开,不管是正常还是异常,我们都要监听到

这里写了一个定时器,两秒进行连接一次,注释写的也很清楚,不做太多介绍

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


[java]  view plain copy
  1. package com.techrare.listener;  
  2.   
  3. import java.util.Timer;  
  4. import java.util.TimerTask;  
  5.   
  6. import org.jivesoftware.smack.ConnectionListener;  
  7.   
  8. import android.util.Log;  
  9.   
  10. import com.techrare.taxicall.MainActivity;  
  11. import com.techrare.utils.Utils;  
  12. import com.techrare.utils.XmppConnection;  
  13.   
  14. /** 
  15.  * 连接监听类 
  16.  *  
  17.  * @author Administrator 
  18.  *  
  19.  */  
  20. public class TaxiConnectionListener implements ConnectionListener {  
  21.     private Timer tExit;  
  22.     private String username;  
  23.     private String password;  
  24.     private int logintime = 2000;  
  25.   
  26.     @Override  
  27.     public void connectionClosed() {  
  28.         Log.i("TaxiConnectionListener""連接關閉");  
  29.         // 關閉連接  
  30.         XmppConnection.getInstance().closeConnection();  
  31.         // 重连服务器  
  32.         tExit = new Timer();  
  33.         tExit.schedule(new timetask(), logintime);  
  34.     }  
  35.   
  36.     @Override  
  37.     public void connectionClosedOnError(Exception e) {  
  38.         Log.i("TaxiConnectionListener""連接關閉異常");  
  39.         // 判斷為帳號已被登錄  
  40.         boolean error = e.getMessage().equals("stream:error (conflict)");  
  41.         if (!error) {  
  42.             // 關閉連接  
  43.             XmppConnection.getInstance().closeConnection();  
  44.             // 重连服务器  
  45.             tExit = new Timer();  
  46.             tExit.schedule(new timetask(), logintime);  
  47.         }  
  48.     }  
  49.   
  50.     class timetask extends TimerTask {  
  51.         @Override  
  52.         public void run() {  
  53.             username = Utils.getInstance().getSharedPreferences("taxicall",  
  54.                     "account", MainActivity.context);  
  55.             password = Utils.getInstance().getSharedPreferences("taxicall",  
  56.                     "password", MainActivity.context);  
  57.             if (username != null && password != null) {  
  58.                 Log.i("TaxiConnectionListener""嘗試登錄");  
  59.                 // 连接服务器  
  60.                 if (XmppConnection.getInstance().login(username, password)) {  
  61.                     Log.i("TaxiConnectionListener""登錄成功");  
  62.                 } else {  
  63.                     Log.i("TaxiConnectionListener""重新登錄");  
  64.                     tExit.schedule(new timetask(), logintime);  
  65.                 }  
  66.             }  
  67.         }  
  68.     }  
  69.   
  70.     @Override  
  71.     public void reconnectingIn(int arg0) {  
  72.     }  
  73.   
  74.     @Override  
  75.     public void reconnectionFailed(Exception arg0) {  
  76.     }  
  77.   
  78.     @Override  
  79.     public void reconnectionSuccessful() {  
  80.     }  
  81.   
  82. }  

其次就是给连接设置监听器了,最好放在登录方法里,关闭连接方法里移除监听

[java]  view plain copy
  1. // 添加連接監聽  
  2. TaxiConnectionListener connectionListener = new TaxiConnectionListener();  
  3. getConnection().addConnectionListener(connectionListener);  
[java]  view plain copy
  1. connection.removeConnectionListener(connectionListener);  

先介绍到这里~

这篇关于Android基于XMPP Smack Openfire下学习开发IM(五)连接断开重连的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!


原文地址:
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.chinasem.cn/article/410730

相关文章

基于Python开发一个图像水印批量添加工具

《基于Python开发一个图像水印批量添加工具》在当今数字化内容爆炸式增长的时代,图像版权保护已成为创作者和企业的核心需求,本方案将详细介绍一个基于PythonPIL库的工业级图像水印解决方案,有需要... 目录一、系统架构设计1.1 整体处理流程1.2 类结构设计(扩展版本)二、核心算法深入解析2.1 自

C#连接SQL server数据库命令的基本步骤

《C#连接SQLserver数据库命令的基本步骤》文章讲解了连接SQLServer数据库的步骤,包括引入命名空间、构建连接字符串、使用SqlConnection和SqlCommand执行SQL操作,... 目录建议配合使用:如何下载和安装SQL server数据库-CSDN博客1. 引入必要的命名空间2.

Android kotlin中 Channel 和 Flow 的区别和选择使用场景分析

《Androidkotlin中Channel和Flow的区别和选择使用场景分析》Kotlin协程中,Flow是冷数据流,按需触发,适合响应式数据处理;Channel是热数据流,持续发送,支持... 目录一、基本概念界定FlowChannel二、核心特性对比数据生产触发条件生产与消费的关系背压处理机制生命周期

Android ClassLoader加载机制详解

《AndroidClassLoader加载机制详解》Android的ClassLoader负责加载.dex文件,基于双亲委派模型,支持热修复和插件化,需注意类冲突、内存泄漏和兼容性问题,本文给大家介... 目录一、ClassLoader概述1.1 类加载的基本概念1.2 android与Java Class

Java通过驱动包(jar包)连接MySQL数据库的步骤总结及验证方式

《Java通过驱动包(jar包)连接MySQL数据库的步骤总结及验证方式》本文详细介绍如何使用Java通过JDBC连接MySQL数据库,包括下载驱动、配置Eclipse环境、检测数据库连接等关键步骤,... 目录一、下载驱动包二、放jar包三、检测数据库连接JavaJava 如何使用 JDBC 连接 mys

Qt使用QSqlDatabase连接MySQL实现增删改查功能

《Qt使用QSqlDatabase连接MySQL实现增删改查功能》这篇文章主要为大家详细介绍了Qt如何使用QSqlDatabase连接MySQL实现增删改查功能,文中的示例代码讲解详细,感兴趣的小伙伴... 目录一、创建数据表二、连接mysql数据库三、封装成一个完整的轻量级 ORM 风格类3.1 表结构

MySQL中的表连接原理分析

《MySQL中的表连接原理分析》:本文主要介绍MySQL中的表连接原理分析,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录1、背景2、环境3、表连接原理【1】驱动表和被驱动表【2】内连接【3】外连接【4编程】嵌套循环连接【5】join buffer4、总结1、背景

SpringBoot开发中十大常见陷阱深度解析与避坑指南

《SpringBoot开发中十大常见陷阱深度解析与避坑指南》在SpringBoot的开发过程中,即使是经验丰富的开发者也难免会遇到各种棘手的问题,本文将针对SpringBoot开发中十大常见的“坑... 目录引言一、配置总出错?是不是同时用了.properties和.yml?二、换个位置配置就失效?搞清楚加

SpringBoot连接Redis集群教程

《SpringBoot连接Redis集群教程》:本文主要介绍SpringBoot连接Redis集群教程,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录1. 依赖2. 修改配置文件3. 创建RedisClusterConfig4. 测试总结1. 依赖 <de

Android DataBinding 与 MVVM使用详解

《AndroidDataBinding与MVVM使用详解》本文介绍AndroidDataBinding库,其通过绑定UI组件与数据源实现自动更新,支持双向绑定和逻辑运算,减少模板代码,结合MV... 目录一、DataBinding 核心概念二、配置与基础使用1. 启用 DataBinding 2. 基础布局