前言

Java領(lǐng)域的即時(shí)通信的解決方案可以考慮openfire+spark+smack。當(dāng)然也有其他的選擇。

Openfire?是基于Jabber協(xié)議(XMPP)實(shí)現(xiàn)的即時(shí)通信服務(wù)器端版本，目前建議使用3.8.1版本，這個(gè)版本是當(dāng)前最新的版本，而且網(wǎng)上可以找到下載的源代碼。

即時(shí)通信客戶端可使用spark2.6.3,這個(gè)版本是目前最新的release版本，經(jīng)過(guò)測(cè)試發(fā)現(xiàn)上一版本在視頻支持,msn網(wǎng)關(guān)支持上可能有問(wèn)題，所以選擇openfire3.8.1+spark2.6.3是最合適的選擇。

Smack是即時(shí)通信客戶端編程庫(kù)，目前我已測(cè)通通過(guò)jsp使用smack的API向openfire注冊(cè)用戶發(fā)送消息，并且可以通過(guò)監(jiān)聽(tīng)器獲得此用戶的應(yīng)答消息。

通過(guò)smack向msn用戶和QQ用戶,gtalk用戶發(fā)送消息應(yīng)該也可以實(shí)現(xiàn)，關(guān)于向gtalk用戶發(fā)送消息的例子較多。這個(gè)留待以后研究。至少目前可以通過(guò)程序向spark發(fā)消息了。對(duì)于局域網(wǎng)內(nèi)部應(yīng)用足以解決系統(tǒng)與用戶交互的問(wèn)題，甚至可以做自動(dòng)應(yīng)答機(jī)器人。?

Spark支持聊天，語(yǔ)音，視頻，會(huì)議，文件收發(fā)，截屏，連接msn等功能。

同時(shí)在Android移動(dòng)端和Web端也有相應(yīng)的編程庫(kù)支持，在后面的章節(jié)會(huì)為大家逐步更新介紹，接下來(lái)我們首先要對(duì)幾個(gè)重點(diǎn)的技術(shù)環(huán)節(jié)做些必要的講解。

?

1.什么是XMPP

XMPP?(Extensible?Messaging?and?Presence?Protocol)，簡(jiǎn)單的來(lái)講，它就是一個(gè)發(fā)送接收處理消息的協(xié)議，但是這個(gè)協(xié)議發(fā)送的消息，既不是二進(jìn)制的東東也不是字符串，而是XML。正是因?yàn)槭褂昧薠ML作為消息傳遞的中介，Extensible?才談的上。XMPP的前身是Jabber，一個(gè)開(kāi)源形式組織產(chǎn)生的網(wǎng)絡(luò)即時(shí)通信協(xié)議。XMPP目前被IETF國(guó)際標(biāo)準(zhǔn)組織完成了標(biāo)準(zhǔn)化工作。

2.IM

Instant?Messenger，及時(shí)通信軟件，就是大家使用的QQ、MSN?Messenger和Gtalk等等。其中Gtalk?就是基于XMPP?協(xié)議的一個(gè)實(shí)現(xiàn)，其他的則不是。當(dāng)前IM?幾乎作為每個(gè)上網(wǎng)者必然使用的工具，在國(guó)外的大型企業(yè)中有一些企業(yè)級(jí)的IM應(yīng)用，但是其商業(yè)價(jià)值還沒(méi)完全發(fā)揮出來(lái)。設(shè)想既然XMPP?協(xié)議是一個(gè)公開(kāi)的協(xié)議，那么每個(gè)企業(yè)都可以利用它來(lái)開(kāi)發(fā)適合本身企業(yè)工作，提高自身生產(chǎn)效率的IM；甚至，你還可以在網(wǎng)絡(luò)游戲中集成這種通信軟件，不但讓你可以邊游戲邊聊天，也可以開(kāi)發(fā)出適合游戲本身的IM?應(yīng)用，比如說(shuō)一些游戲關(guān)鍵場(chǎng)景提醒功能，團(tuán)隊(duì)語(yǔ)音交流等等都可以基于IM來(lái)實(shí)現(xiàn)。

3.Spark,smack和Openfire

開(kāi)源界總是有許多有趣的東東，這三個(gè)合起來(lái)就是一個(gè)完整的XMPP?IM?實(shí)現(xiàn)。包括服務(wù)器端——Openfire，客戶端——Spark，XMPP?傳輸協(xié)議的實(shí)現(xiàn)——Smack（記住，XMPP是一個(gè)協(xié)議，協(xié)議是需要實(shí)現(xiàn)的，Smack起到的就是這樣的一個(gè)作用）。三者都是基于Java?語(yǔ)言的實(shí)現(xiàn)。

Spark?提供了客戶端一個(gè)基本的實(shí)現(xiàn)，并提出了一個(gè)很好的插件架構(gòu)，這對(duì)于開(kāi)發(fā)者來(lái)說(shuō)不能不說(shuō)是一個(gè)福音。我強(qiáng)烈建議基于插件方式來(lái)實(shí)現(xiàn)你新增加的功能，而不是去改它的源代碼，這樣有利于你項(xiàng)目架構(gòu)，把原始項(xiàng)目的影響降到最低。

Openfire?是基于XMPP?協(xié)議的IM?的服務(wù)器端的一個(gè)實(shí)現(xiàn)，雖然當(dāng)兩個(gè)用戶連接后，可以通過(guò)點(diǎn)對(duì)點(diǎn)的方式來(lái)發(fā)送消息，但是用戶還是需要連接到服務(wù)器來(lái)獲取一些連接信息和通信信息的，所以服務(wù)器端是必須要實(shí)現(xiàn)的。Openfire?也提供了一些基本功能，但真的很基本的！慶幸的是，它也提供插件的擴(kuò)展，像Spark?一樣，同樣強(qiáng)烈建議使用插件擴(kuò)展的方式來(lái)增加新的功能，而不是修改人家的源代碼。

Smack?是一個(gè)XMPP?協(xié)議的Java?實(shí)現(xiàn)，提供一套可擴(kuò)展的API，不過(guò)有些時(shí)候，你還是不得不使用自己定制發(fā)送的XML?文件內(nèi)容的方式來(lái)實(shí)現(xiàn)自己的功能

下圖展示了三者之間的關(guān)系：

Spark?提供了客戶端一個(gè)基本的實(shí)現(xiàn)，并提出了一個(gè)很好的插件架構(gòu)，這對(duì)于開(kāi)發(fā)者來(lái)說(shuō)不能不說(shuō)是一個(gè)福音。我強(qiáng)烈建議基于插件方式來(lái)實(shí)現(xiàn)你新增加的功能，而不是去改它的源代碼，這樣有利于你項(xiàng)目架構(gòu)，把原始項(xiàng)目的影響降到最低。

Openfire?是基于XMPP?協(xié)議的IM?的服務(wù)器端的一個(gè)實(shí)現(xiàn)，雖然當(dāng)兩個(gè)用戶連接后，可以通過(guò)點(diǎn)對(duì)點(diǎn)的方式來(lái)發(fā)送消息，但是用戶還是需要連接到服務(wù)器來(lái)獲取一些連接信息和通信信息的，所以服務(wù)器端是必須要實(shí)現(xiàn)的。Openfire?也提供了一些基本功能，但真的很基本的！慶幸的是，它也提供插件的擴(kuò)展，像Spark?一樣。

Smack?是一個(gè)XMPP?協(xié)議的Java?實(shí)現(xiàn)，提供一套可擴(kuò)展的API，不過(guò)有些時(shí)候，你還是不得不使用自己定制發(fā)送的XML?文件內(nèi)容的方式來(lái)實(shí)現(xiàn)自己的功能。

4.安裝Openfire3.8.1

使用openfire需要配置機(jī)器的域名。如果局域網(wǎng)內(nèi)沒(méi)有安裝域服務(wù)器，則需要手工為機(jī)器配置域名，打開(kāi)C:\WINDOWS\system32\drivers\etc\hosts文件，增加一新行：?
127.0.0.1 csdn.shimiso.com? （用戶根據(jù)自己的需要可配置稱別的名字，但最好符合帶.的域名格式）?
其他機(jī)器使用域名訪問(wèn)openfire,也需要在C:\WINDOWS\system32\drivers\etc\hosts中指定bzwang.tzsoft.com對(duì)應(yīng)的ip地址，假設(shè)安裝openfire的主機(jī)IP為192.168.1.10,則hosts文件中應(yīng)增加一新行:?
192.168.1.10 csdn.shimiso.com?
通過(guò)這種方式指定主機(jī)域名，建議安裝openfire的機(jī)器配置靜態(tài)ip地址以免ip發(fā)生改變。

語(yǔ)言選擇簡(jiǎn)體中文，見(jiàn)下圖：

后續(xù)按照提示安裝，點(diǎn)擊完成啟動(dòng)openfire，最后出現(xiàn)下面的界面：

????

點(diǎn)”Launch?Admin”,出現(xiàn)下面的頁(yè)面，頁(yè)面連接為http://127.0.0.1:9090/setup/index.jsp

語(yǔ)種選擇中文（簡(jiǎn)體），點(diǎn)”Continue”:（下面的頁(yè)面如果出現(xiàn)英文，請(qǐng)刷新一下頁(yè)面或者重新點(diǎn)Launch?Admin）

這個(gè)頁(yè)面的Domain默認(rèn)為機(jī)器名，請(qǐng)改為一開(kāi)始設(shè)置的域名，例如csdn.shimiso.com，接著點(diǎn)Continue(繼續(xù)):

這個(gè)頁(yè)面中第一個(gè)選項(xiàng)，即標(biāo)準(zhǔn)數(shù)據(jù)庫(kù)連接，不要選擇嵌入的數(shù)據(jù)庫(kù)(Embedded?Database,嵌入的數(shù)據(jù)庫(kù)是hsqldb數(shù)據(jù)庫(kù)，生產(chǎn)環(huán)境不要選擇此選項(xiàng)?),然后點(diǎn)”繼續(xù)”:

這里我用的是mysql數(shù)據(jù)庫(kù)，按官方要求最好是5.0以上，確保有個(gè)名字叫openfire的庫(kù)存在，配好后點(diǎn)繼續(xù)

這個(gè)頁(yè)面是配置是否使用LDAP,我們現(xiàn)在不配置LDAP,所以選擇?Default默認(rèn)即可，點(diǎn)繼續(xù):

這里填寫郵箱和確認(rèn)密碼后直接點(diǎn)繼續(xù)： 等待大約30秒左右，到此安裝和配置操作全部完成。打開(kāi)http://127.0.0.1:9090/login.jsp?登錄管理頁(yè)面

進(jìn)入用戶/組新增一個(gè)用戶。

5.客戶端配置和調(diào)試

這里我沒(méi)用使用官方的spark客戶端，而是用了?潘迪安?和?如意通?，配置截圖如下：

????

聊天演示：

?

從上面的聊天記錄我們發(fā)現(xiàn)所有的用戶id全稱都是：用戶名@域名/資源名，這個(gè)就是我們?cè)赬MPP協(xié)議中通常說(shuō)說(shuō)的JID，即jabber id，它是一個(gè)xmpp協(xié)議帳號(hào)系統(tǒng)的通稱，后面我們?cè)谑褂胹mack編程庫(kù)調(diào)試接口時(shí)會(huì)經(jīng)常用到這個(gè)參數(shù)。

?

6.使用Smack編程庫(kù)進(jìn)行代碼功能調(diào)試

關(guān)于Smack編程庫(kù)，前面我們提到，它是面向Java端的api，主要在PC上使用，利用它我們可以?向openfire服務(wù)器注冊(cè)用戶，發(fā)送消息，并且可以通過(guò)監(jiān)聽(tīng)器獲得此用戶的應(yīng)答消息，以及構(gòu)建聊天室，分組，個(gè)人通訊錄等等。

下面我們寫幾個(gè)程序小例子測(cè)試一下。

（1）登錄操作

PPConnection.DEBUG_ENABLED = true; AccountManager accountManager; final ConnectionConfiguration connectionConfig = new ConnectionConfiguration( "192.168.1.78", Integer.parseInt("5222"), "csdn.shimiso.com"); // 允許自動(dòng)連接 connectionConfig.setReconnectionAllowed(true); connectionConfig.setSendPresence(true); Connection connection = new XMPPConnection(connectionConfig); try { connection.connect();// 開(kāi)啟連接 accountManager = connection.getAccountManager();// 獲取賬戶管理類 } catch (XMPPException e) { throw new IllegalStateException(e); } // 登錄 connection.login("admin", "admin","SmackTest"); System.out.println(connection.getUser()); connection.getChatManager().createChat("shimiso@csdn.shimiso.com",null).sendMessage("Hello word!");

運(yùn)行結(jié)果：

在login中一共有三個(gè)參數(shù)，登錄名，密碼，資源名，可能有人不明白資源名到底是什么意思，其實(shí)就是客戶端的來(lái)源，客戶端的名稱，如果不寫它默認(rèn)就叫smack，如果你用相同的賬戶不同的資源名和同一個(gè)人發(fā)三條消息，那將會(huì)彈出三個(gè)窗口，而不是一個(gè)窗口。?
同時(shí)smack還為我們提供了非常好的調(diào)試工具Smack Debug，利用該工具我們可以準(zhǔn)確的捕獲詳細(xì)的往返報(bào)文信息。

（2）下面我們繼續(xù)寫個(gè)聊天的例子：

PPConnection.DEBUG_ENABLED = true; AccountManager accountManager; final ConnectionConfiguration connectionConfig = new ConnectionConfiguration( "192.168.1.78", Integer.parseInt("5222"), "csdn.shimiso.com"); // 允許自動(dòng)連接 connectionConfig.setReconnectionAllowed(true); connectionConfig.setSendPresence(true); Connection connection = new XMPPConnection(connectionConfig); try { connection.connect();// 開(kāi)啟連接 accountManager = connection.getAccountManager();// 獲取賬戶管理類 } catch (XMPPException e) { throw new IllegalStateException(e); } // 登錄 connection.login("admin", "admin","SmackTest3"); ChatManager chatmanager = connection.getChatManager(); Chat newChat = chatmanager.createChat("shimiso@csdn.shimiso.com", new MessageListener() { public void processMessage(Chat chat, Message message) { if (message.getBody() != null) { System.out.println("Received from 【" + message.getFrom() + "】 message: " + message.getBody()); } } }); Scanner input = new Scanner(System.in); while (true) { String message = input.nextLine(); newChat.sendMessage(message); }

運(yùn)行結(jié)果：

這里我們用Scanner來(lái)捕捉用戶在控制臺(tái)的鍵盤操作，將信息發(fā)出，同時(shí)創(chuàng)建了一個(gè)MessageListener監(jiān)聽(tīng)，在其中強(qiáng)制實(shí)現(xiàn)processMessage方法即可捕獲發(fā)回的信息，在初次使用上還是較為容易上手的，我們只要細(xì)心查看API即可逐步深入下去。

（3）除了聊天以外我們經(jīng)常還能想到就是廣播，需要給所有在線的用戶發(fā)送一個(gè)通知，或者給所有在線和離線的用戶全發(fā)送，我們先演示如何給在線用戶發(fā)送一個(gè)廣播：

PPConnection.DEBUG_ENABLED = false; AccountManager accountManager; final ConnectionConfiguration connectionConfig = new ConnectionConfiguration( "192.168.1.78", Integer.parseInt("5222"), "csdn.shimiso.com"); // 允許自動(dòng)連接 connectionConfig.setReconnectionAllowed(true); connectionConfig.setSendPresence(true); Connection connection = new XMPPConnection(connectionConfig); try { connection.connect();// 開(kāi)啟連接 accountManager = connection.getAccountManager();// 獲取賬戶管理類 } catch (XMPPException e) { throw new IllegalStateException(e); } connection.login("admin", "admin","SmackTest3"); Message newmsg = new Message(); newmsg.setTo("shimiso@csdn.shimiso.com"); newmsg.setSubject("重要通知"); newmsg.setBody("今天下午2點(diǎn)60分有會(huì)！"); newmsg.setType(Message.Type.headline);// normal支持離線 connection.sendPacket(newmsg); connection.disconnect();

運(yùn)行結(jié)果：

將參數(shù)設(shè)置為Message.Type.normal即可支持離線廣播，openfire系統(tǒng)會(huì)自動(dòng)判斷該用戶是否在線，如果在線就直接發(fā)送出去，如果不在線則將信息存入ofoffline表，現(xiàn)在我將shimiso用戶退出登錄，再給它發(fā)消息，我們可以進(jìn)入openfire庫(kù)的ofoffline表中，非常清楚看到里面躺著一條離線消息記錄是發(fā)給shimiso這個(gè)用戶的

（4）那么我們?nèi)绾巫宻himiso這個(gè)用戶一登陸就取到離線消息呢？請(qǐng)看如下代碼

PPConnection.DEBUG_ENABLED = false; AccountManager accountManager; final ConnectionConfiguration connectionConfig = new ConnectionConfiguration( "192.168.1.78", Integer.parseInt("5222"), "csdn.shimiso.com"); // 允許自動(dòng)連接 connectionConfig.setReconnectionAllowed(true); connectionConfig.setSendPresence(false);//不要告訴服務(wù)器自己的狀態(tài) Connection connection = new XMPPConnection(connectionConfig); try { connection.connect();// 開(kāi)啟連接 accountManager = connection.getAccountManager();// 獲取賬戶管理類 } catch (XMPPException e) { throw new IllegalStateException(e); } connection.login("shimiso", "123","SmackTest"); OfflineMessageManager offlineManager = new OfflineMessageManager( connection); try { Iterator<org.jivesoftware.smack.packet.Message> it = offlineManager .getMessages(); System.out.println(offlineManager.supportsFlexibleRetrieval()); System.out.println("離線消息數(shù)量: " + offlineManager.getMessageCount()); Map<String, ArrayList<Message>> offlineMsgs = new HashMap<String, ArrayList<Message>>(); while (it.hasNext()) { org.jivesoftware.smack.packet.Message message = it.next(); System.out .println("收到離線消息, Received from 【" + message.getFrom() + "】 message: " + message.getBody()); String fromUser = message.getFrom().split("/")[0]; if (offlineMsgs.containsKey(fromUser)) { offlineMsgs.get(fromUser).add(message); } else { ArrayList<Message> temp = new ArrayList<Message>(); temp.add(message); offlineMsgs.put(fromUser, temp); } } // 在這里進(jìn)行處理離線消息集合...... Set<String> keys = offlineMsgs.keySet(); Iterator<String> offIt = keys.iterator(); while (offIt.hasNext()) { String key = offIt.next(); ArrayList<Message> ms = offlineMsgs.get(key); for (int i = 0; i < ms.size(); i++) { System.out.println("-->" + ms.get(i)); } } offlineManager.deleteMessages(); } catch (Exception e) { e.printStackTrace(); } offlineManager.deleteMessages();//刪除所有離線消息 Presence presence = new Presence(Presence.Type.available);nnection.sendPacket(presence);//上線了nnection.disconnect();//關(guān)閉連接

運(yùn)行結(jié)果：

這里我們需要特別當(dāng)心的是先不要告訴openfire服務(wù)器你上線了，否則永遠(yuǎn)也拿不到離線消息，用下面老外的話將就是在你上線之前去獲取離線消息，這么設(shè)計(jì)是很有道理的。

The OfflineMessageManager helps manage offline messages even before the user has sent an available presence. When a user asks for his offline messages before sending an available presence then the server will not send a flood with all the offline messages when the user becomes online. The server will not send a flood with all the offline messages to the session that made the offline messages request or to any other session used by the user that becomes online.

同時(shí)拿到離線消息以后刪除離線消息offlineManager.deleteMessages();，同是通知服務(wù)器自己上線了。

（5）下面我們來(lái)看看如何來(lái)發(fā)送文件

PPConnection.DEBUG_ENABLED = false; AccountManager accountManager; final ConnectionConfiguration connectionConfig = new ConnectionConfiguration( "192.168.1.78", Integer.parseInt("5222"), "csdn.shimiso.com"); // 允許自動(dòng)連接 connectionConfig.setReconnectionAllowed(true); connectionConfig.setSendPresence(true); Connection connection = new XMPPConnection(connectionConfig); try { connection.connect();// 開(kāi)啟連接 accountManager = connection.getAccountManager();// 獲取賬戶管理類 } catch (XMPPException e) { throw new IllegalStateException(e); } connection.login("admin", "admin","Rooyee"); Presence pre = connection.getRoster().getPresence("shimiso@csdn.shimiso.com"); System.out.println(pre); if (pre.getType() != Presence.Type.unavailable) { // 創(chuàng)建文件傳輸管理器 FileTransferManager manager = new FileTransferManager(connection); // 創(chuàng)建輸出的文件傳輸 OutgoingFileTransfer transfer = manager .createOutgoingFileTransfer(pre.getFrom()); // 發(fā)送文件 transfer.sendFile(new File("E:\\Chrysanthemum.jpg"), "圖片"); while (!transfer.isDone()) { if (transfer.getStatus() == FileTransfer.Status.in_progress) { // 可以調(diào)用transfer.getProgress();獲得傳輸?shù)倪M(jìn)度　 System.out.println(transfer.getStatus()); System.out.println(transfer.getProgress()); System.out.println(transfer.isDone()); } } }

運(yùn)行結(jié)果：

在這里我們需要特別注意的是，跨資源是無(wú)法發(fā)送文件的，看connection.login("admin", "admin","Rooyee");這個(gè)代碼就明白了，必須是“域名和資源名”完全相同的兩個(gè)用戶才可以互發(fā)文件，否則永遠(yuǎn)都沒(méi)反應(yīng)，如果不清楚自己所用的客戶端的資源名，可以借助前面提到的SmackDebug工具查看往返信息完整報(bào)文，在to和from中一定可以看到。

如果我們自己要寫文件接收例子的話，參考代碼如下：

FileTransferManager transfer = new FileTransferManager(connection); transfer.addFileTransferListener(new RecFileTransferListener()); public class RecFileTransferListener implements FileTransferListener { public String getFileType(String fileFullName) { if (fileFullName.contains(".")) { return "." + fileFullName.split("//.")[1]; } else { return fileFullName; } } @Override public void fileTransferRequest(FileTransferRequest request) { System.out.println("接收文件開(kāi)始....."); final IncomingFileTransfer inTransfer = request.accept(); final String fileName = request.getFileName(); long length = request.getFileSize(); final String fromUser = request.getRequestor().split("/")[0]; System.out.println("文件大小:" + length + " " + request.getRequestor()); System.out.println("" + request.getMimeType()); try { JFileChooser chooser = new JFileChooser(); chooser.setCurrentDirectory(new File(".")); int result = chooser.showOpenDialog(null); if (result == JFileChooser.APPROVE_OPTION) { final File file = chooser.getSelectedFile(); System.out.println(file.getAbsolutePath()); new Thread() { public void run() { try { System.out.println("接受文件: " + fileName); inTransfer .recieveFile(new File(file .getAbsolutePath() + getFileType(fileName))); Message message = new Message(); message.setFrom(fromUser); message.setProperty("REC_SIGN", "SUCCESS"); message.setBody("[" + fromUser + "]發(fā)送文件: " + fileName + "/r/n" + "存儲(chǔ)位置: " + file.getAbsolutePath() + getFileType(fileName)); if (Client.isChatExist(fromUser)) { Client.getChatRoom(fromUser) .messageReceiveHandler(message); } else { ChatFrameThread cft = new ChatFrameThread( fromUser, message); cft.start(); } } catch (Exception e2) { e2.printStackTrace(); } } }.start(); } else { System.out.println("拒絕接受文件: " + fileName); request.reject(); Message message = new Message(); message.setFrom(fromUser); message.setBody("拒絕" + fromUser + "發(fā)送文件: " + fileName); message.setProperty("REC_SIGN", "REJECT"); if (Client.isChatExist(fromUser)) { Client.getChatRoom(fromUser).messageReceiveHandler(message); } else { ChatFrameThread cft = new ChatFrameThread(fromUser, message); cft.start(); } } /* * InputStream in = inTransfer.recieveFile(); * * String fileName = "r"+inTransfer.getFileName(); * * OutputStream out = new FileOutputStream(new * File("d:/receive/"+fileName)); byte[] b = new byte[512]; * while(in.read(b) != -1) { out.write(b); out.flush(); } * * in.close(); out.close(); */ } catch (Exception e) { e.printStackTrace(); } System.out.println("接收文件結(jié)束....."); }}

（6）?用戶列表

** * 返回所有組信息 <RosterGroup> * * @return List(RosterGroup) */ public static List<RosterGroup> getGroups(Roster roster) { List<RosterGroup> groupsList = new ArrayList<RosterGroup>(); Collection<RosterGroup> rosterGroup = roster.getGroups(); Iterator<RosterGroup> i = rosterGroup.iterator(); while (i.hasNext()) groupsList.add(i.next()); return groupsList; } /** * 返回相應(yīng)(groupName)組里的所有用戶<RosterEntry> * * @return List(RosterEntry) */ public static List<RosterEntry> getEntriesByGroup(Roster roster, String groupName) { List<RosterEntry> EntriesList = new ArrayList<RosterEntry>(); RosterGroup rosterGroup = roster.getGroup(groupName); Collection<RosterEntry> rosterEntry = rosterGroup.getEntries(); Iterator<RosterEntry> i = rosterEntry.iterator(); while (i.hasNext()) EntriesList.add(i.next()); return EntriesList; } /** * 返回所有用戶信息 <RosterEntry> * * @return List(RosterEntry) */ public static List<RosterEntry> getAllEntries(Roster roster) { List<RosterEntry> EntriesList = new ArrayList<RosterEntry>(); Collection<RosterEntry> rosterEntry = roster.getEntries(); Iterator<RosterEntry> i = rosterEntry.iterator(); while (i.hasNext()) EntriesList.add(i.next()); return EntriesList; }

（7）用戶頭像的獲取，?使用VCard，很強(qiáng)大，具體自己看API吧，?可以看看VCard傳回來(lái)XML的組成，含有很多信息的

** * 獲取用戶的vcard信息 * @param connection * @param user * @return * @throws XMPPException */ public static VCard getUserVCard(XMPPConnection connection, String user) throws XMPPException { VCard vcard = new VCard(); vcard.load(connection, user); return vcard; } /** * 獲取用戶頭像信息 */ public static ImageIcon getUserImage(XMPPConnection connection, String user) { ImageIcon ic = null; try { System.out.println("獲取用戶頭像信息: "+user); VCard vcard = new VCard(); vcard.load(connection, user); if(vcard == null || vcard.getAvatar() == null) { return null; } ByteArrayInputStream bais = new ByteArrayInputStream( vcard.getAvatar()); Image image = ImageIO.read(bais); ic = new ImageIcon(image); System.out.println("圖片大小:"+ic.getIconHeight()+" "+ic.getIconWidth()); } catch (Exception e) { e.printStackTrace(); } return ic; }

（8）組操作和用戶分組操作

** * 添加一個(gè)組 */ public static boolean addGroup(Roster roster,String groupName) { try { roster.createGroup(groupName); return true; } catch (Exception e) { e.printStackTrace(); return false; } } /** * 刪除一個(gè)組 */ public static boolean removeGroup(Roster roster,String groupName) { return false; } /** * 添加一個(gè)好友 無(wú)分組 */ public static boolean addUser(Roster roster,String userName,String name) { try { roster.createEntry(userName, name, null); return true; } catch (Exception e) { e.printStackTrace(); return false; } } /** * 添加一個(gè)好友到分組 * @param roster * @param userName * @param name * @return */ public static boolean addUser(Roster roster,String userName,String name,String groupName) { try { roster.createEntry(userName, name,new String[]{ groupName}); return true; } catch (Exception e) { e.printStackTrace(); return false; } } /** * 刪除一個(gè)好友 * @param roster * @param userName * @return */ public static boolean removeUser(Roster roster,String userName) { try { if(userName.contains("@")) { userName = userName.split("@")[0]; } RosterEntry entry = roster.getEntry(userName); System.out.println("刪除好友:"+userName); System.out.println("User: "+(roster.getEntry(userName) == null)); roster.removeEntry(entry); return true; } catch (Exception e) { e.printStackTrace(); return false; } }

（9）用戶查詢

public static List<UserBean> searchUsers(XMPPConnection connection,String serverDomain,String userName) throws XMPPException { List<UserBean> results = new ArrayList<UserBean>(); System.out.println("查詢開(kāi)始..............."+connection.getHost()+connection.getServiceName()); UserSearchManager usm = new UserSearchManager(connection); Form searchForm = usm.getSearchForm(serverDomain);Form answerForm = searchForm.createAnswerForm();answerForm.setAnswer("Username", true);answerForm.setAnswer("search", userName);ReportedData data = usm.getSearchResults(answerForm, serverDomain); Iterator<Row> it = data.getRows(); Row row = null; UserBean user = null; while(it.hasNext()) { user = new UserBean(); row = it.next(); user.setUserName(row.getValues("Username").next().toString()); user.setName(row.getValues("Name").next().toString()); user.setEmail(row.getValues("Email").next().toString()); System.out.println(row.getValues("Username").next()); System.out.println(row.getValues("Name").next()); System.out.println(row.getValues("Email").next()); results.add(user); //若存在，則有返回,UserName一定非空，其他兩個(gè)若是有設(shè)，一定非空 } return results; }

（10）修改自身狀態(tài)，?包括上線，隱身，對(duì)某人隱身，對(duì)某人上線

ublic static void updateStateToAvailable(XMPPConnection connection) { Presence presence = new Presence(Presence.Type.available);nnection.sendPacket(presence); public static void updateStateToUnAvailable(XMPPConnection connection) { Presence presence = new Presence(Presence.Type.unavailable);nnection.sendPacket(presence);} public static void updateStateToUnAvailableToSomeone(XMPPConnection connection,String userName) { Presence presence = new Presence(Presence.Type.unavailable); presence.setTo(userName);nnection.sendPacket(presence); } public static void updateStateToAvailableToSomeone(XMPPConnection connection,String userName) { Presence presence = new Presence(Presence.Type.available); presence.setTo(userName);nnection.sendPacket(presence); }

（11）心情修改

** * 修改心情 * @param connection * @param status */ public static void changeStateMessage(XMPPConnection connection,String status) { Presence presence = new Presence(Presence.Type.available); presence.setStatus(status); connection.sendPacket(presence); }

（12）修改用戶頭像，?有點(diǎn)麻煩，主要是讀入圖片文件，編碼，傳輸之

public static void changeImage(XMPPConnection connection,File f) throws XMPPException, IOException{ VCard vcard = new VCard(); vcard.load(connection); byte[] bytes; bytes = getFileBytes(f); String encodedImage = StringUtils.encodeBase64(bytes); vcard.setAvatar(bytes, encodedImage); vcard.setEncodedImage(encodedImage); vcard.setField("PHOTO", "<TYPE>image/jpg</TYPE><BINVAL>" + encodedImage + "</BINVAL>", true); ByteArrayInputStream bais = new ByteArrayInputStream( vcard.getAvatar()); Image image = ImageIO.read(bais); ImageIcon ic = new ImageIcon(image); vcard.save(connection); } private static byte[] getFileBytes(File file) throws IOException {BufferedInputStream bis = null;try {bis = new BufferedInputStream(new FileInputStream(file));int bytes = (int) file.length();byte[] buffer = new byte[bytes];int readBytes = bis.read(buffer);if (readBytes != buffer.length) {throw new IOException("Entire file not read");}return buffer;} finally {if (bis != null) {bis.close();}} }

（13）用戶狀態(tài)的監(jiān)聽(tīng)，?即對(duì)方改變頭像，狀態(tài)，心情時(shí)，更新自己用戶列表，其實(shí)這里已經(jīng)有?smack?實(shí)現(xiàn)的監(jiān)聽(tīng)器

nal Roster roster = Client.getRoster(); roster.addRosterListener( new RosterListener() { @Override public void entriesAdded(Collection<String> arg0) { // TODO Auto-generated method stub System.out.println("--------EE:"+"entriesAdded"); } @Override public void entriesDeleted(Collection<String> arg0) { // TODO Auto-generated method stub System.out.println("--------EE:"+"entriesDeleted"); } @Override public void entriesUpdated(Collection<String> arg0) { // TODO Auto-generated method stub System.out.println("--------EE:"+"entriesUpdated"); } @Override public void presenceChanged(Presence arg0) { // TODO Auto-generated method stub System.out.println("--------EE:"+"presenceChanged"); } });

?

?

?

至此，有關(guān)openfire和smack的安裝部署使用基本代碼調(diào)試講解完畢，本集源碼容我稍作整理后再更新出來(lái)，請(qǐng)大家保持關(guān)注，同時(shí)下面會(huì)我們進(jìn)入課程的重點(diǎn)環(huán)節(jié)，包括

如何在Openfire服務(wù)器上開(kāi)發(fā)一款A(yù)ndroid端的聊天軟件。。。

如何在openfire上二次開(kāi)發(fā)，如何在在web和android上接入IM模塊。。。

如何在Spark基礎(chǔ)二次開(kāi)發(fā)基于java swing的PC客戶端。。。

結(jié)合我之前講的?Android端服務(wù)器推送技術(shù)原理分析及XMPP簡(jiǎn)單的使用?由淺入深的對(duì)apache MINA，XMPP協(xié)議，以及socket底層等一些難點(diǎn)進(jìn)行討論剖析。。。

Openfire作為一款優(yōu)秀的XMPP開(kāi)源服務(wù)器，整合及時(shí)通訊，視頻，語(yǔ)音，會(huì)議室等多種服務(wù)，如何更好的讓它集成到現(xiàn)有的系統(tǒng)中去才是我們研究的最終價(jià)值，否則一切都是空談，本教程結(jié)合實(shí)戰(zhàn)和理論，為大家提供提供一個(gè)共同研究和學(xué)習(xí)的平臺(tái)，歡迎有識(shí)之士加入我們的技術(shù)交流群:173711587，?共同探討Java開(kāi)發(fā)那些事兒

放些圖以饗讀者。。。

??

總結(jié)

以上是生活随笔為你收集整理的基于openfire+smack的Android、消息推送服务的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。