java+smack+openfire即时通讯Im（一）

朱雀 2020-10-18 05:40 963阅读 0赞

# 简介 #

使用java+smack+openfire完成简单的即时通讯，包括登录、注册、添加好友、获取好友列表、获取离线信息等。

openfire这个东西确实很老了，所以文档说明也不是很多，而且是英文的，英文不好的可以使用浏览器的翻译将就一下把，还是勉强能看懂的。  
用到的jar包的话就比较肯定得，我在这里也遇到了好多坑，一开始是在官网下的包，然后导入项目以后不是少这个就是少那个，就算包是对的，里面的方法也不全。所以后面都是一边写，然后看具体少那一个包，这样一个一个导进去。 
![smack的相关jar包][smack_jar]

# 登录、注册 #

包全部导完以后就可以开始进行开发了

## 初始化链接 ##

/*** * * 方法名称：initOpenfireConnect * 概要说明：初始化openfire连接 * * @param * @return org.jivesoftware.smack.tcp.XMPPTCPConnection * * @author ZhangYH * @date 2020/4/1 13:59 */
 public static XMPPTCPConnection initOpenfireConnect() { 
 XMPPTCPConnection connection = null;
 try { 
 XMPPTCPConnectionConfiguration.Builder configBuilder = XMPPTCPConnectionConfiguration.builder();
 //设置服务器名称
 configBuilder.setServiceName(OPENFIRE_SERVICE_NAME);
 //设置服务器地址（ip）
 configBuilder.setHost(OPENFIRE_HOST);
 //设置服务器端口
 configBuilder.setPort(OPENFIRE_PORT);
 configBuilder.setSecurityMode(XMPPTCPConnectionConfiguration.SecurityMode.disabled);
 //设置登录状态为离线（这个很重要，不设置的话，接收不到离线消息）
 configBuilder.setSendPresence(false);
 connection = new XMPPTCPConnection(configBuilder.build());
 // 连接服务器
 connection.connect();
 }catch (Exception e){ 
 e.printStackTrace();
 }
 return connection;
 }

把openfire服务器相关的信息设置进去，然后调用connect()方法就可以完成连接初始化了。

## 注册 ##

/*** * * 方法名称：openfireRegister * 概要说明：用户注册 * * @param userName * @param password * @return void * * @author ZhangYH * @date 2020/4/1 14:06 */
 public static void openfireRegister(String userName, String password){ 
 try { 
 XMPPTCPConnection connection = initOpenfireConnect();
 //创建用户
 AccountManager manager = AccountManager.getInstance(connection);
 manager.createAccount(userName, password);
 }catch (Exception e){ 
 e.printStackTrace();
 }
 }

## 登录 ##

登录的话，初始化连接完了以后直接调用login()方法即可。

XMPPTCPConnection  connection = initOpenfireConnect();
     connection.login(userName,password);

以上就是连接openfire完成登录、注册的全部过程了。其实最麻烦的就是导包的那个地方，因为现在网上版本很多很多，随便下载一个一下还不能用，没办法，只能一个一个导了。

完整代码：

package com.yonghon.smack.util;
 
 import java.io.BufferedReader;
 import java.io.InputStreamReader;
 import java.util.*;
 import java.net.*;
 import java.io.*;
 
 import org.apache.commons.lang3.StringUtils;
 import org.jivesoftware.smack.chat.Chat;
 import org.jivesoftware.smack.chat.ChatManager;
 import org.jivesoftware.smack.packet.Presence;
 import org.jivesoftware.smack.roster.Roster;
 import org.jivesoftware.smack.roster.RosterEntry;
 import org.jivesoftware.smack.tcp.XMPPTCPConnection;
 import org.jivesoftware.smack.tcp.XMPPTCPConnectionConfiguration;
 import org.jivesoftware.smackx.iqregister.AccountManager;
 import org.jivesoftware.smackx.offline.OfflineMessageHeader;
 import org.jivesoftware.smackx.offline.OfflineMessageManager;
 import org.jivesoftware.smack.packet.Message;
 import org.jivesoftware.smackx.pubsub.LeafNode;
 import org.jivesoftware.smackx.pubsub.PubSubManager;
 import org.jivesoftware.smackx.pubsub.Subscription;
 import org.jivesoftware.smackx.pubsub.Item;
 import org.jxmpp.jid.EntityBareJid;
 import org.jxmpp.jid.impl.JidCreate;
 
 public class OpenfireUtils { 
 //服务器名称
 private static String OPENFIRE_SERVICE_NAME = "YongHon";
 //地址
 private static String OPENFIRE_HOST = "127.0.0.1";
 //端口
 private static int OPENFIRE_PORT = 端口;
 //获取好友在线状态的URL地址
 private static String OPENFIRE_PRESENCE_URL = "http://Yonghon:9090/plugins/presence/status";
 
 /*** * * 方法名称：initOpenfireConnect * 概要说明：初始化openfire连接 * * @param * @return org.jivesoftware.smack.tcp.XMPPTCPConnection * * @author ZhangYH * @date 2020/4/1 13:59 */
 public static XMPPTCPConnection initOpenfireConnect() { 
 XMPPTCPConnection connection = null;
 try { 
 XMPPTCPConnectionConfiguration.Builder configBuilder = XMPPTCPConnectionConfiguration.builder();
 //设置服务器名称
 configBuilder.setServiceName(OPENFIRE_SERVICE_NAME);
 //设置服务器地址（ip）
 configBuilder.setHost(OPENFIRE_HOST);
 //设置服务器端口
 configBuilder.setPort(OPENFIRE_PORT);
 configBuilder.setSecurityMode(XMPPTCPConnectionConfiguration.SecurityMode.disabled);
 //设置登录状态为离线（这个很重要，不设置的话，接收不到离线消息）
 configBuilder.setSendPresence(false);
 connection = new XMPPTCPConnection(configBuilder.build());
 // 连接服务器
 connection.connect();
 //登录
 			//connection.login(“userName”,“password”);
 }catch (Exception e){ 
 e.printStackTrace();
 }
 return connection;
 }
 
 /*** * * 方法名称：closeConnection * 概要说明：关闭连接 * * @param connection * @return void * * @author ZhangYH * @date 2020/4/1 14:03 */
 public static void closeConnection(XMPPTCPConnection connection) { 
 connection.disconnect();
 }
 
 /*** * * 方法名称：openfireRegister * 概要说明：用户注册 * * @param userName * @param password * @return void * * @author ZhangYH * @date 2020/4/1 14:06 */
 public static void openfireRegister(String userName, String password){ 
 try { 
 XMPPTCPConnection connection = initOpenfireConnect();
 //创建用户
 AccountManager manager = AccountManager.getInstance(connection);
 manager.createAccount(userName, password);
 }catch (Exception e){ 
 e.printStackTrace();
 }
 }
 }

[smack_jar]: /images/1602999597654.png