### java+smack+openfire即时通讯Im(四) ###

* 创建群聊

* 加入群聊

# 创建群聊 #

前面的单聊完成以后，就开始群聊的功能把，首先是创建群聊：

后端进行群组创建：

/***

*

* 方法名称：createMutiUserChat

* 概要说明：创建群聊

*

* @param userName

* @param password

* @param roomName

* @param roomDesc

* @return void

*

* @author ZhangYH

* @date 2020/06/17 10:18:08

*/

public static String createMutiUserChat(String userName, String password,String roomName,String roomDesc){

//默认使用创建人用户名+时间戳为房间ID

String roomId = userName+"_"+System.currentTimeMillis();

try {

XMPPTCPConnection connection = initOpenfireConnect();

connection.login(userName,password);

//获取房间管理对象

MultiUserChatManager manager = MultiUserChatManager.getInstanceFor(connection);

//创建一个房间

MultiUserChat muc = manager.getMultiUserChat(roomId+"@conference."+OPENFIRE_SERVICE_NAME);

muc.create(userName);

// User1 (which is the room owner) configures the room as a moderated room

Form form = muc.getConfigurationForm();

Form answerForm = form.createAnswerForm();

//向提交的表单添加默认答复,获取房间的默认设置菜单

for(FormField field : form.getFields() ){

if(!FormField.Type.hidden.name().equals(field.getType()) && field.getVariable() != null) {

answerForm.setDefaultAnswer(field.getVariable());

}

}

//muc#

//房间名称

answerForm.setAnswer(FormField.FORM_TYPE, "http://jabber.org/protocol/muc#roomconfig");

//设置房间名称

answerForm.setAnswer("muc#roomconfig_roomname",roomName);

//设置房间描述

answerForm.setAnswer("muc#roomconfig_roomdesc", roomDesc);

//是否允许修改主题

answerForm.setAnswer("muc#roomconfig_changesubject", true);

//设置房间最大用户数

List maxusers = new ArrayList();

maxusers.add("100");

answerForm.setAnswer("muc#roomconfig_maxusers", maxusers);

List cast_values = new ArrayList();

cast_values.add("moderator");

cast_values.add("participant");

cast_values.add("visitor");

answerForm.setAnswer("muc#roomconfig_presencebroadcast", cast_values);

//设置为公共房间

answerForm.setAnswer("muc#roomconfig_publicroom", true);

//设置为永久房间

answerForm.setAnswer("muc#roomconfig_persistentroom", true);

//允许修改昵称

answerForm.setAnswer("x-muc#roomconfig_canchangenick", true);

//允许用户登录注册房间

answerForm.setAnswer("x-muc#roomconfig_registration", true);

muc.sendConfigurationForm(answerForm);

muc.join(userName);

//关闭连接

closeConnection(connection);

return roomId;

}catch (Exception e){

e.printStackTrace();

}

return roomId;

}

# 加入群聊 #

/***

*

* 方法名称：joinMultiUserChat

* 概要说明：加入群聊

*

* @param userName

* @param password

* @param roomId

* @return void

*

* @author ZhangYH

* @date 2020/06/17 10:30:28

*/

public static void joinMultiUserChat(String userName, String password, String roomId) {

try {

XMPPTCPConnection connection = initOpenfireConnect();

connection.login(userName,password);

// 使用XMPPConnection创建一个MultiUserChat窗口

MultiUserChatManager manager = MultiUserChatManager.getInstanceFor(connection);

//获取会议室信息

MultiUserChat muc = manager.getMultiUserChat(roomId+"@conference."+OPENFIRE_SERVICE_NAME);

// 聊天室服务将会决定要接受的历史记录数量

DiscussionHistory history = new DiscussionHistory();

history.setMaxStanzas(0);

//history.setSince(new Date());

// 用户加入聊天室

muc.join(userName, password, history, System.currentTimeMillis());

System.out.println("群聊加入成功........");

//关闭连接

closeConnection(connection);

}catch (Exception e){

e.printStackTrace();

}

}

注：openfire的群聊机制是这样的：建群的时候必须要设置群组信息持久化(answerForm.setAnswer(“muc\#roomconfig\_persistentroom”, true);)，要不然过一段时间群聊会自动删除的，还有就是添加成员进入群聊以后，当成员下线以后会自动将下线的成员踢出群聊。