java+smack+openfire即时通讯Im（四）

朱雀 2020-10-25 07:52 1036阅读 0赞

### 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<String> maxusers = new ArrayList<String>();
 maxusers.add("100");
 answerForm.setAnswer("muc#roomconfig_maxusers", maxusers);
 
 List<String> cast_values = new ArrayList<String>();
 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);），要不然过一段时间群聊会自动删除的，还有就是添加成员进入群聊以后，当成员下线以后会自动将下线的成员踢出群聊。