java Smack整合Openfire服务器实现IM即时通讯聊天功能

客官°小女子只卖身不卖艺 2022-07-21 01:22 328阅读 0赞

原文：[java Smack整合Openfire服务器实现IM即时通讯聊天功能][java Smack_Openfire_IM]

源代码下载地址： [http://www.zuidaima.com/share/1816369152052224.htm][java Smack_Openfire_IM]

在文章开始，请你了解和熟悉openfire方面的相关知识，这样对你理解下面代码以及下面代码的用途有很好的了解。同时，你可能需要安装一个简单的CS聊天工具，来测试你的代码是否成功的在openfire服务器上建立会话链接，并成功的向在线用户发送聊天消息。

[聊天软件Spark][Spark]，用于测试聊天消息发送是否成功，下载地址：[http://www.igniterealtime.org/downloads/download-landing.jsp?file=spark/spark\_2\_6\_3.exe][http_www.igniterealtime.org_downloads_download-landing.jsp_file_spark_spark_2_6_3.exe]

然后你需要添加smack相关的jar包

smack.jar  
smackx.jar

jar包下载地址：[http://www.igniterealtime.org/downloads/download-landing.jsp?file=smack/smack\_3\_2\_2.zip][http_www.igniterealtime.org_downloads_download-landing.jsp_file_smack_smack_3_2_2.zip]

代码中还用到了junit，junit jar下载地址：[http://ebr.springsource.com/repository/app/bundle/version/download?name=com.springsource.org.junit&version=4.8.2&type=binary][http_ebr.springsource.com_repository_app_bundle_version_download_name_com.springsource.org.junit_version_4.8.2_type_binary]

package com.hoo.smack;
     
    import java.util.Collection;
    import java.util.Iterator;
    import javax.net.SocketFactory;
    import org.jivesoftware.smack.AccountManager;
    import org.jivesoftware.smack.Chat;
    import org.jivesoftware.smack.ChatManager;
    import org.jivesoftware.smack.Connection;
    import org.jivesoftware.smack.ConnectionConfiguration;
    import org.jivesoftware.smack.MessageListener;
    import org.jivesoftware.smack.Roster;
    import org.jivesoftware.smack.RosterEntry;
    import org.jivesoftware.smack.XMPPConnection;
    import org.jivesoftware.smack.XMPPException;
    import org.jivesoftware.smack.packet.Message;
    import org.jivesoftware.smack.packet.Presence;
    import org.jivesoftware.smack.packet.Session;
    import org.jivesoftware.smack.packet.Message.Type;
    import org.junit.After;
    import org.junit.Before;
    import org.junit.Test;
     
    /**
     * 利用Smack框架完成 XMPP 协议通信
     */
    public class SmackXMPPTest {
     
        private Connection connection;
        private ConnectionConfiguration config;
        /** openfire服务器address */
        private final static String server = "192.168.8.32";
        
        private final void fail(Object o) {
            if (o != null) {
                System.out.println(o);
            }
        }
        
        private final void fail(Object o, Object... args) {
            if (o != null && args != null && args.length > 0) {
                String s = o.toString();
                for (int i = 0; i < args.length; i++) {
                    String item = args[i] == null ? "" : args[i].toString();
                    if (s.contains("{" + i + "}")) {
                        s = s.replace("{" + i + "}", item);
                    } else {
                        s += " " + item;
                    }
                }
                System.out.println(s);
            }
        }
        
        /**
         *  初始Smack对openfire服务器链接的基本配置
         */
        @Before
        public void init() {
            try {
                //connection = new XMPPConnection(server);
                //connection.connect();
                /** 5222是openfire服务器默认的通信端口，你可以登录http://192.168.8.32:9090/到管理员控制台查看客户端到服务器端口 */
                config = new ConnectionConfiguration(server, 5222);
                
                /** 是否启用压缩 */ 
                config.setCompressionEnabled(true);
                /** 是否启用安全验证 */
                config.setSASLAuthenticationEnabled(true);
                /** 是否启用调试 */
                config.setDebuggerEnabled(false);
                //config.setReconnectionAllowed(true);
                //config.setRosterLoadedAtLogin(true);
                
                /** 创建connection链接 */
                connection = new XMPPConnection(config);
                /** 建立连接 */
                connection.connect();
            } catch (XMPPException e) {
                e.printStackTrace();
            }
            fail(connection);
            fail(connection.getConnectionID());
        }
        
        @After
        public void destory() {
            if (connection != null) {
                connection.disconnect();
                connection = null;
            }
        }
        
        /**
         * ConnectionConfiguration 的基本配置相关信息
         */
        @Test
        public void testConfig() {
            fail("PKCS11Library: " + config.getPKCS11Library());
            fail("ServiceName: {0}", config.getServiceName());
            // ssl证书密码
            fail("TruststorePassword: {0}", config.getTruststorePassword());
            fail("TruststorePath: {0}", config.getTruststorePath());
            fail("TruststoreType: {0}", config.getTruststoreType());
            
            SocketFactory socketFactory = config.getSocketFactory();
            fail("SocketFactory: {0}", socketFactory);
            /*try {
                fail("createSocket: {0}", socketFactory.createSocket("localhost", 3333));
            } catch (IOException e) {
                e.printStackTrace();
            }*/
        }
        
        /**
         *  Connection 基本方法信息
         */
        @Test
        public void testConnection() {
            /** 用户管理 */
            AccountManager accountManager = connection.getAccountManager();
            for (String attr : accountManager.getAccountAttributes()) {
                fail("AccountAttribute: {0}", attr);
            }
            fail("AccountInstructions: {0}", accountManager.getAccountInstructions());
            /** 是否链接 */
            fail("isConnected:", connection.isConnected());
            fail("isAnonymous:", connection.isAnonymous());
            /** 是否有权限 */
            fail("isAuthenticated:", connection.isAuthenticated());
            fail("isSecureConnection:", connection.isSecureConnection());
            /** 是否使用压缩 */
            fail("isUsingCompression:", connection.isUsingCompression());
        }
        
        /**
         * 用户管理器
         */
        @Test
        public void testAccountManager() {
            AccountManager accountManager = connection.getAccountManager();
            for (String attr : accountManager.getAccountAttributes()) {
                fail("AccountAttribute: {0}", attr);
            }
            fail("AccountInstructions: {0}", accountManager.getAccountInstructions());
            
            fail("supportsAccountCreation: {0}", accountManager.supportsAccountCreation());
            try {
                /** 创建一个用户boy，密码为boy；你可以在管理员控制台页面http://192.168.8.32:9090/user-summary.jsp查看用户/组的相关信息，来查看是否成功创建用户 */
                accountManager.createAccount("boy", "boy");
                /** 修改密码 */
                accountManager.changePassword("abc");
            } catch (XMPPException e) {
                e.printStackTrace();
            }
        }
        
        @Test
        public void testUser() {
            try {
                /** 用户登陆，用户名、密码 */
                connection.login("hoojo", "hoojo");
            } catch (XMPPException e) {
                e.printStackTrace();
            }
            /** 获取当前登陆用户 */
            fail("User:", connection.getUser());
            
            /** 所有用户组 */
            Roster roster = connection.getRoster();
            
            /** 好友用户组，你可以用Spark添加用户好友，这样这里就可以查询到相关的数据 */
            Collection<RosterEntry> rosterEntiry = roster.getEntries();
            Iterator<RosterEntry> iter = rosterEntiry.iterator();
            while (iter.hasNext()) {
                RosterEntry entry = iter.next();
                fail("Groups: {0}, Name: {1}, Status: {2}, Type: {3}, User: {4}", entry.getGroups(), entry.getName(), entry.getStatus(), entry.getType(), entry);
            }
            
            fail("-------------------------------");
            /** 未处理、验证好友，添加过的好友，没有得到对方同意 */
            Collection<RosterEntry> unfiledEntries = roster.getUnfiledEntries();
            iter = unfiledEntries.iterator();
            while (iter.hasNext()) {
                RosterEntry entry = iter.next();
                fail("Groups: {0}, Name: {1}, Status: {2}, Type: {3}, User: {4}", entry.getGroups(), entry.getName(), entry.getStatus(), entry.getType(), entry);
            }
        }
        
        @Test
        @SuppressWarnings("static-access")
        public void testPacket() {
            try {
                connection.login("hoojo", "hoojo");
            } catch (XMPPException e) {
                e.printStackTrace();
            }
            
            //Packet packet = new Data(new DataPacketExtension("jojo@" + server, 2, "this is a message"));
            //connection.sendPacket(packet);
            
            /** 更改用户状态，available=true表示在线，false表示离线，status状态签名；当你登陆后，在Spark客户端软件中就可以看到你登陆的状态 */
            Presence presence = new Presence(Presence.Type.available);
            presence.setStatus("Q我吧");
            connection.sendPacket(presence);
            
            Session session = new Session();
            String sessid = session.nextID();
            connection.sendPacket(session);
            /** 向jojo@192.168.8.32 发送聊天消息，此时你需要用Spark软件登陆jojo这个用户，
             * 这样代码就可以向jojo这个用户发送聊天消息，Spark登陆的jojo用户就可以接收到消息
             **/
            /** Type.chat 表示聊天，groupchat多人聊天，error错误，headline在线用户； */
            Message message = new Message("jojo@" + server, Type.chat);
            //Message message = new Message(sessid, Type.chat);
            message.setBody("h!~ jojo, I'am is hoojo!");
            connection.sendPacket(message);
            
            try {
                Thread.sleep(1);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        
        /**
         *  测试聊天消息管理类
         */
        @Test
        public void testChatManager() {
            /** 设置状态 */
            try {
                connection.login("hoojo", "hoojo");
            } catch (XMPPException e) {
                e.printStackTrace();
            }
            
            /** 设置状态 */
            Presence presence = new Presence(Presence.Type.available);
            presence.setStatus("Q我吧");
            connection.sendPacket(presence);
            
            /** 获取当前登陆用户的聊天管理器 */
            ChatManager chatManager = connection.getChatManager();
            /** 为指定用户创建一个chat，MyMessageListeners用于监听对方发过来的消息  */
            Chat chat = chatManager.createChat("jojo@" + server, new MyMessageListeners());
            try {
                /** 发送消息 */
                chat.sendMessage("h!~ jojo……");
                
                /** 用message对象发送消息 */
                Message message = new Message();
                message.setBody("message");
                message.setProperty("color", "red");
                chat.sendMessage(message);
            } catch (XMPPException e) {
                e.printStackTrace();
            }
            try {
                Thread.sleep(1000 * 1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        
        /**
         *  消息监听器，用户监听对方发送的消息，也可以想对方发送消息
         */
        class MyMessageListeners implements MessageListener {
            public void processMessage(Chat chat, Message message) {
                try {
                    /** 发送消息 */
                    chat.sendMessage("dingding……" + message.getBody());
                } catch (XMPPException e) {
                    e.printStackTrace();
                }
                /** 接收消息 */
                fail("From: {0}, To: {1}, Type: {2}, Sub: {3}", message.getFrom(), message.getTo(), message.getType(), message.toXML());
                /*Collection<Body> bodys =  message.getBodies();
                for (Body body : bodys) {
                    fail("bodies[{0}]", body.getMessage());
                }
                //fail(message.getLanguage());
                //fail(message.getThread());
                //fail(message.getXmlns());*/
                fail("body: ", message.getBody());
            }
        }
    }

好了，这些都是smack的基本功能。

原文地址：[http://www.blogjava.net/hoojo/archive/2012/06/25/381445.html][http_www.blogjava.net_hoojo_archive_2012_06_25_381445.html]

欢迎学习哦！

[java Smack_Openfire_IM]: http://www.zuidaima.com/share/1816369152052224.htm
[Spark]: http://www.igniterealtime.org/downloads/index.jsp
[http_www.igniterealtime.org_downloads_download-landing.jsp_file_spark_spark_2_6_3.exe]: http://www.igniterealtime.org/downloads/download-landing.jsp?file=spark/spark_2_6_3.exe
[http_www.igniterealtime.org_downloads_download-landing.jsp_file_smack_smack_3_2_2.zip]: http://www.igniterealtime.org/downloads/download-landing.jsp?file=smack/smack_3_2_2.zip
[http_ebr.springsource.com_repository_app_bundle_version_download_name_com.springsource.org.junit_version_4.8.2_type_binary]: http://ebr.springsource.com/repository/app/bundle/version/download?name=com.springsource.org.junit&version=4.8.2&type=binary
[http_www.blogjava.net_hoojo_archive_2012_06_25_381445.html]: http://www.blogjava.net/hoojo/archive/2012/06/25/381445.html