Smack 結合 Openfire服務器，創建IM通訊，發送聊天消息
在文章開始，請你瞭解和熟悉openfire方面的相關知識，這樣對你理解下面代碼以及下面代碼的用途有很好的瞭解。同時，你可能須要安裝一個簡單的CS聊天工具，來測試你的代碼是否成功的在openfire服務器上創建會話連接，併成功的向在線用戶發送聊天消息。html
必須瞭解：http://www.cnblogs.com/hoojo/archive/2012/05/17/2506769.htmljava
http://www.cnblogs.com/hoojo/archive/2012/05/13/2498151.html （非windows 系統）spring
可選：http://www.cnblogs.com/hoojo/archive/2012/05/17/2506845.htmlwindows
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包session
smack.jar
smackx.jarapp
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=binarysocket
下面開始代碼部分
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的基本功能，還有更多的東西須要研究，下次有機會再分享！
相關文章
- 1. Smack 結合 Openfire服務器，創建IM通訊，發送聊天消息
- 2. Android基於XMPP Smack Openfire開發IM（1）搭建openfire服務器
- 3. Android基於XMPP Smack Openfire開發IM（5）發送消息
- 4. 基於Openfire Smack開發即時通訊應用、搭建Openfire服務器(一)
- 5. Openfire XMPP Smack RTC IM 即時通信 聊天 MD
- 6. Openfire 單人聊天和多人聊天（發送消息、接收消息）
- 7. openfire smack包聊天室
- 8. openfire源碼修改聊天消息發送內容
- 9. 騰訊IM客服聊天
- 10. 創建即時通信服務器的工具 openfire 簡介
- 更多相關文章...
- • HTTP 消息結構 - HTTP 教程
- • Git 服務器搭建 - Git 教程
- • Spring Cloud 微服務實戰(三) - 服務註冊與發現
- • PHP開發工具
相關標籤/搜索
每日一句
-
每一个你不满意的现在，都有一个你没有努力的曾经。
最新文章
- 1. 融合阿里雲，牛客助您找到心儀好工作
- 2. 解決jdbc(jdbctemplate)在測試類時不報錯在TomCatb部署後報錯
- 3. 解決PyCharm GoLand IntelliJ 等 JetBrains 系列 IDE無法輸入中文
- 4. vue+ant design中關於圖片請求不顯示的問題。
- 5. insufficient memory && Native memory allocation (malloc) failed
- 6. 解決IDEA用Maven創建的Web工程不能創建Java Class文件的問題
- 7. [已解決] Error: Cannot download ‘https://start.spring.io/starter.zip?
- 8. 在idea讓java文件夾正常使用
- 9. Eclipse啓動提示「subversive connector discovery」
- 10. 帥某-技巧-快速轉帖博主文章（article_content）
歡迎關注本站公眾號,獲取更多信息
相關文章
- 1. Smack 結合 Openfire服務器，創建IM通訊，發送聊天消息
- 2. Android基於XMPP Smack Openfire開發IM（1）搭建openfire服務器
- 3. Android基於XMPP Smack Openfire開發IM（5）發送消息
- 4. 基於Openfire Smack開發即時通訊應用、搭建Openfire服務器(一)
- 5. Openfire XMPP Smack RTC IM 即時通信 聊天 MD
- 6. Openfire 單人聊天和多人聊天（發送消息、接收消息）
- 7. openfire smack包聊天室
- 8. openfire源碼修改聊天消息發送內容
- 9. 騰訊IM客服聊天
- 10. 創建即時通信服務器的工具 openfire 簡介