Android IM 即时通讯应用开发实战：基于 Smack 与 Openfire

4.2 注册与登录

根据用户是否已注册，执行不同的逻辑。

import org.jivesoftware.smack.AccountManager;
import org.jivesoftware.smack.packet.Message;
import org.jivesoftware.smackx.disco.ServiceDiscoveryManager;
import org.jivesoftware.smackx.iq.register.RegisterManager;
import org.jivesoftware.smackx.iq.register.provider.Register;
import org.jivesoftware.smackx.xdata.DataForm;
import org.jivesoftware.smackx.xdata.field.Field;

// 初始化连接后执行
XMPPTCPConnection connection = XmppConfig.createConnection("192.168.1.100", "im.example.com");
connection.connect();

// 判断是否需要注册
AccountManager accountManager = AccountManager.getInstance(connection);
accountManager.sensitiveOperationOverInsecureConnectionDefault(true);

try {
    if (!accountManager.supportsRegistration()) {
        // 如果服务器不支持注册，直接尝试登录
        connection.login("user_id", "password");
    } else {
        // 尝试创建账号
        HashMap<String, String> attributes = new HashMap<>();
        attributes.put("name", "此处填账号名称即用户名");
        accountManager.createAccount("user_id", "password", attributes);
        connection.login("user_id", "password");
    }
} catch (XMPPException e) {
    e.printStackTrace();
    // 处理登录失败逻辑
}

5. 消息收发功能

5.1 接收消息监听

使用 ChatManager 监听聊天会话。

import org.jivesoftware.smack.chat.Chat;
import org.jivesoftware.smack.chat.ChatManager;
import org.jivesoftware.smack.chat.ChatMessageListener;
import org.jivesoftware.smack.filter.StanzaTypeFilter;

ChatManager cm = ChatManager.getInstanceFor(connection);
cm.addChatListener((chat, createdLocally) -> {
    if (!createdLocally) { // 仅处理对方发来的消息
        chat.addMessageListener((chatInstance, message) -> {
            String body = message.getBody();
            // 在主线程更新 UI 显示消息
            runOnUiThread(() -> {
                // updateUI(message);
            });
        });
    }
});

5.2 发送消息

创建聊天会话并发送文本消息。

import org.jivesoftware.smack.packet.Message;
import org.jivesoftware.smackx.muc.MUCService; // 如需群聊需引入

ChatManager cm = ChatManager.getInstanceFor(connection);
String targetJid = "[email protected]"; // 目标用户 ID + 域名

Chat chat = cm.createChat(targetJid);
Message message = new Message();
message.setBody("此处填文本消息内容");
chat.sendMessage(message);

6. 高级功能拓展

6.1 离线消息处理

当用户离线时，服务器会保存消息。重新上线后可获取。

import org.jivesoftware.smackx.offline.OfflineMessageManager;

OfflineMessageManager offlineManager = OfflineMessageManager.getInstanceFor(connection);
List<Message> messages = offlineManager.getMessages();
for (Message msg : messages) {
    // 处理历史离线消息
}

6.2 在线状态管理

设置并发布当前用户的 Presence 状态。

import org.jivesoftware.smack.packet.Presence;

Presence userState = new Presence(Presence.Type.available);
userState.setStatus("online");
connection.sendStanza(userState);

6.3 连接状态监听

监控连接生命周期，处理断线重连。

import org.jivesoftware.smack.ConnectionListener;

connection.addConnectionListener(new ConnectionListener() {
    @Override
    public void connected(XMPPConnection connection, boolean resumed) {
        // 连接成功回调
    }

    @Override
    public void authenticated(XMPPConnection connection, boolean resumed) {
        // 认证成功回调
    }

    @Override
    public void connectionClosed() {
        // 连接正常关闭
    }

    @Override
    public void connectionClosedOnError(Exception e) {
        // 异常关闭
    }
});

6.4 自动重连机制

启用 Smack 内置的重连管理器。

import org.jivesoftware.smack.ReconnectionManager;

ReconnectionManager reconnectionManager = ReconnectionManager.getInstanceFor(connection);
reconnectionManager.enableAutomaticReconnection();
reconnectionManager.setReconnectionPolicy(ReconnectionManager.ReconnectionPolicy.FIXED_DELAY);
reconnectionManager.setFixedDelay(5); // 每间隔 5 秒重连一次

7. 注意事项

1. 线程安全: XMPP 通信通常在后台线程进行，更新 UI 时需切换至主线程。
2. 安全性: 生产环境建议启用 SSL/TLS (SecurityMode.require)，避免明文传输密码。
3. 资源释放: 应用退出前务必调用 connection.disconnect() 释放资源。
4. 版本兼容: Smack 4.4.x 系列较为稳定，若使用新版本请查阅官方迁移文档。

8. 总结

本文详细介绍了基于 Smack 和 Openfire 构建 Android 即时通讯应用的核心流程。从服务器部署到客户端连接、消息收发及异常处理，涵盖了 IM 开发的关键环节。开发者可根据实际需求扩展群聊、文件传输等功能。