使用 Smack 和 Openfire 时遇到 sending/receiving 条消息问题

Question

我在使用 Smack 和 Openfire 时遇到 sending/receiving 消息问题。目前我的设置涉及两台计算机。两台计算机都是运行一个启动程序的 android 模拟器。该程序首先启动登录 activity，然后启动聊天界面 activity。聊天界面目前没有做任何事情； ChatInterface activity 启动后，会自动发送一条消息。

一台电脑（笔记本电脑）充当服务器，台式电脑连接到笔记本电脑服务器（Openfire）。查看笔记本电脑上的 Openfire 用户摘要，两个用户似乎都可用并准备聊天。但是，当它接收消息时，什么也没有出现。消息不会打印在 ListView 等视图对象上，而是打印在日志上。

以下为笔记本电脑代码：

private static final String TAG = "MSG";

private ListView screen;
private EditText textEditor;
private Button sendButton;    

private final String Host = "10.0.2.2";
private final int port = 5222;

private   AbstractXMPPConnection connection;

@Override
protected void onCreate(Bundle savedInstanceState) {
    super.onCreate(savedInstanceState);
    setContentView(R.layout.activity_chat_interface);

    screen = (ListView) findViewById(R.id.ScreenView);
    textEditor = (EditText) findViewById(R.id.TextEditBox);
    sendButton = (Button) findViewById(R.id.SendButton);

    Log.d(TAG, "onCreate Chat Interface");

    final String username = getIntent().getExtras().getString("Username");
    final String password = getIntent().getExtras().getString("Password");

    new AsyncConnect().execute(username, password);

    sendButton.setOnClickListener(new View.OnClickListener(){
        public void onClick(View v) {
        }
    });

    Log.d(TAG, "Success");

}

public class AsyncConnect extends AsyncTask<String, Void, Void>
{
    ProgressDialog pdLoading = new ProgressDialog(ChatInterface.this);

    protected void onPreExecute()
    {
        pdLoading.setMessage("Loading...");
        pdLoading.show();
    }

    protected Void doInBackground(String...params)
    {
        XMPPTCPConnectionConfiguration.Builder configBuilder = XMPPTCPConnectionConfiguration.builder();
        configBuilder.setUsernameAndPassword(params[0], params[1]);
        configBuilder.setServiceName("Openfire");
        configBuilder.setHost(Host);
        configBuilder.setPort(port);
        configBuilder.build();

        configBuilder.setSecurityMode(ConnectionConfiguration.SecurityMode.disabled); // Remove this later could be security threat
        connection = new XMPPTCPConnection(configBuilder.build());

        try {

            connection.connect();
            connection.login();
            Log.d(TAG, "Logged on");
            Log.d(TAG, "Connection: " + connection.getUser());


            if(params[0].equals("test2") && params[1].equals("test2!")) {
                Log.d(TAG, "Entered test2");




                ChatManager chatManager = ChatManager.getInstanceFor(connection);
                Log.d(TAG, "ChatManager");

                Chat newChat = chatManager.createChat("LoveJack@yahoo.com", new ChatMessageListener(){

                    public void processMessage(Chat chat, Message message)
                    {
                        Log.d(TAG, "Received Message From Desktop: " + message.getBody());

                    }

                });

                newChat.sendMessage("This is Jane Doe");
                chatManager.addChatListener(
                        new ChatManagerListener() {

                            @Override
                            public void chatCreated(Chat chat, boolean createdLocally) {

                                Log.d(TAG, "Entered chatCreated");

                                if (!createdLocally) {

                                    Log.d(TAG, "Entered Locally");
                                    chat.addMessageListener(new ChatMessageListener() {
                                        @Override
                                        public void processMessage(Chat chat, Message message) {

                                            try {
                                                Log.d(TAG, "Incoming message...");
                                                Log.d(TAG, "Received message from Desktop: " + message.getBody());
                                                Log.d(TAG, "Message Received");

                                            } catch (Exception e) {
                                                e.printStackTrace();
                                            }


                                        }
                                    });

                                }
                            }
                        });

                Log.d(TAG, "Listened");
            }



        }
        catch(SmackException.ConnectionException e)
        {
            e.printStackTrace();
            Log.d(TAG, "SmackException.ConnectionException");
        }
        catch(XMPPException e)
        {
            e.printStackTrace();
            Log.d(TAG, "XMPPException");
        }
        catch(IOException e)
        {
            e.printStackTrace();
            Log.d(TAG, "IOException");
        }
        catch(SmackException e)
        {
            e.printStackTrace();
            Log.d(TAG, "SmackException");
        }
        return null;
    }

    protected void onPostExecute(Void params)
    {
        pdLoading.dismiss();
    }
}

以下是桌面代码：

private static final String TAG = "MSG";

private ListView screen;
private EditText textEditor;
private Button sendButton;


private final String Host = "192.168.1.152";
private final int port = 5222;

private AbstractXMPPConnection connection;

@Override
protected void onCreate(Bundle savedInstanceState) {
    super.onCreate(savedInstanceState);
    setContentView(R.layout.activity_chat_interface);

    screen = (ListView) findViewById(R.id.ScreenView);
    textEditor = (EditText) findViewById(R.id.TextEditBox);
    sendButton = (Button) findViewById(R.id.SendButton);

    Log.d(TAG, "onCreate Chat Interface");

    final String username = getIntent().getExtras().getString("Username");
    final String password = getIntent().getExtras().getString("Password");

    sendButton.setOnClickListener(new View.OnClickListener(){
        public void onClick(View v){
        }
    });

    new AsyncConnect().execute(username, password);
    Log.d(TAG, "Success");
}

public class AsyncConnect extends AsyncTask<String, Void, Void> {
    ProgressDialog pdLoading = new ProgressDialog(ChatInterface.this);

    protected void onPreExecute() {
        pdLoading.setMessage("Loading...");
        pdLoading.show();
    }

    protected Void doInBackground(String...params) {
        XMPPTCPConnectionConfiguration.Builder configBuilder = XMPPTCPConnectionConfiguration.builder();
        configBuilder.setUsernameAndPassword(params[0], params[1]);
        configBuilder.setServiceName("Openfire");
        configBuilder.setHost(Host);
        configBuilder.setPort(port);
        configBuilder.build();

        configBuilder.setSecurityMode(ConnectionConfiguration.SecurityMode.disabled); // Remove this later could be security threat
        connection = new XMPPTCPConnection(configBuilder.build());

        try {

            connection.connect();
            connection.login();
            Log.d(TAG, "Logged on");
            Log.d(TAG, "Connection: " + connection.getUser());
            if(params[0].equals("test1") && params[1].equals("test1!"))
            {
                Log.d(TAG, "Entered test1");
                ChatManager chatmanager = ChatManager.getInstanceFor(connection);
                Log.d(TAG, "ChatManager");
                Chat newChat = chatmanager.createChat("HumbleBee001@yahoo.com", new ChatMessageListener() {

                    @Override
                    public void processMessage(Chat chat, Message message) {

                       Log.d(TAG, message.getBody());
                    }
                });

                newChat.sendMessage("This is John Doe");
                Log.d(TAG, newChat.getParticipant());
                Log.d(TAG, "Message sent");
            }

        }
        catch(SmackException.ConnectionException e)
        {
            e.printStackTrace();
            Log.d(TAG, "SmackException.ConnectionException");
        }
        catch(XMPPException e)
        {
            e.printStackTrace();
            Log.d(TAG, "XMPPException");
        }
        catch(IOException e)
        {
            e.printStackTrace();
            Log.d(TAG, "IOException");
        }
        catch(SmackException e)
        {
            e.printStackTrace();
            Log.d(TAG, "SmackException");
        }
        return null;
    }

    protected void onPostExecute(Void params)
    {
        pdLoading.dismiss();
    }
}

没有任何 processMessages 方法被调用，因为 logcat 中没有打印任何内容。

我不太确定问题出在哪里。一些 Smack 文档似乎已经过时，并且 API 没有很多有用的资源。有没有人知道可能是什么问题？

Answer 1

我看到很多问题，我建议更好地阅读文档。

我发现了什么：

XMPPTCPConnectionConfiguration.Builder configBuilder = XMPPTCPConnectionConfiguration.builder();
        configBuilder.setUsernameAndPassword(params[0], params[1]);
        configBuilder.setServiceName("Openfire");
        configBuilder.setHost(Host);
        configBuilder.setPort(port);
        configBuilder.build();

ServiceName 这是您的服务器的名称，默认情况下 它是安装 Openfire 的机器名称。如果您没有特定的配置来分配此名称，您将遇到麻烦。检查管理控制面板上的正确名称（Openfire 日志会说明它在哪里收听...类似 yourmachinename:9090）

最好将连接功能与登录功能分开。我建议删除 setUsernameAndPassword 并在 connection.login() 调用中使用 params[0] 和 params[1]。您错过了 Resource（它是一个像“Spark”、“Smack”、“Android", "MyXmppClient") 还有一些默认配置和问题，如果你错过了。

所以我建议改变，例如，这样：

connection.login(param[0],param[1],"MyAndroidApp");

用户名必须小写，Openfire 在他的代码中有一些防御性的 toLowerCase() 但最好避免使用大写字母。所以一定要用小写的JID。

LoveJack@yahoo.com 必须是：lovejack@yahoo.com

但是，这与电子邮件无关：您需要一个 JID，所以它不是 "yahoo.com"，而是 @yourservername（我之前谈到的 ServiceName 的同一期）。

您正在尝试在名为 "yahoo.com" 的 XmppServer 上创建与 "LoveJack" 的聊天，我认为这不是您的目标。

可能你没有正确注册你在服务器上使用的用户，尝试检查（如果在 Yahoo 上谈论它是你想要的，也许你需要阅读一些东西 like this）

使用 Smack 和 Openfire 时遇到 sending/receiving 条消息问题

Having trouble sending/receiving messages with Smack and Openfire

java

android

openfire

smack