openfire系列之二 实现消息的接收

要实现消息的接收，需要使用Openfire提供的XMPP协议和Smack API。

首先，需要在代码中创建一个XMPP连接，连接到Openfire服务器。可以使用Smack API提供的XMPPTCPConnection类来创建连接，并传入Openfire服务器的IP地址、端口号和用户名密码等信息。

XMPPTCPConnectionConfiguration.Builder configBuilder = XMPPTCPConnectionConfiguration.builder()
    .setServiceName(serverName)
    .setHost(serverIP)
    .setPort(serverPort)
    .setUsernameAndPassword(username, password)
    .setSecurityMode(ConnectionConfiguration.SecurityMode.disabled)
    .setCompressionEnabled(false);
AbstractXMPPConnection connection = new XMPPTCPConnection(configBuilder.build());

然后，需要注册一个消息监听器，以便在收到消息时进行处理。可以使用Smack API提供的StanzaListener接口来实现监听器。

connection.addAsyncStanzaListener(new StanzaListener() {
    @Override
    public void processStanza(Stanza stanza) throws SmackException.NotConnectedException, InterruptedException {
        if (stanza instanceof Message) {
            Message message = (Message) stanza;
            String fromUser = message.getFrom().toString();
            String messageBody = message.getBody();
            // 处理收到的消息
        }
    }
}, new StanzaFilter() {
    @Override
    public boolean accept(Stanza stanza) {
        return stanza instanceof Message;
    }
});

最后，需要调用连接对象的connect()方法和login()方法，建立连接并登录到Openfire服务器。

connection.connect();
connection.login();

这样，当有消息发送到当前用户时，就会触发消息监听器的processStanza()方法，从而实现消息的接收。