第一步：

在pom.xml文件中，引入依赖项

    <dependency><groupId>org.igniterealtime.smack</groupId><artifactId>smack-core</artifactId><version>4.3.4</version></dependency><dependency><groupId>org.igniterealtime.smack</groupId><artifactId>smack-extensions</artifactId><version>4.3.4</version></dependency><dependency><groupId>org.igniterealtime.smack</groupId><artifactId>smack-tcp</artifactId><version>4.3.4</version></dependency><dependency><groupId>org.igniterealtime.smack</groupId><artifactId>smack-java7</artifactId><version>4.3.4</version></dependency>

第二步：

IM登录，创建群聊、加入群聊、发送消息、退出群聊模块代码编写

package com.eddue;import org.jivesoftware.smack.ConnectionConfiguration.SecurityMode;
import org.jivesoftware.smack.SmackConfiguration;
import org.jivesoftware.smack.SmackException;
import org.jivesoftware.smack.SmackException.NotConnectedException;
import org.jivesoftware.smack.XMPPException;
import org.jivesoftware.smack.chat2.Chat;
import org.jivesoftware.smack.chat2.ChatManager;
import org.jivesoftware.smack.chat2.IncomingChatMessageListener;
import org.jivesoftware.smack.packet.Message;
import org.jivesoftware.smack.tcp.XMPPTCPConnection;
import org.jivesoftware.smack.tcp.XMPPTCPConnectionConfiguration;
import org.jivesoftware.smackx.muc.MucEnterConfiguration;
import org.jivesoftware.smackx.muc.MultiUserChat;
import org.jivesoftware.smackx.muc.MultiUserChatManager;
import org.jivesoftware.smackx.xdata.Form;
import org.jxmpp.jid.EntityBareJid;
import org.jxmpp.jid.impl.JidCreate;
import org.jxmpp.jid.parts.Resourcepart;
import org.jxmpp.stringprep.XmppStringprepException;
import java.io.IOException;
import java.util.ArrayList;
import java.util.List;public class Test {private static XMPPTCPConnectionConfiguration config;private static XMPPTCPConnection conn;static {try {config = XMPPTCPConnectionConfiguration.builder().setXmppDomain("192.168.0.229").setHost("192.168.0.229").setPort(5222).setDebuggerFactory(SmackConfiguration.getDefaultSmackDebuggerFactory()).setSecurityMode(SecurityMode.disabled).build();conn = new XMPPTCPConnection(config);conn.connect();} catch (Exception e) {e.printStackTrace();}}public static void login(String username,String password){try {if(conn!=null){conn.login(username, password);System.out.println("user "+username+" login successfully.");}} catch (XMPPException e) {e.printStackTrace();} catch (SmackException e) {e.printStackTrace();} catch (IOException e) {e.printStackTrace();} catch (InterruptedException e) {e.printStackTrace();}}@SuppressWarnings("deprecation")public static void sendMessage(String username,String password,String msg){//先登录login(username, password);//再构建聊天室ChatManager cm = ChatManager.getInstanceFor(conn);cm.addIncomingListener(new IncomingChatMessageListener() {@Overridepublic void newIncomingMessage(EntityBareJid from, Message message, Chat chat) {System.out.println("message from : "+from+" : "+message.getBody());}});try {EntityBareJid jid = JidCreate.entityBareFrom("smack@192.168.0.229");Chat chat = cm.chatWith(jid);Message message = new Message();message.setBody(msg);chat.send(message);while (true){}} catch (XmppStringprepException e) {e.printStackTrace();} catch (NotConnectedException e) {e.printStackTrace();} catch (InterruptedException e) {e.printStackTrace();}}/*** 创建群聊房间* @param groupName 群名称* @param users 创建群完成后添加的群成员* @param groupNickName 群昵称* @return*/public static MultiUserChat createChatRoom(String groupName, List<User> users, String groupNickName) throws Exception {//组装群聊jid,这里需要注意一下,群jid的格式就是  群名称@conference.openfire服务器名称String jid = groupName + "@conference." + "192.168.0.229";EntityBareJid groupJid = JidCreate.entityBareFrom(jid);MultiUserChatManager multiUserChatManager = MultiUserChatManager.getInstanceFor(conn);MultiUserChat muc = multiUserChatManager.getMultiUserChat(groupJid);muc.create(Resourcepart.from(groupNickName));// 获得聊天室的配置表单Form form = muc.getConfigurationForm();// 根据原始表单创建一个要提交的新表单。Form submitForm = form.createAnswerForm();// 设置聊天室的新拥有者List<String> owners = new ArrayList<>();owners.add("admin"+ "@" + "192.168.0.229");//这里的用户实体我要说一下，因为这是我这个项目的实体，实际上这里只需要知道用户的jid获者名称就可以了if(users != null && !users.isEmpty()) {for (int i = 0; i < users.size(); i++){  //添加群成员,用户jid格式和之前一样 用户名@openfire服务器名称EntityBareJid userJid = JidCreate.entityBareFrom(users.get(i).getUsername() + "@" +"192.168.0.229");owners.add(userJid + "");}}submitForm.setAnswer("muc#roomconfig_roomowners", owners);//设置为公共房间submitForm.setAnswer("muc#roomconfig_publicroom", true);// 设置聊天室是持久聊天室，即将要被保存下来submitForm.setAnswer("muc#roomconfig_persistentroom", true);// 房间仅对成员开放submitForm.setAnswer("muc#roomconfig_membersonly", false);// 允许占有者邀请其他人submitForm.setAnswer("muc#roomconfig_allowinvites", true);//进入不需要密码submitForm.setAnswer("muc#roomconfig_passwordprotectedroom",  false);// 能够发现占有者真实 JID 的角色// submitForm.setAnswer("muc#roomconfig_whois", "anyone");// 登录房间对话submitForm.setAnswer("muc#roomconfig_enablelogging", true);// 仅允许注册的昵称登录submitForm.setAnswer("x-muc#roomconfig_reservednick", false);// 允许使用者修改昵称submitForm.setAnswer("x-muc#roomconfig_canchangenick", true);// 允许用户注册房间submitForm.setAnswer("x-muc#roomconfig_registration", false);// 发送已完成的表单（有默认值）到服务器来配置聊天室muc.sendConfigurationForm(submitForm);//添加群消息监听muc.addMessageListener(new InGroupChatMessageListener(jid));return muc;}/*** 发送群聊普通消息* @param groupName* @param body*/public static void sendChatGroupMessage(String groupName, String body) throws Exception {//拼凑jidString jid = groupName + "@conference." + "192.168.0.229";//创建jid实体EntityBareJid groupJid = JidCreate.entityBareFrom(jid);//群管理对象MultiUserChatManager multiUserChatManager = MultiUserChatManager.getInstanceFor(conn);MultiUserChat multiUserChat = multiUserChatManager.getMultiUserChat(groupJid);//发送信息multiUserChat.sendMessage(body);}/*** 加入群聊会议室* @param groupName* @param nickName* @return* @throws Exception*/public static MultiUserChat joinMultiUserChat(String groupName, String nickName) throws Exception {//群jidString jid = groupName + "@conference." + "192.168.0.229";//jid实体创建EntityBareJid groupJid = JidCreate.entityBareFrom(jid);//获取群管理对象MultiUserChatManager multiUserChatManager = MultiUserChatManager.getInstanceFor(conn);//通过群管理对象获取该群房间对象MultiUserChat multiUserChat = multiUserChatManager.getMultiUserChat(groupJid);MucEnterConfiguration.Builder builder = multiUserChat.getEnterConfigurationBuilder(Resourcepart.from(nickName));//只获取最后99条历史记录builder.requestMaxCharsHistory(99);MucEnterConfiguration mucEnterConfiguration = builder.build();//加入群multiUserChat.join(mucEnterConfiguration);return multiUserChat;}/*** 退出群聊* @param groupName* @throws XmppStringprepException*/public static void quitRoom(String groupName) throws Exception {String jid = groupName + "@conference." + "192.168.0.229";EntityBareJid groupJid = JidCreate.entityBareFrom(jid);MultiUserChatManager multiUserChatManager = MultiUserChatManager.getInstanceFor(conn);MultiUserChat multiUserChat = multiUserChatManager.getMultiUserChat(groupJid);//退出群multiUserChat.leave();}public static void main( String[] args ) throws Exception{
//        sendMessage("openfire", "123456", "hello,smack 1111");
//        List<User> list = new ArrayList<>();
//        User user = new User();
//        user.setUsername("openfire");
//        list.add(user);
//        login("admin", "123456");createChatRoom("test2", list, "测试群");
//        sendChatGroupMessage("test2", "hello world");login("smack", "123456");joinMultiUserChat("test2", "haha");sendChatGroupMessage("test2", "hello world2");quitRoom("test2");sendChatGroupMessage("test2", "hello world3");System.in.read();}
}

第三步：

编写群消息IM监听器代码

package com.eddue;import org.jivesoftware.smack.*;
import org.jivesoftware.smack.packet.Message;
import org.jivesoftware.smack.tcp.XMPPTCPConnection;
import org.jivesoftware.smack.tcp.XMPPTCPConnectionConfiguration;
import org.jivesoftware.smackx.muc.MultiUserChat;
import org.jivesoftware.smackx.muc.MultiUserChatManager;
import org.jxmpp.jid.EntityBareJid;
import org.jxmpp.jid.impl.JidCreate;
import org.jxmpp.stringprep.XmppStringprepException;/*** @author zzx* @Description TODO* @company www.eddue.com* @since 2019/8/5 10:58*/
public class InGroupChatMessageListener implements MessageListener {private static XMPPTCPConnectionConfiguration config;private static AbstractXMPPConnection conn;private String jid;public InGroupChatMessageListener(String jid) {this.jid = jid;}static {try {config = XMPPTCPConnectionConfiguration.builder().setXmppDomain("192.168.0.229").setHost("192.168.0.229").setPort(5222).setDebuggerFactory(SmackConfiguration.getDefaultSmackDebuggerFactory()).setSecurityMode(ConnectionConfiguration.SecurityMode.disabled).build();conn = new XMPPTCPConnection(config);conn.connect();} catch (Exception e) {e.printStackTrace();}}@Overridepublic void processMessage(Message message) {try {//创建jid实体EntityBareJid groupJid = JidCreate.entityBareFrom(jid);//群管理对象MultiUserChatManager multiUserChatManager = MultiUserChatManager.getInstanceFor(conn);MultiUserChat multiUserChat = multiUserChatManager.getMultiUserChat(groupJid);//发送信息multiUserChat.sendMessage(message);} catch (SmackException.NotConnectedException e) {e.printStackTrace();} catch (InterruptedException e) {e.printStackTrace();} catch (XmppStringprepException e) {e.printStackTrace();}}}

第四步：

创建一个用户对象

package com.eddue;/*** @author zzx* @Description TODO* @company www.eddue.com* @since 2019/8/5 11:33*/
public class User {private String username;public String getUsername() {return username;}public void setUsername(String username) {this.username = username;}
}

第五步：

使用Spark工具，测试群聊功能是否ok