Android平台下基於XMPP的IM研究

由於項目需要做一個基於XMPP協議的Android通訊軟件。故開始研究XMPP

XMPP協議采用的是客戶端-服務器架構，所有從一個客戶端發到另一個客戶端的消息和數據都必須經過XMPP服務器轉發，而且支持服務器間DNS的路由，也就是說可以構建服務器集群，使不同的服務器下的客戶端也可以通信，XMPP的前身是一個開源組織制定的網絡通信協議——Jabber，XMPP的核心是在網絡上分片段發送XML流的協議，這個協議是XMPP的即時通訊指令的傳遞手段。

為了防止服務器間發送的數據被篡改或偷聽，XMPP服務器通信引入了TLS機制，使用TLS機制能實現數據的加密，從而保證了在數據傳輸過程種數據的安全。

一個XMPP實體的地址稱為Jabber Identifier或JID，作用類似於IP地址。一個合法的JID包括節點名,域名資源名，其格式為：jid=[node'@']domain['/'resource]

XMPP協議的命名空間：
jabber:iq:private   -- 私有數據存儲，用於本地用戶私人設置信息，比如用戶備注等。
jabber:iq:conference  -- 一般會議，用於多個用戶之間的信息共享
jabber:x:encrypted -- 加密的消息，用於發送加密消息
jabber:x:expire  -- 消息終止
jabber:iq:time  -- 客戶端時間
jabber:iq:auth  -- 簡單用戶認證，一般用於服務器之間或者服務器和客戶端之間的認證
jabber:x:roster  -- 內部花名冊
jabber:x:signed  -- 標記的在線狀態
jabber:iq:search -- 用戶數據庫查詢，用於向服務器發送查詢請求
jabber:iq:register -- 注冊請求，用於用戶注冊相關信息
jabber:x:iq:roster -- 花名冊管理
jabber:x:conference -- 會議邀請，用於向參加會議用戶發送開會通知
jabber:x:event  -- 消息事件
vcard-temp  -- 臨時的vCard,用於設置用戶的頭像以及昵稱等

在網上找了下，有開源的項目BEEM，開源的用於android的xmpp框架asmack，asmack是smack的android版本。現在開始學習smack

。Xmpp就是神馬東西，就不廢話了。首先在網上下一個Openfire和Spack，不知道這兩個是什麼東西，就直接google吧。安裝openfire需要mysql的支持，當然，Oracle，sqlserver肯定是可以的。還是先上圖吧： 

Openfire + Spark + MyXMPPP

1. import java.io.InputStreamReader;  
2. import java.util.Collection;  
3.   
4. import org.jivesoftware.smack.Chat;  
5. import org.jivesoftware.smack.ChatManager;  
6. import org.jivesoftware.smack.ChatManagerListener;  
7. import org.jivesoftware.smack.ConnectionConfiguration;  
8. import org.jivesoftware.smack.MessageListener;  
9. import org.jivesoftware.smack.PrivacyListManager;  
10. import org.jivesoftware.smack.Roster;  
11. import org.jivesoftware.smack.RosterEntry;  
12. import org.jivesoftware.smack.RosterGroup;  
13. import org.jivesoftware.smack.RosterListener;  
14. import org.jivesoftware.smack.XMPPConnection;  
15. import org.jivesoftware.smack.packet.Message;  
16. import org.jivesoftware.smack.packet.Presence;  
17.   
18. public class TestSmack {  
19.     public static void main(String[] args) {XMPPConnection.DEBUG_ENABLED = true;  
20.         //我的電腦IP:10.16.25.90   
21.         final ConnectionConfiguration connectionConfig = new ConnectionConfiguration("10.16.25.91", 5222, "");  
22.         connectionConfig.setSASLAuthenticationEnabled(false);  
23.                 try {  
24.                       
25.                     XMPPConnection connection = new XMPPConnection(connectionConfig);  
26.                     connection.connect();//連接   
27.                     connection.login("test", "test");//登陸   
28.                     System.out.println(connection.getUser());  
29.                     ChatManager chatmanager = connection.getChatManager();  
30.   
31.                     //新建一個會話   
32.                     Chat newChat = chatmanager.createChat("test3@pc2010102716", new MessageListener() {  
33.                         public void processMessage(Chat chat, Message message) {  
34.                             System.out.println("Received from 【" + message.getFrom() + "】 message: " + message.getBody());  
35.                         }  
36.                     });  
37.                       
38.                     // 監聽被動接收消息，或廣播消息監聽器   
39.                     chatmanager.addChatListener(new ChatManagerListener() {  
40.                         @Override  
41.                         public void chatCreated(Chat chat, boolean createdLocally) {  
42.                             chat.addMessageListener(new MessageListener() {  
43.                                 @Override  
44.                                 public void processMessage(Chat chat, Message message) {  
45.                                     System.out.println("Received from 【" + message.getFrom() + "】 message: " + message.getBody());  
46.                                 }  
47.                                       
48.                             });  
49.                         }  
50.                     });  
51.                     //發送消息   
52.                     newChat.sendMessage("我是菜鳥");  
53.                       
54.                     //獲取花名冊   
55.                     Roster roster = connection.getRoster();  
56.                     Collection<RosterEntry> entries = roster.getEntries();  
57.                     for(RosterEntry entry : entries) {  
58.                         System.out.print(entry.getName() + " - " + entry.getUser() + " - " + entry.getType() + " - " + entry.getGroups().size());  
59.                         Presence presence = roster.getPresence(entry.getUser());  
60.                         System.out.println(" - " + presence.getStatus() +" - "+ presence.getFrom());  
61.                     }  
62.                       
63.                     //添加花名冊監聽器，監聽好友狀態的改變。   
64.                     roster.addRosterListener(new RosterListener() {  
65.   
66.                         @Override  
67.                         public void entriesAdded(Collection<String> addresses) {  
68.                             System.out.println("entriesAdded");  
69.                         }  
70.   
71.                         @Override  
72.                         public void entriesUpdated(Collection<String> addresses) {  
73.                             System.out.println("entriesUpdated");  
74.                         }  
75.   
76.                         @Override  
77.                         public void entriesDeleted(Collection<String> addresses) {  
78.                             System.out.println("entriesDeleted");  
79.                         }  
80.   
81.                         @Override  
82.                         public void presenceChanged(Presence presence) {  
83.                             System.out.println("presenceChanged - >" + presence.getStatus());  
84.                         }  
85.                           
86.                     });  
87.                       
88.                     //創建組   
89. //                  /RosterGroup group = roster.createGroup("大學");   
90. //                  for(RosterEntry entry : entries) {   
91. //                      group.addEntry(entry);   
92. //                  }   
93.                     for(RosterGroup g : roster.getGroups()) {  
94.                         for(RosterEntry entry : g.getEntries()) {  
95.                             System.out.println("Group " +g.getName() +" >> " + entry.getName() + " - " + entry.getUser() + " - " + entry.getType() + " - " + entry.getGroups().size());  
96.                         }  
97.                     }  
98.                       
99.                     //發送消息   
100.                     BufferedReader cmdIn = new BufferedReader(new InputStreamReader(System.in));  
101.                     while(true) {  
102.                       try {  
103.                          String cmd = cmdIn.readLine();  
104.                          if("!q".equalsIgnoreCase(cmd)) {  
105.                              break;  
106.                          }  
107.                          newChat.sendMessage(cmd);  
108.                       }catch(Exception ex) {  
109.                       }  
110.                     }  
111.                     connection.disconnect();  
112.                     System.exit(0);  
113.                 } catch (Exception e) {  
114.                     e.printStackTrace();  
115.                 }  
116.     }  
117. }  

以上代碼如果在一般的Java Project上運行需要加入smack.jar 和klmx2.jar,如果是Android Project，基本代碼不需改變只需將其放入onCreate(...)方法下即可，需要加入asmack.jar包.

1、ConnectionConfiguration
 作為用於與XMPP服務建立連接的配置。它能配置；連接是否使用TLS，SASL加密。
 包含內嵌類：ConnectionConfiguration.SecurityMode

2、XMPPConnection.
 XMPPConnection這個類用來連接XMPP服務.
 可以使用connect()方法建立與服務器的連接。disconnect()方法斷開與服務器的連接.
 在創建連接前可以使用XMPPConnection.DEBUG_ENABLED = true; 使開發過程中可以彈出一個GUI窗口，用於顯示我們的連接與發送Packet的信息。

3、ChatManager
 用於監控當前所有chat。可以使用createChat(String userJID, MessageListener listener)創建一個聊天。
 
4、Chat
 Chat用於監控兩個用戶間的一系列message。使用addMessageListener(MessageListener listener)當有任何消息到達時將會觸發listener的processMessage(Chat chat, Message message)
方法.
 我們可以使用sendMessage()發送消息,這個方法有兩個重載方法，一種類類型的參數時String類型，另一種則是傳入Message對象(後面介紹)。
 那麼有這樣一種情況，當別人主動跟我們建立連接發送消息，或者系統發送消息時我們怎麼才能接收消息呢？
    我現在是這樣操作的：
 chatmanager.addChatListener(new ChatManagerListener() {
  @Override
  public void chatCreated(Chat chat, boolean createdLocally) {
   chat.addMessageListener(new MessageListener() {
    @Override
    public void processMessage(Chat chat, Message message) {
     System.out.println("Received message: " + message.getBody());
    }
         
   });
  }
 });
 
5、Message
 Message用於表示一個消息包(可以用調試工具看到發送包和接收包的具體內容)。它有以下多種類型。
  Message.Type.NORMAL -- （默認）文本消息（比如郵件）
  Message.Type.CHAT -- 典型的短消息，如QQ聊天的一行一行顯示的消息
  Message.Type.GROUP_CHAT -- 群聊消息
  Message.Type.HEADLINE -- 滾動顯示的消息
  Message.TYPE.ERROR -- 錯誤的消息
 Message有兩個內部類：
  Message.Body -- 表示消息體
  Message.Type -- 表示消息類型
 
6、Roster
 表示存儲了很多RosterEntry的一個花名冊.為了易於管理，花名冊的項被分貝到了各個group中.
 當建立與XMPP服務的連接後可以使用connection.getRoster()獲取Roster對象。
 別的用戶可以使用一個訂閱請求(相當於QQ加好友)嘗試訂閱目的用戶。可以使用枚舉類型Roster.SubscriptionMode的值處理這些請求：
 accept_all: 接收所有訂閱請求
 reject_all：拒絕所有訂閱請求
 manual：  手工處理訂閱請求
 
 創建組：RosterGroup group = roster.createGroup("大學");
 向組中添加RosterEntry對象: group.addEntry(entry);
 
7、RosterEntry
 表示Roster（花名冊）中的每條記錄.它包含了用戶的JID，用戶名，或用戶分配的昵稱.
 
8、RosterGroup
 表示RosterEntry的組。可以使用addEntry(RosterEntry entry)添加。contains(String user) 判斷某用戶是否在組中.當然removeEntry(RosterEntry entry)就是從組中移除了。getEntries()

獲取所有RosterEntry.
 
9、Presence
 表示XMPP狀態的packet。每個presence packet都有一個狀態。用枚舉類型Presence.Type的值表示：
 available -- （默認）用戶空閒狀態
 unavailable -- 用戶沒空看消息
 subscribe -- 請求訂閱別人，即請求加對方為好友
 subscribed -- 統一被別人訂閱，也就是確認被對方加為好友
 unsubscribe -- 他取消訂閱別人，請求刪除某好友
 unsubscribed -- 拒絕被別人訂閱，即拒絕對放的添加請求
 error -- 當前狀態packet有錯誤
 內嵌兩個枚舉類型:Presence.Mode和Presence.Type.
 可以使用setStatus自定義用戶當前的狀態（像QQ一樣的)