Smack 结合 Openfire服务器，建立IM通信，发送聊天消息

本文主要是介绍Smack 结合 Openfire服务器，建立IM通信，发送聊天消息，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

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

必须了解：http://www.cnblogs.com/hoojo/archive/2012/05/17/2506769.html

http://www.cnblogs.com/hoojo/archive/2012/05/13/2498151.html （非windows 系统）

可选：http://www.cnblogs.com/hoojo/archive/2012/05/17/2506845.html

http://www.cnblogs.com/hoojo/archive/2012/06/18/2553975.html

聊天软件Spark，用于测试聊天消息发送是否成功，下载地址：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

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

下面开始代码部分

[java]  view plain copy print ?  
 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;  
   
 /** 
  * <b>function:</b> 利用Smack框架完成 XMPP 协议通信 
  * @author hoojo 
  * @createDate 2012-5-22 上午10:28:18 
  * @file ConnectionServerTest.java 
  * @package com.hoo.smack.conn 
  * @project jwchat 
  * @blog http://blog.csdn.net/IBM_hoojo 
  * @email hoojo_@126.com 
  * @version 1.0 
  */  
 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);  
         }  
     }  
       
     /** 
      * <b>function:</b> 初始Smack对openfire服务器链接的基本配置 
      * @author hoojo 
      * @createDate 2012-6-25 下午04:06:42 
      */  
     @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;  
         }  
     }  
       
     /** 
      * <b>function:</b> ConnectionConfiguration 的基本配置相关信息 
      * @author hoojo 
      * @createDate 2012-6-25 下午04:11:25 
      */  
     @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(); 
         }*/  
     }  
       
     /** 
      * <b>function:</b> Connection 基本方法信息 
      * @author hoojo 
      * @createDate 2012-6-25 下午04:12:04 
      */  
     @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());  
     }  
       
     /** 
      * <b>function:</b> 用户管理器 
      * @author hoojo 
      * @createDate 2012-6-25 下午04:22:31 
      */  
     @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();  
         }  
     }  
       
     /** 
      * <b>function:</b> 测试聊天消息管理类 
      * @author hoojo 
      * @createDate 2012-6-25 下午05:03:23 
      */  
     @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();  
         }  
     }  
       
     /** 
      * <b>function:</b> 消息监听器，用户监听对方发送的消息，也可以想对方发送消息 
      * @author hoojo 
      * @createDate 2012-6-25 下午05:05:31 
      * @file SmackXMPPTest.java 
      * @package com.hoo.smack 
      * @project jwchat 
      * @blog http://blog.csdn.net/IBM_hoojo 
      * @email hoojo_@126.com 
      * @version 1.0 
      */  
     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());  
         }  
     }  
 }  