在android中监听XMPP数据包

Question

我发现了这个问题：Android 上的 XMPP 事件，答案解释了我的问题的解决方案我有。但我似乎无法弄清楚如何让 packetListener 工作。我尝试过 packetCollectors 和 packetListeners 但注意到似乎有效。

我不确定应该将数据包监听器放置在哪里。它应该进入服务的 onCreate() 方法，还是 onStartCommand() 中，或者应该放入每隔几秒运行一次的单独方法中？

我的困惑主要在于听众的概念。侦听器是否始终运行，并且一旦收到数据包就会触发？如何确保侦听器可以“看到”传入的数据包事件？

这是我目前尝试让它发挥作用的尝试：

public class XMPPService extends Service{

    private static String TAG = "XMPPService";
    XMPPConnection connection;
    MultiUserChat muc;      

    @Override
    public IBinder onBind(Intent intent) {
        // TODO Auto-generated method stub
        return null;
    }

    @Override
    public void onCreate(){
        super.onCreate();
    }

    public int onStartCommand(Intent intent, int flags, int startId){

        ConnectionConfiguration config = new ConnectionConfiguration("jabber.org", 5222);
        connection = new XMPPConnection(config);

        try 
        {
            connection.connect();
            Log.i(TAG,"connected");
        }
        catch (XMPPException e) 
        {
            Log.e(TAG, "Connection Issue: ", e);
        }

        try 
        {
            connection.login("user", "password");

            muc = new MultiUserChat(connection, "[email protected]");
            muc.join("nick","password");    

            Presence presence = new Presence(Presence.Type.available);
            connection.sendPacket(presence);
            setConnection(connection);
        } 
        catch (XMPPException e) 
        {
            Log.e(TAG, "Connection Issue: ", e);
        }

        makeNotification("started");

        return 1;
    }

    private void makeNotification(String msg){
        Notification notification = new Notification(R.drawable.icon, msg, System.currentTimeMillis());
        PendingIntent contentIntent = PendingIntent.getActivity(this, 0, new Intent(this, MUCTestActivity.class), 2);
        notification.setLatestEventInfo(this, "Title", msg, contentIntent);

        NotificationManager nmgr = (NotificationManager)getSystemService(NOTIFICATION_SERVICE);
        nmgr.notify(123443, notification);
    }


    public void setConnection(XMPPConnection connection) {
        this.connection = connection;
        if (connection != null) {
            // Add a packet listener to get messages sent to us
            PacketFilter filter = new MessageTypeFilter(Message.Type.chat);
            connection.addPacketListener(new PacketListener() {
                public void processPacket(Packet packet) {
                    Message message = (Message) packet;
                    if (message.getBody() != null) {
                        String fromName = StringUtils.parseBareAddress(message.getFrom());
                        Log.i(TAG, "Got text [" + message.getBody() + "] from [" + fromName + "]");
                    }
                    else
                    {
                        Log.i(TAG,"null");
                    }
                }
            }, filter);
        }
    }

}

Answer 1

PacketListener 部分看起来是正确的。它将附加到 smacks 连接（读取器线程），并在与过滤器匹配的数据包到达时由连接调用。你的概念是对的。
返回 START_STICKY（请在此处使用常量而不是值）也应该有助于保持服务并因此保持连接处于活动状态。

您在线看到连接的 JID 了吗？我不确定是否可以在不在 JID 名册中的情况下向 JID 发送消息。尝试在 smack 中启用调试：Connection.DEBUG_ENABLED=true。如果您有 asmack，所有调试消息都将进入 DBMS 日志。另外，模拟器和带断点的 eclipse 都是帮助您分析问题的强大工具。