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;
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;
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 {
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();
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. });
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. }
48. });
49. }
50. });
51. //發送消息
52. newChat.sendMessage("我是菜鳥");
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. }
63. //添加花名冊監聽器，監聽好友狀態的改變。
64. roster.addRosterListener(new RosterListener() {
66. @Override
67. public void entriesAdded(Collection<String> addresses) {
68. System.out.println("entriesAdded");
69. }
71. @Override
72. public void entriesUpdated(Collection<String> addresses) {
73. System.out.println("entriesUpdated");
74. }
76. @Override
77. public void entriesDeleted(Collection<String> addresses) {
78. System.out.println("entriesDeleted");
79. }
81. @Override
82. public void presenceChanged(Presence presence) {
83. System.out.println("presenceChanged - >" + presence.getStatus());
84. }
86. });
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. }
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一樣的)