Smack+OpenFire搭建IM通信,包含心跳和自动重连(Android实现)
发布日期:2022-03-30 18:18:25 浏览次数:51 分类:博客文章

本文共 3689 字,大约阅读时间需要 12 分钟。

Smack是一个开源,易于使用的XMPP(jabber)客户端类库。优点:简单的,功能强大,给用户发送信息只需三行代码便可完成。缺点:API并非为大量并发用户设计,每个客户要1个线程,占用资源大。

OpenFire是开源的、基于可拓展通讯和表示协议(XMPP)、采用Java编程语言开发的实时协作服务器。 Openfire安装和使用都非常简单,并利用Web进行管理。单台服务器可支持上万并发用户。
1、首先到网址 http://www.igniterealtime.org 下载OpenFire服务器和Smack jar包

2、安装OpenFire登陆到控制台

   这里设置多长时间关闭闲置连接,可以判断用户是否在线的最长反应时间

3、创建两个测试账号,先用Spark登陆一个账号

4、手机端登陆,使用Service保持连接,并与spark端发送消息,实现双向通信(代码和程序在后面)

5、关键代码

配置连接OpenFire服务器,连接成功后设置响应Linstener和Receiver,这里因业务需求设置ping间隔为10s

1     public void connect() { 2         Log.i(TAG, "connect()"); 3         XMPPTCPConnectionConfiguration.Builder configBuilder = XMPPTCPConnectionConfiguration.builder(); 4         configBuilder.setHost(SmackConst.XMPP_HOST); 5         configBuilder.setServiceName(SmackConst.SERVICE_NAME); 6         configBuilder.setUsernameAndPassword(mUsername, mPassword); 7         configBuilder.setSecurityMode(SecurityMode.disabled); 8         mConnection = new XMPPTCPConnection(configBuilder.build()); 9         //Set ConnectionListener here to catch initial connect();10         mConnection.addConnectionListener(this);11         try {12             mConnection.connect();13             mConnection.login();14             if(mConnection.isAuthenticated()){//登录成功15                 MyPingManager.setDefaultPingInterval(10);//Ping every 10 seconds16                 MyPingManager myPingManager = MyPingManager.getInstanceFor(mConnection);17                 //Set PingListener here to catch connect status18                 myPingManager.registerPingFailedListener(SmackConnection.this);19                 setupSendMessageReceiver();20                 //Set ChatListener here to catch receive message and send NEW_MESSAGE broadcast21                 ChatManager.getInstanceFor(mConnection).addChatListener(this);22                 //Set ChatListener here to catch roster change and rebuildRoster23                 //Roster.getInstanceFor(mConnection).addRosterListener(this);24                 sendLoginBroadcast(true);25             }else{26                 mConnection.disconnect();27                 Log.i(TAG, "Authentication failure");28                 sendLoginBroadcast(false);29             }30         } catch (Exception e) {31             e.printStackTrace();32             sendLoginBroadcast(false);33             Intent intent = new Intent(mService, mService.getClass());34             mService.stopService(intent);35         }36 37     }

 自动重连TimerTask,Ping失败后启动,重连成功后关闭

1     private Timer reConnectTimer; 2     private int delay = 10000; 3     //pingFailed时启动重连线程 4     class ReConnectTimer extends TimerTask {   5         @Override   6         public void run() { 7             // 无网络连接时,直接返回 8             if (getNetworkState(mService) == NETWORN_NONE) { 9                 Log.i(TAG, "无网络连接,"+delay/1000+"s后重新连接");10                 reConnectTimer.schedule(new ReConnectTimer(), delay);11                 //reConnectTimer.cancel();12                 return;13             }14             // 连接服务器 15             try {16                 mConnection.connect();17                 if(!mConnection.isAuthenticated()){18                     mConnection.login();19                     reConnectTimer.cancel();20                 }21                 Log.i(TAG, "重连成功");22                 Intent intent = new Intent(SmackConst.ACTION_RECONNECT_SUCCESS);23                 mService.sendBroadcast(intent);24             } catch (Exception e) {25                 Log.i(TAG, "重连失败,"+delay/1000+"s后重新连接");26                 e.printStackTrace();27                 reConnectTimer.schedule(new ReConnectTimer(), delay);28             } 29             30         }  31     }

资源地址:https://github.com/liuhaijin/Smack-Openfire

菜鸟一枚,共同学习~~

 

转载地址:https://www.cnblogs.com/code0001/p/6495851.html 如侵犯您的版权,请留言回复原文章的地址,我们会给您删除此文章,给您带来不便请您谅解!

上一篇:JAVA 入门学习(概述)
下一篇:浅谈Ambarella 的BOSS架构

发表评论

最新留言

逛到本站,mark一下
[***.202.152.39]2024年02月06日 15时53分33秒