基於openfire+smack的Android、Web、PC開發(一)

時間  2019-11-10
標籤 基於 openfire+smack openfire smack android web 開發 欄目 Android 简体版
原文   原文鏈接

前言java

Java領域的即時通訊的解決方案能夠考慮openfire+spark+smack。固然也有其餘的選擇。mysql

Openfire是基於Jabber協議(XMPP)實現的即時通訊服務器端版本，目前建議使用3.8.1版本，這個版本是當前最新的版本，並且網上能夠找到下載的源代碼。android

即時通訊客戶端可以使用spark2.6.3,這個版本是目前最新的release版本，通過測試發現上一版本在視頻支持,msn網關支持上可能有問題，因此選擇openfire3.8.1+spark2.6.3是最合適的選擇。web

Smack是即時通訊客戶端編程庫，目前我已測統統過jsp使用smack的API向openfire註冊用戶發送消息，而且能夠經過監聽器得到此用戶的應答消息。sql

經過smack向msn用戶和QQ用戶,gtalk用戶發送消息應該也能夠實現，關於向gtalk用戶發送消息的例子較多。這個留待之後研究。至少目前能夠經過程序向spark發消息了。對於局域網內部應用足以解決系統與用戶交互的問題，甚至能夠作自動應答機器人。數據庫

Spark支持聊天，語音，視頻，會議，文件收發，截屏，鏈接msn等功能。apache

同時在Android移動端和Web端也有相應的編程庫支持，在後面的章節會爲你們逐步更新介紹，接下來咱們首先要對幾個重點的技術環節作些必要的講解。編程

1.什麼是XMPPapi

XMPP(Extensible Messaging and Presence Protocol)，簡單的來說，它就是一個發送接收處理消息的協議，可是這個協議發送的消息，既不是二進制的東東也不是字符串，而是XML。正是由於使用了XML做爲消息傳遞的中介，Extensible 才談的上。XMPP的前身是Jabber，一個開源形式組織產生的網絡即時通訊協議。XMPP目前被IETF國際標準組織完成了標準化工做。服務器

2.IM

Instant Messenger，及時通訊軟件，就是你們使用的QQ、MSN Messenger和Gtalk等等。其中Gtalk 就是基於XMPP 協議的一個實現，其餘的則不是。當前IM 幾乎做爲每一個上網者必然使用的工具，在國外的大型企業中有一些企業級的IM應用，可是其商業價值還沒徹底發揮出來。設想既然XMPP 協議是一個公開的協議，那麼每一個企業均可以利用它來開發適合自己企業工做，提升自身生產效率的IM；甚至，你還能夠在網絡遊戲中集成這種通訊軟件，不但讓你能夠邊遊戲邊聊天，也能夠開發出適合遊戲自己的IM 應用，好比說一些遊戲關鍵場景提醒功能，團隊語音交流等等均可以基於IM來實現。

3.Spark,smack和Openfire

開源界老是有許多有趣的東東，這三個合起來就是一個完整的XMPP IM 實現。包括服務器端——Openfire，客戶端——Spark，XMPP 傳輸協議的實現——Smack（記住，XMPP是一個協議，協議是須要實現的，Smack起到的就是這樣的一個做用）。三者都是基於Java 語言的實現。

Spark 提供了客戶端一個基本的實現，並提出了一個很好的插件架構，這對於開發者來講不能不說是一個福音。我強烈建議基於插件方式來實現你新增長的功能，而不是去改它的源代碼，這樣有利於你項目架構，把原始項目的影響降到最低。

Openfire 是基於XMPP 協議的IM 的服務器端的一個實現，雖然當兩個用戶鏈接後，能夠經過點對點的方式來發送消息，可是用戶仍是須要鏈接到服務器來獲取一些鏈接信息和通訊信息的，因此服務器端是必需要實現的。Openfire 也提供了一些基本功能，但真的很基本的！慶幸的是，它也提供插件的擴展，像Spark 同樣，一樣強烈建議使用插件擴展的方式來增長新的功能，而不是修改人家的源代碼。

Smack 是一個XMPP 協議的Java 實現，提供一套可擴展的API，不過有些時候，你仍是不得不使用本身定製發送的XML 文件內容的方式來實現本身的功能

下圖展現了三者之間的關係：

Spark 提供了客戶端一個基本的實現，並提出了一個很好的插件架構，這對於開發者來講不能不說是一個福音。我強烈建議基於插件方式來實現你新增長的功能，而不是去改它的源代碼，這樣有利於你項目架構，把原始項目的影響降到最低。

Openfire 是基於XMPP 協議的IM 的服務器端的一個實現，雖然當兩個用戶鏈接後，能夠經過點對點的方式來發送消息，可是用戶仍是須要鏈接到服務器來獲取一些鏈接信息和通訊信息的，因此服務器端是必需要實現的。Openfire 也提供了一些基本功能，但真的很基本的！慶幸的是，它也提供插件的擴展，像Spark 同樣。

Smack 是一個XMPP 協議的Java 實現，提供一套可擴展的API，不過有些時候，你仍是不得不使用本身定製發送的XML 文件內容的方式來實現本身的功能。

4.安裝Openfire3.8.1

使用openfire須要配置機器的域名。若是局域網內沒有安裝域服務器，則須要手工爲機器配置域名，打開C:\WINDOWS\system32\drivers\etc\hosts文件，增長一新行： 127.0.0.1 csdn.shimiso.com （用戶根據本身的須要可配置稱別的名字，但最好符合帶.的域名格式） 其餘機器使用域名訪問openfire,也須要在C:\WINDOWS\system32\drivers\etc\hosts中指定bzwang.tzsoft.com對應的ip地址，假設安裝openfire的主機IP爲192.168.1.10,則hosts文件中應增長一新行: 192.168.1.10 csdn.shimiso.com 經過這種方式指定主機域名，建議安裝openfire的機器配置靜態ip地址以避免ip發生改變。

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

後續按照提示安裝，點擊完成啓動openfire，最後出現下面的界面：

點」Launch Admin」,出現下面的頁面，頁面鏈接爲http://127.0.0.1:9090/setup/index.jsp

語種選擇中文（簡體），點」Continue」:（下面的頁面若是出現英文，請刷新一下頁面或者從新點Launch Admin）

這個頁面的Domain默認爲機器名，請改成一開始設置的域名，例如csdn.shimiso.com，接着點Continue(繼續):

這個頁面中第一個選項，即標準數據庫鏈接，不要選擇嵌入的數據庫( Embedded Database,嵌入的數據庫是hsqldb數據庫，生產環境不要選擇此選項),而後點」繼續」:

這裏我用的是mysql數據庫，按官方要求最好是5.0以上，確保有個名字叫openfire的庫存在，配好後點繼續

這個頁面是配置是否使用LDAP,咱們如今不配置LDAP,因此選擇 Default默認便可，點繼續:

這裏填寫郵箱和確認密碼後直接點繼續：

等待大約30秒左右，到此安裝和配置操做所有完成。打開http://127.0.0.1:9090/login.jsp登陸管理頁面

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

5.客戶端配置和調試

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

聊天演示：

從上面的聊天記錄咱們發現全部的用戶id全稱都是：用戶名@域名/資源名，這個就是咱們在XMPP協議中一般說說的JID，即jabber id，它是一個xmpp協議賬號系統的通稱，後面咱們在使用smack編程庫調試接口時會常常用到這個參數。

6.使用Smack編程庫進行代碼功能調試

關於Smack編程庫，前面咱們提到，它是面向Java端的api，主要在PC上使用，利用它咱們能夠 向openfire服務器註冊用戶，發送消息，而且能夠經過監聽器得到此用戶的應答消息，以及構建聊天室，分組，我的通信錄等等。

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

（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!");

運行結果：

在login中一共有三個參數，登陸名，密碼，資源名，可能有人不明白資源名究竟是什麼意思，其實就是客戶端的來源，客戶端的名稱，若是不寫它默認就叫smack，若是你用相同的帳戶不一樣的資源名和同一我的發三條消息，那將會彈出三個窗口，而不是一個窗口。 同時smack還爲咱們提供了很是好的調試工具Smack Debug，利用該工具咱們能夠準確的捕獲詳細的往返報文信息。

（2）下面咱們繼續寫個聊天的例子： 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);
}

運行結果：

這裏咱們用Scanner來捕捉用戶在控制檯的鍵盤操做，將信息發出，同時建立了一個MessageListener監聽，在其中強制實現processMessage方法便可捕獲發回的信息，在初次使用上仍是較爲容易上手的，咱們只要細心查看API便可逐步深刻下去。

（3）除了聊天之外咱們常常還能想到就是廣播，須要給全部在線的用戶發送一個通知，或者給全部在線和離線的用戶全發送，咱們先演示如何給在線用戶發送一個廣播： 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();

運行結果：

將參數設置爲Message.Type.normal便可支持離線廣播，openfire系統會自動判斷該用戶是否在線，若是在線就直接發送出去，若是不在線則將信息存入ofoffline表，如今我將shimiso用戶退出登陸，再給它發消息，咱們能夠進入openfire庫的ofoffline表中，很是清楚看到裏面躺着一條離線消息記錄是發給shimiso這個用戶的

（4）那麼咱們如何讓shimiso這個用戶一登錄就取到離線消息呢？請看以下代碼 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);//不要告訴服務器本身的狀態
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("離線消息數量: " + 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();//關閉鏈接

運行結果：

這裏咱們須要特別小心的是先不要告訴openfire服務器你上線了，不然永遠也拿不到離線消息，用下面老外的話將就是在你上線以前去獲取離線消息，這麼設計是頗有道理的。

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();，同是通知服務器本身上線了。

（5）下面咱們來看看如何來發送文件 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) {
    // 建立文件傳輸管理器
    FileTransferManager manager = new FileTransferManager(connection);
    // 建立輸出的文件傳輸
    OutgoingFileTransfer transfer = manager
        .createOutgoingFileTransfer(pre.getFrom());
    // 發送文件
    transfer.sendFile(new File("E:\\Chrysanthemum.jpg"), "圖片");
    while (!transfer.isDone()) {
      if (transfer.getStatus() == FileTransfer.Status.in_progress) {
        // 能夠調用transfer.getProgress();得到傳輸的進度　
        System.out.println(transfer.getStatus());
        System.out.println(transfer.getProgress());
        System.out.println(transfer.isDone());
      }
    }
  }

運行結果：

在這裏咱們須要特別注意的是，跨資源是沒法發送文件的，看connection.login("admin", "admin","Rooyee");這個代碼就明白了，必須是「域名和資源名」徹底相同的兩個用戶才能夠互發文件，不然永遠都沒反應，若是不清楚本身所用的客戶端的資源名，能夠藉助前面提到的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 + "]發送文件: "
              + 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 + "發送文件: " + 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("接收文件結束.....");

}

} （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; }

/**

  • 返回相應(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必定非空，其餘兩個如果有設，必定非空
 }
 
 return results;

} （10）修改自身狀態， 包括上線，隱身，對某人隱身，對某人上線 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）用戶狀態的監聽， 即對方改變頭像，狀態，心情時，更新本身用戶列表，其實這裏已經有smack實現的監聽器 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");
      }   
      
});

至此，有關openfire和smack的安裝部署使用基本代碼調試講解完畢，本集源碼容我稍做整理後再更新出來，請你們保持關注，同時下面會咱們進入課程的重點環節，包括

如何在Openfire服務器上開發一款Android端的聊天軟件。。。

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

如何在Spark基礎二次開發基於java swing的PC客戶端。。。

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

Openfire做爲一款優秀的XMPP開源服務器，整合及時通信，視頻，語音，會議室等多種服務，如何更好的讓它集成到現有的系統中去纔是咱們研究的最終價值，不然一切都是空談，本教程結合實戰和理論，爲你們提供提供一個共同研究和學習的平臺，歡迎有識之士加入咱們的技術交流羣:173711587， 共同探討Java開發那些事兒

放些圖以饗讀者。。。

相關文章
相關標籤/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公眾號
   歡迎關注本站公眾號,獲取更多信息
聯繫我們 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程