前言

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

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

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

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

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

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

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

?

1.什么是XMPP

XMPP?(Extensible?Messaging?and?Presence?Protocol)，簡單的來講，它就是一個發(fā)送接收處理消息的協(xié)議，但是這個協(xié)議發(fā)送的消息，既不是二進制的東東也不是字符串，而是XML。正是因為使用了XML作為消息傳遞的中介，Extensible?才談的上。XMPP的前身是Jabber，一個開源形式組織產(chǎn)生的網(wǎng)絡(luò)即時通信協(xié)議。XMPP目前被IETF國際標準組織完成了標準化工作。

2.IM

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

3.Spark,smack和Openfire

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

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

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

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

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

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

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

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

4.安裝Openfire3.8.1

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

語言選擇簡體中文，見下圖：

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

????

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

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

這個頁面的Domain默認為機器名，請改為一開始設(shè)置的域名，例如csdn.shimiso.com，接著點Continue(繼續(xù)):

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

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

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

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

進入用戶/組新增一個用戶。

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

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

????

聊天演示：

?

從上面的聊天記錄我們發(fā)現(xiàn)所有的用戶id全稱都是：用戶名@域名/資源名，這個就是我們在XMPP協(xié)議中通常說說的JID，即jabber id，它是一個xmpp協(xié)議帳號系統(tǒng)的通稱，后面我們在使用smack編程庫調(diào)試接口時會經(jīng)常用到這個參數(shù)。

?

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

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

下面我們寫幾個程序小例子測試一下。

（1）登錄操作

PPConnection.DEBUG_ENABLED = true; AccountManager accountManager; final ConnectionConfiguration connectionConfig = new ConnectionConfiguration( "192.168.1.78", Integer.parseInt("5222"), "csdn.shimiso.com"); // 允許自動連接 connectionConfig.setReconnectionAllowed(true); connectionConfig.setSendPresence(true); Connection connection = new XMPPConnection(connectionConfig); try { connection.connect();// 開啟連接 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!");

運行結(jié)果：

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

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

PPConnection.DEBUG_ENABLED = true; AccountManager accountManager; final ConnectionConfiguration connectionConfig = new ConnectionConfiguration( "192.168.1.78", Integer.parseInt("5222"), "csdn.shimiso.com"); // 允許自動連接 connectionConfig.setReconnectionAllowed(true); connectionConfig.setSendPresence(true); Connection connection = new XMPPConnection(connectionConfig); try { connection.connect();// 開啟連接 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); }

運行結(jié)果：

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

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

PPConnection.DEBUG_ENABLED = false; AccountManager accountManager; final ConnectionConfiguration connectionConfig = new ConnectionConfiguration( "192.168.1.78", Integer.parseInt("5222"), "csdn.shimiso.com"); // 允許自動連接 connectionConfig.setReconnectionAllowed(true); connectionConfig.setSendPresence(true); Connection connection = new XMPPConnection(connectionConfig); try { connection.connect();// 開啟連接 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點60分有會！"); newmsg.setType(Message.Type.headline);// normal支持離線 connection.sendPacket(newmsg); connection.disconnect();

運行結(jié)果：

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

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

PPConnection.DEBUG_ENABLED = false; AccountManager accountManager; final ConnectionConfiguration connectionConfig = new ConnectionConfiguration( "192.168.1.78", Integer.parseInt("5222"), "csdn.shimiso.com"); // 允許自動連接 connectionConfig.setReconnectionAllowed(true); connectionConfig.setSendPresence(false);//不要告訴服務(wù)器自己的狀態(tài) Connection connection = new XMPPConnection(connectionConfig); try { connection.connect();// 開啟連接 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); } } // 在這里進行處理離線消息集合...... 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)閉連接

運行結(jié)果：

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

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.

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

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

PPConnection.DEBUG_ENABLED = false; AccountManager accountManager; final ConnectionConfiguration connectionConfig = new ConnectionConfiguration( "192.168.1.78", Integer.parseInt("5222"), "csdn.shimiso.com"); // 允許自動連接 connectionConfig.setReconnectionAllowed(true); connectionConfig.setSendPresence(true); Connection connection = new XMPPConnection(connectionConfig); try { connection.connect();// 開啟連接 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度　 System.out.println(transfer.getStatus()); System.out.println(transfer.getProgress()); System.out.println(transfer.isDone()); } } }

運行結(jié)果：

在這里我們需要特別注意的是，跨資源是無法發(fā)送文件的，看connection.login("admin", "admin","Rooyee");這個代碼就明白了，必須是“域名和資源名”完全相同的兩個用戶才可以互發(fā)文件，否則永遠都沒反應(yīng)，如果不清楚自己所用的客戶端的資源名，可以借助前面提到的SmackDebug工具查看往返信息完整報文，在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("接收文件開始....."); 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" + "存儲位置: " + 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，很強大，具體自己看API吧，?可以看看VCard傳回來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）組操作和用戶分組操作

** * 添加一個組 */ public static boolean addGroup(Roster roster,String groupName) { try { roster.createGroup(groupName); return true; } catch (Exception e) { e.printStackTrace(); return false; } } /** * 刪除一個組 */ public static boolean removeGroup(Roster roster,String groupName) { return false; } /** * 添加一個好友 無分組 */ 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; } } /** * 添加一個好友到分組 * @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; } } /** * 刪除一個好友 * @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("查詢開始..............."+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一定非空，其他兩個若是有設(shè)，一定非空 } return results; }

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

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）修改用戶頭像，?有點麻煩，主要是讀入圖片文件，編碼，傳輸之

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ài)，心情時，更新自己用戶列表，其實這里已經(jīng)有?smack?實現(xiàn)的監(jiān)聽器

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)試講解完畢，本集源碼容我稍作整理后再更新出來，請大家保持關(guān)注，同時下面會我們進入課程的重點環(huán)節(jié)，包括

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

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

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

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

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

放些圖以饗讀者。。。

??

總結(jié)

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

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