简单的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
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
|
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对象(后面介绍)。
那么有这样一种情况，当别人主动跟我们建立连接发送消息，或者系统发送消息时我们怎么才能接收消息呢？
我现在是这样操作的：
|
1
2
3
4
5
6
7
8
9
10
11
12
|
chatmanager.addchatlistener(new chatmanagerlistener() {@overridepublic 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聊天室
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
407
408
409
|
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, "instant@conference.pc2010102716"); muc.create("user1"); muc.sendconfigurationform(new form(form.type_submit)); //----创建手动配置聊天室---- muc = new multiuserchat(connection, "reserved4@conference.pc2010102716"); //销毁聊天室 //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, "ddd@conference.pc2010102716"); 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, "ddd@conference.pc2010102716"); //muc.join("喝醉的毛毛虫", "ddd"); //加入聊天室(使用昵称喝醉的毛毛虫 ,使用密码ddd)并且获取聊天室里最后5条信息， //注：addmessagelistener监听器必须在此join方法之前，否则无法监听到需要的5条消息 muc = new multiuserchat(connection, "ddd@conference.pc2010102716"); 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, "ddd@conference.pc2010102716"); 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("ddd@conference.pc2010102716/飞鸟", 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的值：
|
1
|
system.out.println(roominfo.getoccupantscount() + " : " + roominfo.getsubject()); |
这是由于openfire端有个bug（暂且这样说吧，我不知为什么openfire这样做）.首先修改smack的一个bug,修改roominfo类的roominfo(discoverinfo info) 方法:
|
1
2
3
4
5
6
7
8
|
iterator<string> values = form.getfield("muc#roominfo_subject").getvalues(); if (values.hasnext()) { this.subject = values.next(); } else { this.subject = ""; } |
改为：
|
1
2
|
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) 方法：
|
1
2
3
4
|
/*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系统同理.
