接收 Smack 的第一条消息时出现问题

Question

我使用下面的代码发送消息。

 // Assume we've created an XMPPConnection name "connection".
ChatManager chatmanager = connection.getChatManager();
Chat newChat = chatmanager.createChat("[email protected]", new MessageListener() {
    public void processMessage(Chat chat, Message message) {
        System.out.println("Received message: " + message);
    }
});

try {
    newChat.sendMessage("Howdy!");
}
catch (XMPPException e) {
    System.out.println("Error Delivering block");
}

下面用于接收异步发送到我的 JabberID 的消息。

// Create a packet filter to listen for new messages from a particular
// user. We use an AndFilter to combine two other filters.
PacketFilter filter = new AndFilter(new PacketTypeFilter(Message.class), 
        new FromContainsFilter("[email protected]"));
// Assume we've created an XMPPConnection name "connection".

// First, register a packet collector using the filter we created.
PacketCollector myCollector = connection.createPacketCollector(filter);
// Normally, you'd do something with the collector, like wait for new packets.

// Next, create a packet listener. We use an anonymous inner class for brevity.
PacketListener myListener = new PacketListener() {
        public void processPacket(Packet packet) {
            // Do something with the incoming packet here.
        }
    };
// Register the listener.
connection.addPacketListener(myListener, filter);

发送消息就OK了。

但是，直到我向该 JabberID 发送消息后，才能从另一个 JabberID 接收消息。

之后我正确地收到它发送的消息。

请注意，我经常需要从不在我的列表中的 jabberID 接收消息，并且我的应用程序通常不是开始聊天的一方。

上面的代码是简单的示例，但我的代码完全相同，只是我没有内联创建 PacketListener 实现。

Answer 1

当我在测试程序期间停止使用同一用户登录的 Jabber 客户端时，我的问题得到了解决。
换句话说，代码是正确的，但 Jabber 客户端捕获发送的消息，并且我的程序没有捕获任何内容。

Answer 2

我已经有一段时间没有使用 smack 了，但我设法根据传入的消息开始聊天。

如果我没记错的话，我有某种“ChatRegistry”，一个简单的 Map，其中键等于聊天伙伴 id。然后我监听传入的消息，提取 jabber id 并查找与该伙伴的活动聊天会话。如果没有活动会话，我会创建一个新的聊天并将新的键/值对添加到注册表中。

Answer 3

只是有点困惑。你说

上面的代码是简单的示例，但我的代码完全相同，只是我没有内联创建 PacketListener 实现。

如果没有 PacketListener 实现，如何接收消息？我认为由于下面的代码，您总是会收到来自您开始的聊天的消息

Chat newChat = chatmanager.createChat("[电子邮件受保护]" , 新的消息监听器() {
公共无效processMessage（聊天聊天，消息消息）{
System.out.println("收到消息：" + message);
}
});

但为了异步等待传入消息，我认为您需要一个 PacketListener。
我可能完全误解了你面临的问题

（这应该是一条评论，但我不知道如何添加一个）

Answer 4

已经有一段时间了，你解决这个问题了吗？为什么要创建 FromContainsFilter？这样，您的侦听器仅处理来自给定用户的数据包，而不是所有数据包。