Android中基于XMPP协议实现IM聊天程序与多人聊天室

简单的im聊天程序
由于项目需要做一个基于xmpp协议的android通讯软件。故开始研究xmpp。
xmpp协议采用的是客户端-服务器架构，所有从一个客户端发到另一个客户端的消息和数据都必须经过xmpp服务器转发，而且支持服务器间dns的路由，也就是说可以构建服务器集群，使不同的

服务器下的客户端也可以通信，xmpp的前身是一个开源组织制定的网络通信协议——jabber，xmpp的核心是在网络上分片段发送xml流的协议，这个协议是xmpp的即时通讯指令的传递手段。
      为了防止服务器间发送的数据被篡改或偷听，xmpp服务器通信引入了tls机制，使用tls机制能实现数据的加密，从而保证了在数据传输过程种数据的安全。
      一个xmpp实体的地址称为jabber identifier或jid，作用类似于ip地址。一个合法的jid包括节点名,域名资源名，其格式为：jid=[node'@']domain['/'resource]

xmpp协议的命名空间：

• jabber:iq:private   -- 私有数据存储，用于本地用户私人设置信息，比如用户备注等。
• jabber:iq:conference  -- 一般会议，用于多个用户之间的信息共享
• jabber:x:encrypted -- 加密的消息，用于发送加密消息
• jabber:x:expire  -- 消息终止
• jabber:iq:time  -- 客户端时间
• jabber:iq:auth  -- 简单用户认证，一般用于服务器之间或者服务器和客户端之间的认证
• jabber:x:roster  -- 内部花名册
• jabber:x:signed  -- 标记的在线状态
• jabber:iq:search -- 用户数据库查询，用于向服务器发送查询请求
• jabber:iq:register -- 注册请求，用于用户注册相关信息
• jabber:x:iq:roster -- 花名册管理
• jabber:x:conference -- 会议邀请，用于向参加会议用户发送开会通知
• jabber:x:event  -- 消息事件
• vcard-temp  -- 临时的vcard,用于设置用户的头像以及昵称等

 在网上找了下，有开源的项目beem，开源的用于android的xmpp框架asmack，asmack是smack的android版本。现在开始学习smack

。xmpp就是神马东西，就不废话了。首先在网上下一个openfire和spack，不知道这两个是什么东西，就直接google吧。安装openfire需要mysql的支持，当然，oracle，sqlserver肯定是可以的。还是先上图吧：

openfire + spark + myxmppp

import java.io.inputstreamreader;
import java.util.collection;

import org.jivesoftware.smack.chat;
import org.jivesoftware.smack.chatmanager;
import org.jivesoftware.smack.chatmanagerlistener;
import org.jivesoftware.smack.connectionconfiguration;
import org.jivesoftware.smack.messagelistener;
import org.jivesoftware.smack.privacylistmanager;
import org.jivesoftware.smack.roster;
import org.jivesoftware.smack.rosterentry;
import org.jivesoftware.smack.rostergroup;
import org.jivesoftware.smack.rosterlistener;
import org.jivesoftware.smack.xmppconnection;
import org.jivesoftware.smack.packet.message;
import org.jivesoftware.smack.packet.presence;

public class testsmack {
  public static void main(string[] args) {xmppconnection.debug_enabled = true;
    //我的电脑ip:10.16.25.90
    final connectionconfiguration connectionconfig = new connectionconfiguration("10.16.25.91", 5222, "");
    connectionconfig.setsaslauthenticationenabled(false);
        try {

          xmppconnection connection = new xmppconnection(connectionconfig);
          connection.connect();//连接
          connection.login("test", "test");//登陆
          system.out.println(connection.getuser());
          chatmanager chatmanager = connection.getchatmanager();

          //新建一个会话
          chat newchat = chatmanager.createchat("test3@pc2010102716", new messagelistener() {
            public void processmessage(chat chat, message message) {
              system.out.println("received from 【" + message.getfrom() + "】 message: " + message.getbody());
            }
          });

          // 监听被动接收消息，或广播消息监听器
          chatmanager.addchatlistener(new chatmanagerlistener() {
            @override
            public void chatcreated(chat chat, boolean createdlocally) {
              chat.addmessagelistener(new messagelistener() {
                @override
                public void processmessage(chat chat, message message) {
                  system.out.println("received from 【" + message.getfrom() + "】 message: " + message.getbody());
                }

              });
            }
          });
          //发送消息
          newchat.sendmessage("我是菜鸟");

          //获取花名册
          roster roster = connection.getroster();
          collection<rosterentry> entries = roster.getentries();
          for(rosterentry entry : entries) {
            system.out.print(entry.getname() + " - " + entry.getuser() + " - " + entry.gettype() + " - " + entry.getgroups().size());
            presence presence = roster.getpresence(entry.getuser());
            system.out.println(" - " + presence.getstatus() +" - "+ presence.getfrom());
          }

          //添加花名册监听器，监听好友状态的改变。
          roster.addrosterlistener(new rosterlistener() {

            @override
            public void entriesadded(collection<string> addresses) {
              system.out.println("entriesadded");
            }

            @override
            public void entriesupdated(collection<string> addresses) {
              system.out.println("entriesupdated");
            }

            @override
            public void entriesdeleted(collection<string> addresses) {
              system.out.println("entriesdeleted");
            }

            @override
            public void presencechanged(presence presence) {
              system.out.println("presencechanged - >" + presence.getstatus());
            }

          });

          //创建组
//         /rostergroup group = roster.creategroup("大学");
//         for(rosterentry entry : entries) {
//           group.addentry(entry);
//         }
          for(rostergroup g : roster.getgroups()) {
            for(rosterentry entry : g.getentries()) {
              system.out.println("group " +g.getname() +" >> " + entry.getname() + " - " + entry.getuser() + " - " + entry.gettype() + " - " + entry.getgroups().size());
            }
          }

          //发送消息
          bufferedreader cmdin = new bufferedreader(new inputstreamreader(system.in));
          while(true) {
           try {
             string cmd = cmdin.readline();
             if("!q".equalsignorecase(cmd)) {
               break;
             }
             newchat.sendmessage(cmd);
           }catch(exception ex) {
           }
          }
          connection.disconnect();
          system.exit(0);
        } catch (exception e) {
          e.printstacktrace();
        }
  }
}

以上代码如果在一般的java project上运行需要加入smack.jar 和klmx2.jar,如果是android project，基本代码不需改变只需将其放入oncreate(...)方法下即可，需要加入asmack.jar包.

1、connectionconfiguration
 作为用于与xmpp服务建立连接的配置。它能配置；连接是否使用tls，sasl加密。
 包含内嵌类：connectionconfiguration.securitymode

2、xmppconnection.
 xmppconnection这个类用来连接xmpp服务.
 可以使用connect()方法建立与服务器的连接。disconnect()方法断开与服务器的连接.
 在创建连接前可以使用xmppconnection.debug_enabled = true; 使开发过程中可以弹出一个gui窗口，用于显示我们的连接与发送packet的信息。

3、chatmanager
 用于监控当前所有chat。可以使用createchat(string userjid, messagelistener listener)创建一个聊天。
 
4、chat
 chat用于监控两个用户间的一系列message。使用addmessagelistener(messagelistener listener)当有任何消息到达时将会触发listener的processmessage(chat chat, message message)
方法.
 我们可以使用sendmessage()发送消息,这个方法有两个重载方法，一种类类型的参数时string类型，另一种则是传入message对象(后面介绍)。
 那么有这样一种情况，当别人主动跟我们建立连接发送消息，或者系统发送消息时我们怎么才能接收消息呢？
    我现在是这样操作的：

chatmanager.addchatlistener(new chatmanagerlistener() {
@override
public void chatcreated(chat chat, boolean createdlocally) {
 chat.addmessagelistener(new messagelistener() {
 @override
 public void processmessage(chat chat, message message) {
  system.out.println("received message: " + message.getbody());
 }

 });
}
});

 
5、message

•  message用于表示一个消息包(可以用调试工具看到发送包和接收包的具体内容)。它有以下多种类型。
•   message.type.normal -- （默认）文本消息（比如邮件）
•   message.type.chat -- 典型的短消息，如qq聊天的一行一行显示的消息
•   message.type.group_chat -- 群聊消息
•   message.type.headline -- 滚动显示的消息
•   message.type.error -- 错误的消息
•  message有两个内部类：
•   message.body -- 表示消息体
•   message.type -- 表示消息类型

6、roster
 表示存储了很多rosterentry的一个花名册.为了易于管理，花名册的项被分贝到了各个group中.
 当建立与xmpp服务的连接后可以使用connection.getroster()获取roster对象。
 别的用户可以使用一个订阅请求(相当于qq加好友)尝试订阅目的用户。可以使用枚举类型roster.subscriptionmode的值处理这些请求：
 accept_all: 接收所有订阅请求
 reject_all：拒绝所有订阅请求
 manual：  手工处理订阅请求
 
 创建组：rostergroup group = roster.creategroup("大学");
 向组中添加rosterentry对象: group.addentry(entry);
 
7、rosterentry
 表示roster（花名册）中的每条记录.它包含了用户的jid，用户名，或用户分配的昵称.
 
8、rostergroup
 表示rosterentry的组。可以使用addentry(rosterentry entry)添加。contains(string user) 判断某用户是否在组中.当然removeentry(rosterentry entry)就是从组中移除了。getentries()

获取所有rosterentry.
 
9、presence
 表示xmpp状态的packet。每个presence packet都有一个状态。用枚举类型presence.type的值表示：
 available -- （默认）用户空闲状态
 unavailable -- 用户没空看消息
 subscribe -- 请求订阅别人，即请求加对方为好友
 subscribed -- 统一被别人订阅，也就是确认被对方加为好友
 unsubscribe -- 他取消订阅别人，请求删除某好友
 unsubscribed -- 拒绝被别人订阅，即拒绝对放的添加请求
 error -- 当前状态packet有错误
 内嵌两个枚举类型:presence.mode和presence.type.
 可以使用setstatus自定义用户当前的状态（像qq一样的)

multiuserchat聊天室

import java.io.bufferedreader;
import java.io.inputstreamreader;
import java.util.arraylist;
import java.util.collection;
import java.util.iterator;
import java.util.list;

import org.jivesoftware.smack.chat;
import org.jivesoftware.smack.connectionconfiguration;
import org.jivesoftware.smack.messagelistener;
import org.jivesoftware.smack.packetlistener;
import org.jivesoftware.smack.smackconfiguration;
import org.jivesoftware.smack.xmppconnection;
import org.jivesoftware.smack.xmppexception;
import org.jivesoftware.smack.packet.message;
import org.jivesoftware.smack.packet.packet;
import org.jivesoftware.smack.provider.providermanager;
import org.jivesoftware.smackx.form;
import org.jivesoftware.smackx.formfield;
import org.jivesoftware.smackx.servicediscoverymanager;
import org.jivesoftware.smackx.muc.defaultparticipantstatuslistener;
import org.jivesoftware.smackx.muc.defaultuserstatuslistener;
import org.jivesoftware.smackx.muc.discussionhistory;
import org.jivesoftware.smackx.muc.hostedroom;
import org.jivesoftware.smackx.muc.invitationlistener;
import org.jivesoftware.smackx.muc.invitationrejectionlistener;
import org.jivesoftware.smackx.muc.multiuserchat;
import org.jivesoftware.smackx.muc.roominfo;
import org.jivesoftware.smackx.muc.subjectupdatedlistener;
import org.jivesoftware.smackx.packet.chatstateextension;
import org.jivesoftware.smackx.packet.discoverinfo;
import org.jivesoftware.smackx.packet.discoveritems;
import org.jivesoftware.smackx.packet.offlinemessageinfo;
import org.jivesoftware.smackx.packet.offlinemessagerequest;
import org.jivesoftware.smackx.provider.adhoccommanddataprovider;
import org.jivesoftware.smackx.provider.bytestreamsprovider;
import org.jivesoftware.smackx.provider.dataformprovider;
import org.jivesoftware.smackx.provider.discoverinfoprovider;
import org.jivesoftware.smackx.provider.discoveritemsprovider;
import org.jivesoftware.smackx.provider.ibbproviders;
import org.jivesoftware.smackx.provider.mucadminprovider;
import org.jivesoftware.smackx.provider.mucownerprovider;
import org.jivesoftware.smackx.provider.mucuserprovider;
import org.jivesoftware.smackx.provider.streaminitiationprovider;
import org.jivesoftware.smackx.provider.vcardprovider;
import org.jivesoftware.smackx.provider.xhtmlextensionprovider;

public class testsmack2 {
  public static void main(string[] args) {xmppconnection.debug_enabled = true;
    final connectionconfiguration connectionconfig = new connectionconfiguration("pc2010102716", 5222, "");
    connectionconfig.setsaslauthenticationenabled(false);
    providermanager pm = providermanager.getinstance();
    configure(pm);
    try {
      xmppconnection connection = new xmppconnection(connectionconfig);
      connection.connect();//连接
      initfeatures(connection);
      connection.login("test", "test");//登陆
      //聊天室
      //multiuserchat multiuserchat = new multiuserchat(connection, new invitationlistener() {});
       //查找服务
      system.out.println(connection.getservicename());
      list<string> col = getconferenceservices(connection.getservicename(), connection);
      for (object acol : col) {
        string service = (string) acol;
         //查询服务器上的聊天室
        collection<hostedroom> rooms = multiuserchat.gethostedrooms(connection, service);
        for(hostedroom room : rooms) {
          //查看room消息
          system.out.println(room.getname() + " - " +room.getjid());
          roominfo roominfo = multiuserchat.getroominfo(connection, room.getjid());
          if(roominfo != null) {
            system.out.println(roominfo.getoccupantscount() + " : " + roominfo.getsubject());
          }
         }
      }

      /*---创建默认配置的聊天室 ---
      先看看官方的文档：
      creates a new multi user chat with the specified connection and room name. note: no
         * information is sent to or received from the server until you attempt to
         * {@link #join(string) join} the chat room. on some server implementations,
         * the room will not be created until the first person joins it
         * 最重要一句:直到用户调用join方法的时候聊天室才会被创建
         */
      multiuserchat muc = new multiuserchat(connection, "[e-mail]2010102716");
       muc.create("user1");
      muc.sendconfigurationform(new form(form.type_submit));

      //----创建手动配置聊天室----
      muc = new multiuserchat(connection, "[e-mail]2010102716");

      //销毁聊天室
      //muc.destroy("test", null);
      muc.create("user2");
      //获取聊天室的配置表单
      form form = muc.getconfigurationform();
      //根据原始表单创建一个要提交的新表单
      form submitform = form.createanswerform();
      //向提交的表单添加默认答复
      for(iterator<formfield> fields = form.getfields(); fields.hasnext();) {
        formfield field = (formfield) fields.next();
        if(!formfield.type_hidden.equals(field.gettype()) && field.getvariable() != null) {
          submitform.setdefaultanswer(field.getvariable());
        }
      }
      //重新设置聊天室名称
      submitform.setanswer("muc#roomconfig_roomname", "reserved4 room");
      //设置聊天室的新拥有者
      list<string> owners = new arraylist<string>();
      owners.add("test@pc2010102716");
      submitform.setanswer("muc#roomconfig_roomowners", owners);
      //设置密码
      submitform.setanswer("muc#roomconfig_passwordprotectedroom", true);
      submitform.setanswer("muc#roomconfig_roomsecret", "reserved");
      //设置描述
      submitform.setanswer("muc#roomconfig_roomdesc", "新创建的reserved聊天室");
      //设置聊天室是持久聊天室，即将要被保存下来
      //submitform.setanswer("muc#roomconfig_persistentroom", true);
      //发送已完成的表单到服务器配置聊天室
      muc.sendconfigurationform(submitform);

      //加入聊天室(使用昵称喝醉的毛毛虫 ,使用密码ddd)
      muc = new multiuserchat(connection, "[e-mail]2010102716");
      muc.join("喝醉的毛毛虫", "ddd");

      //监听消息
      muc.addmessagelistener(new packetlistener() {
        @override
        public void processpacket(packet packet) {
          message message = (message) packet;
          system.out.println(message.getfrom() + " : " + message.getbody());;
        }
      });

      //muc = new multiuserchat(connection, "[e-mail]2010102716");
      //muc.join("喝醉的毛毛虫", "ddd");

      //加入聊天室(使用昵称喝醉的毛毛虫 ,使用密码ddd)并且获取聊天室里最后5条信息，
      //注：addmessagelistener监听器必须在此join方法之前，否则无法监听到需要的5条消息
      muc = new multiuserchat(connection, "[e-mail]2010102716");
      discussionhistory history = new discussionhistory();
      history.setmaxstanzas(5);
      muc.join("喝醉的毛毛虫", "ddd", history, smackconfiguration.getpacketreplytimeout());

      //监听拒绝加入聊天室的用户
      muc.addinvitationrejectionlistener(new invitationrejectionlistener() {
        @override
        public void invitationdeclined(string invitee, string reason) {
        system.out.println(invitee + " reject invitation, reason is " + reason);
        }
      });
      //邀请用户加入聊天室
      muc.invite("test3@pc2010102716", "大家来谈谈人生");
      //监听邀请加入聊天室请求
      multiuserchat.addinvitationlistener(connection, new invitationlistener() {
        @override
        public void invitationreceived(xmppconnection conn, string room, string inviter, string reason, string password, message message) {
        //例：直接拒绝邀请
        multiuserchat.decline(conn, room, inviter, "你丫很闲啊！");
        }
      });


      //根据roomjid获取聊天室信息
      roominfo roominfo = multiuserchat.getroominfo(connection, "[e-mail]2010102716");
       system.out.println(roominfo.getroom() + "-" + roominfo.getsubject() + "-" + roominfo.getoccupantscount());

      //判断用户是否支持multi-user聊天协议
      //注：需要加上资源标识符
      boolean supports = multiuserchat.isserviceenabled(connection, "test3@pc2010102716/spark");
       //获取某用户所加入的聊天室
      if(supports) {
        iterator<string> joinedrooms = multiuserchat.getjoinedrooms(connection, "test3@pc2010102716/spark");
        while(joinedrooms.hasnext()) {
          system.out.println("test3 has joined room " + joinedrooms.next());
        }
      }

      //与聊天室用户私聊
      chat chat = muc.createprivatechat("[e-mail]2010102716/飞鸟", new messagelistener() {
         @override
         public void processmessage(chat chat, message message) {
           system.out.println("private chat: received message from " + message.getfrom() + "-" + message.getbody());
         }
      });
      chat.sendmessage("今天不用加班吧？");

      //改变聊天室主题
      muc.addsubjectupdatedlistener(new subjectupdatedlistener() {
        @override
        public void subjectupdated(string subject, string from) {
          system.out.println("subject updated to " + subject +" by " + from);
        }
      });
      //muc.changesubject("new subject11");

      /*一个成员可能有四种角色:
      1：主持者(moderator) （权限最大的角色，管理其他成员在聊天室中的角色
      2：参与者(participant
      3：游客 (visitor) (不能向所有成员发送消息)
      4：无（没有角色）（none）
      */

      /*聊天室用户可以有5种从属关系
       * 1、所有者 owner
       * 2、管理员 admin
       * 3、成员 member
       * 4、被驱逐者 outcast
       * 5、无（不存在从属关系) none
       */

      //配置聊天室为moderated聊天室
      form = muc.getconfigurationform();
      form answerform = form.createanswerform();
      answerform.setanswer("muc#roomconfig_moderatedroom", "1");
      muc.sendconfigurationform(answerform);

      //监听自己的状态变更和事件
      muc.adduserstatuslistener(new defaultuserstatuslistener() {
        @override
        public void voicerevoked() {
          super.voicerevoked();
          system.out.println("你被禁言了!");
        }

        @override
        public void voicegranted() {
          super.voicegranted();
          system.out.println("你被批准发言了!");
        }

        @override
        public void membershipgranted() {
          super.membershipgranted();
          system.out.println("你被赋予了member权限");
        }

        @override
        public void membershiprevoked() {
          super.membershiprevoked();
          system.out.println("你被解除了member权限");
        }

        @override
        public void admingranted() {
          super.admingranted();
          system.out.println("你被赋予了管理员权限");
        }

        @override
        public void adminrevoked() {
        super.adminrevoked();
        system.out.println("你被解除了管理员权限");
        }
      //......
      });
      //房主(owner)批准test3发言权
      muc.grantvoice("test3@pc2010102716");

      //监听他人状态变更
      muc.addparticipantstatuslistener(new defaultparticipantstatuslistener() {

        @override
        public void voicegranted(string participant) {
          super.voicegranted(participant);
        system.out.println(participant + "被批准发言了!");
        }

        @override
        public void voicerevoked(string participant) {
          super.voicerevoked(participant);
          system.out.println(participant + "被禁言了!");
        }

        @override
        public void membershiprevoked(string participant) {
          super.membershiprevoked(participant);
        }

        @override
        public void admingranted(string participant) {
          super.admingranted(participant);
        }

        @override
        public void adminrevoked(string participant) {
          super.adminrevoked(participant);
        }

      });

      //房主(owner)批准test3管理员特权
      muc.grantadmin("test3@pc2010102716");


      //发送消息
      bufferedreader cmdin = new bufferedreader(new inputstreamreader(system.in));
      while(true) {
        try {
           string cmd = cmdin.readline();
           if("!q".equalsignorecase(cmd)) {
             break;
           }
         }catch(exception ex) {
         }
      }
      connection.disconnect();
      system.exit(0);
    } catch (exception e) {
      e.printstacktrace();
    }
  }

  public static list<string> getconferenceservices(string server, xmppconnection connection) throws exception {
   list<string> answer = new arraylist<string>();
      servicediscoverymanager discomanager = servicediscoverymanager.getinstancefor(connection);
       discoveritems items = discomanager.discoveritems(server);
      for (iterator<discoveritems.item> it = items.getitems(); it.hasnext();) {
         discoveritems.item item = (discoveritems.item)it.next();
        if (item.getentityid().startswith("conference") || item.getentityid().startswith("private")) {
           answer.add(item.getentityid());
        }
        else {
          try {
            discoverinfo info = discomanager.discoverinfo(item.getentityid());
             if (info.containsfeature("http://jabber.org/protocol/muc")) {
               answer.add(item.getentityid());
            }
          }
          catch (xmppexception e) {
          }
        }
      }
      return answer;
    }


  private static void configure(providermanager pm) {
    // service discovery # items
    pm.addiqprovider("query", "http://jabber.org/protocol/disco#items", new discoveritemsprovider());
     // service discovery # info
    pm.addiqprovider("query", "http://jabber.org/protocol/disco#info", new discoverinfoprovider());

    // service discovery # items
    pm.addiqprovider("query", "http://jabber.org/protocol/disco#items", new discoveritemsprovider());
     // service discovery # info
    pm.addiqprovider("query", "http://jabber.org/protocol/disco#info", new discoverinfoprovider());

    //offline message requests
    pm.addiqprovider("offline","http://jabber.org/protocol/offline", new offlinemessagerequest.provider());
        //offline message indicator
        pm.addextensionprovider("offline","http://jabber.org/protocol/offline", new offlinemessageinfo.provider());

    //vcard
    pm.addiqprovider("vcard","vcard-temp", new vcardprovider());

    //filetransfer
    pm.addiqprovider("si","http://jabber.org/protocol/si", new streaminitiationprovider());
        pm.addiqprovider("query","http://jabber.org/protocol/bytestreams", new bytestreamsprovider());
        pm.addiqprovider("open","http://jabber.org/protocol/ibb", new ibbproviders.open());
        pm.addiqprovider("close","http://jabber.org/protocol/ibb", new ibbproviders.close());
        pm.addextensionprovider("data","http://jabber.org/protocol/ibb", new ibbproviders.data());
        //data forms
      pm.addextensionprovider("x", "jabber:x:data", new dataformprovider());
      //html
      pm.addextensionprovider("html", "http://jabber.org/protocol/xhtml-im", new xhtmlextensionprovider());
      //ad-hoc command
      pm.addiqprovider("command", "http://jabber.org/protocol/commands", new adhoccommanddataprovider());
    // chat state
    chatstateextension.provider chatstate = new chatstateextension.provider();
    pm.addextensionprovider("active", "http://jabber.org/protocol/chatstates", chatstate);
    pm.addextensionprovider("composing", "http://jabber.org/protocol/chatstates",
      chatstate);
    pm.addextensionprovider("paused", "http://jabber.org/protocol/chatstates", chatstate);
    pm.addextensionprovider("inactive", "http://jabber.org/protocol/chatstates", chatstate);
    pm.addextensionprovider("gone", "http://jabber.org/protocol/chatstates", chatstate);
    //muc user,admin,owner
    pm.addextensionprovider("x", "http://jabber.org/protocol/muc#user", new mucuserprovider());
    pm.addiqprovider("query", "http://jabber.org/protocol/muc#admin", new mucadminprovider());
    pm.addiqprovider("query", "http://jabber.org/protocol/muc#owner", new mucownerprovider());
  }

  private static void initfeatures(xmppconnection xmppconnection) {
    servicediscoverymanager.setidentityname("android_im");
    servicediscoverymanager.setidentitytype("phone");
    servicediscoverymanager sdm = servicediscoverymanager.getinstancefor(xmppconnection);
     if(sdm == null) {
    sdm = new servicediscoverymanager(xmppconnection);
    }
    sdm.addfeature("http://jabber.org/protocol/disco#info");
    sdm.addfeature("http://jabber.org/protocol/caps");
    sdm.addfeature("urn:xmpp:avatar:metadata");
    sdm.addfeature("urn:xmpp:avatar:metadata+notify");
    sdm.addfeature("urn:xmpp:avatar:data");
    sdm.addfeature("http://jabber.org/protocol/nick");
    sdm.addfeature("http://jabber.org/protocol/nick+notify");
    sdm.addfeature("http://jabber.org/protocol/xhtml-im");
    sdm.addfeature("http://jabber.org/protocol/muc");
    sdm.addfeature("http://jabber.org/protocol/commands");
    sdm.addfeature("http://jabber.org/protocol/si/profile/file-transfer");
    sdm.addfeature("http://jabber.org/protocol/si");
    sdm.addfeature("http://jabber.org/protocol/bytestreams");
    sdm.addfeature("http://jabber.org/protocol/ibb");
    sdm.addfeature("http://jabber.org/protocol/feature-neg");
    sdm.addfeature("jabber:iq:privacy");
  }

}

上面有两张spark客户端的聊天室列表占有者一列不同的原因：当使用以下代码获取时不能获取occupantscount和subject的值：  

system.out.println(roominfo.getoccupantscount() + " : " + roominfo.getsubject());

这是由于openfire端有个bug（暂且这样说吧，我不知为什么openfire这样做）.首先修改smack的一个bug,修改roominfo类的roominfo(discoverinfo info) 方法:         

iterator<string> values = form.getfield("muc#roominfo_subject").getvalues();
if (values.hasnext()) {
  this.subject = values.next();
}
else {
  this.subject = "";
}

改为：   

final formfield subjfield = form.getfield("muc#roominfo_subject");
this.subject = subjfield == null ? "" : subjfield.getvalues().next();

  修改openfire的源码，org/jivesoftware/openfire/muc/spi/multiuserchatserviceimpl类的public dataform getextendedinfo(string name, string node, jid senderjid) 方法：         

/*final formfield fieldocc = dataform.addfield(); */
fieldsubj.setvariable("muc#roominfo_occupants");
fieldsubj.setlabel(localeutils.getlocalizedstring("muc.extended.info.occupants"));
fieldsubj.addvalue(integer.tostring(room.getoccupantscount()));

  
改为：         

final formfield fieldoccu= dataform.addfield()； 
fieldoccu.setvariable("muc#roominfo_occupants"); 
fieldoccu.setlabel(localeutils.getlocalizedstring("muc.extended.info.occupants")); 
fieldoccu.addvalue(integer.tostring(room.getoccupantscount()));  

 

使用asmack开发基于android的im系统同理.