QuickBlox 聊天信息监听器

Question

我使用2.1.1版的Android SDK，并希望通知用户应用程序接收到了新的传入消息。

这里有一个问题。我想在用户启动应用程序时通知用户，因此我想在“用户登录”阶段添加监听器，如代码段所示：

        QBAuth.createSession(user, new QBEntityCallbackImpl<QBSession>() {
        @Override
        public void onSuccess(QBSession session, Bundle args) {
            // login to Chat
            chatService.login(user, new QBEntityCallbackImpl() {
                @Override
                public void onSuccess() {
                    HERE I WOULD LIKE A CODE TO START LISTEN FOR ALL INCOMING MESSAGES

根据http://sdk.quickblox.com/android/com/quickblox/chat/listeners/QBMessageListenerImpl.html，监听器需要使用QBChat进行初始化。但我想监听所有消息，而不仅限于特定的聊天。

简而言之，如何实现消息监听器以捕获发送给已登录用户的所有消息？

- NBayaman

---

请在找到解决方案后分享代码。 - Naveen Kumar

Answer 1

在我的启动活动中，我启动了一个监听器来捕获XMPP连接。

    private void XMPPConnectionListener() {
    XMPPConnection.addConnectionCreationListener(new ConnectionCreationListener() {

        @Override
        public void connectionCreated(XMPPConnection connection) {
            GlobalVar.XMPPConn = connection;
            ChatHelper.idleMessageListener(StartActivity.this);

        }
    });

}

然后我使用GlobalVar.XMPPConn来捕获数据包并解析它们：

    public static void idleMessageListener(final Activity activity) {
    PacketListener myListener = new PacketListener() {
        public void processPacket(final Packet packet) {
            final Integer userID = Integer.parseInt(returnIDFromPacket(packet.getFrom()));
            final String body = returnBodyFromPacket(packet.toString());
            if (!GlobalVar.currentOpponent.equals(userID) && !body.isEmpty()) {
                activity.runOnUiThread(new Runnable() {
                    public void run() {
                        QBUsers.getUser(userID, new QBEntityCallbackImpl<QBUser>() {
                            @Override
                            public void onSuccess(final QBUser user, Bundle args) {
                                sendNotification(activity, user, body);
                            }

                            @Override
                            public void onError(List<String> errors) {
                                Log.d(TAG, errors.toString());
                            }
                        });
                    }
                });

            }
        }
    };
    PacketFilter filter = new MessageTypeFilter(Message.Type.chat);

    if (GlobalVar.XMPPConn != null) {
        GlobalVar.XMPPConn.addPacketListener(myListener, filter);
    }
}

所以，逻辑是捕获由QuickBlox触发的连接，然后将数据包监听器附加到该连接上。

- NBayaman

---

你能否更详细地解释一下这段代码？因为我不明白GlobalVar是什么意思，以及如何调用XMPPConnectionListener等，请对代码进行更详细的解释。 - Kamalakannan J