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

  

下面開始代碼部分

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());

}

}

}

 

好了，這些都是smack的基本功能，還有更多的東西須要研究，下次有機會再分享！