XMPP群聊java - 在邀请监听器内加入房间的用户的逻辑不起作用答案

【问题标题】：XMPP Group chat java - logic to join users in room inside invitation listener is not workingXMPP群聊java - 在邀请监听器内加入房间的用户的逻辑不起作用
【发布时间】：2016-07-07 13:30:01
【问题描述】：

我正在尝试创建示例 java 应用程序来实现 XMPP 的 MultiUserChat。我如何能够创建用户并在 openfire 中使其在线。谁能建议如何将所有用户加入创建的聊天室？

这是我在 SampleMultiUserChat 类中的示例代码，我邀请所有用户加入该组，但它没有加入。我错过了什么？

SampleMultiUserChat(){
    oConnectionConfiguration = new ConnectionConfiguration("10.10.1.105",5223);
    createChatRoom();
}

/**
 * @param args
 */
public static void main(String[] args) {
    SampleMultiUserChat oSampleMultiUserChat = new SampleMultiUserChat();

    for(int i = 2; i < 4; i++){
        oSampleMultiUserChat.openXMPPConnection("user"+i);
        oSampleMultiUserChat.createAcceptInvitationListener("user"+i);
        oSampleMultiUserChat.inviteToJoinRoom("user"+i);
    }

    Thread mainThread = Thread.currentThread();
    while(true){
        try {
            mainThread.sleep(500);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

private void openXMPPConnection(String user){
    XMPPConnection oXmppConnection = new XMPPConnection(oConnectionConfiguration);
    try {
        oXmppConnection.connect();
        oXmppConnection.login(user, "60474c9c10d7142b7508ce7a50acf414");
        userConnection.put(user, oXmppConnection);
    } catch (XMPPException e) {
        System.out.println("Exception occured in login in user : "+user);
    }
}

private void createChatRoom(){
    XMPPConnection oXmppConnection = new XMPPConnection(oConnectionConfiguration);
    try {
        oXmppConnection.connect();
        oXmppConnection.login("user1", "60474c9c10d7142b7508ce7a50acf414");

        myChattingRoom = new MultiUserChat(oXmppConnection, "mychattingroom@conference.10.10.1.105");

        myChattingRoom.create("roomNickName");
        myChattingRoom.sendConfigurationForm(new Form(Form.TYPE_SUBMIT));
    } catch (XMPPException e) {
        e.printStackTrace();
    }
}

private void inviteToJoinRoom(String user){
    myChattingRoom.invite(user+"@10.10.1.105", "Please join my chatting room");
    System.out.println("sent invitation by "+user);
}

private void sendMessage(String msg){
    try {
        myChattingRoom.sendMessage(msg);
    } catch (XMPPException e) {
        System.out.println("Exception occured while sending msg to chat room"+e);
    }
}

private void createAcceptInvitationListener(String user){
    MultiUserChat.addInvitationListener(userConnection.get(user), new InvitationListener() {

        public void invitationReceived(Connection connection, String room, String inviter,
                String reason, String password, Message msg) {
            try {
                myChattingRoom.join(connection.getUser().substring(0, connection.getUser().indexOf("@")));
            } catch (XMPPException e) {
                e.printStackTrace();
            }
        }
    });
}

提前致谢。

【问题讨论】：

Adding participants to XMPP chat rooms的可能重复
我的问题是，即使我邀请用户加入群组，用户也不会加入群组。这是我的问题。任何的想法？ @legoscia
是的，正如this answer 中所述，没有办法强制用户加入群组：用户收到邀请后，必须决定如何/是否采取行动。跨度>
你控制客户吗？如果是，我可以告诉你一个解决方案，否则 legoscia 所说的......
控制客户端是什么意思？在收到邀请的方法中，我加入了聊天室“myChattingRoom”中的用户，但它没有加入。为什么？ @MrPK

标签： java xmpp openfire smack

【解决方案1】：

我通过创建 MultiUserChat 的新实例解决了上述问题。

这是我编辑的方法'createAcceptInvitationListener'

private void createAcceptInvitationListener(String user){
    System.out.println("inside create accept invitation listener");
    final XMPPConnection oXmppConnection = userConnection.get(user);

    MultiUserChat.addInvitationListener(oXmppConnection, new InvitationListener() {

        public void invitationReceived(Connection connection, String room, String inviter,
                String reason, String password, Message msg) {
            System.out.println("inside invitation received method");
            try {
                System.out.println(connection.getUser().substring(0, connection.getUser().indexOf("@")));
                MultiUserChat myChattingRoom = new MultiUserChat(oXmppConnection, "mychattingroom@conference.10.10.1.105");

                myChattingRoom.join(connection.getUser().substring(0, connection.getUser().indexOf("@")));

            } catch (Exception e) {
                e.printStackTrace();
                System.out.println("Exception occured while joining the chat room : "+e);
            }
        }
    });
}

private void reservedRoomsCreation(MultiUserChat myChattingRoom) throws XMPPException{
    Form form = myChattingRoom.getConfigurationForm();
    Form submitForm = form.createAnswerForm();
    for(Iterator fields = form.getFields(); fields.hasNext();){
        FormField formFields = (FormField) fields.next();
        if (!FormField.TYPE_HIDDEN.equals(formFields.getType()) && formFields.getVariable() != null) {
            submitForm.setDefaultAnswer(formFields.getVariable());
        }
    }
    submitForm.setAnswer("muc#roomconfig_persistentroom", true);
    myChattingRoom.sendConfigurationForm(submitForm);
}

【讨论】：