前言
很久沒寫BLOG了，之前在寫Android聊天室的時候答應過要寫一個客戶（好友）之間的聊天demo，Android 基於Socket的聊天室已經實現了通過Socket廣播形式的通信功能。
以下是我寫的一個類似現在多數聊天軟件的冒泡聊天APP。全部功能都是自己的想法，對於現在市面上成功的例子是怎么實現的，我還不了解。所以讀者可只做參考學習，也可以分享您的案例給我。
功能
- 一對一聊天，非聊天室
- 好友列表
- 好友在線，離線狀態(實時更新)
- 冒泡實時聊天窗口
- 發送離線信息
基本原理
之前的聊天室原理：每當客戶端Socket連接到該ServerSocket之后，程序將對應Socket加入clients集合中保存，並為該Socket啟動一條線程，該線程負責處理該Socket所有的通信任務,當服務器線程讀到客戶端數據之后，程序遍歷clients集合，並將該數據向clients集合中的每個Socket發送一次 
一對一的聊天：Server通過Map把Clients的Socket都儲存起來，把Client用戶ID作為Map的key，當A發送信息給B時，服務器搜索出B的Socket，建立他們的通信通道。
服務器Server
這次我在服務器加入了2個Socket集合，一個用來處理用戶Online/Offline，另一個則專門用於處理用戶之間的通信信息傳遞
1 static Map<String, Socket> socketMap = new HashMap<String, Socket>();
2 static Map<String, Socket> onlineMap = new HashMap<String, Socket>();
Clients 上線，下線動作，Server都會經過篩選然后通知其在線的好友，Clients收到好友的在線狀態然后修改Friends List。
1 //save client's name ,online
2 //...
3 getnameString = str.substring(config.PROTOCOL_KEY.length()+config.PROTOCOL_ONLINE.length());
4 Server.onlineMap.put(getnameString, s);
5 //...
6 //update online friends
7 DataOutputStream onlineDOS = new DataOutputStream (Server.onlineMap.get(clientKey).getOutputStream());
8 onlineDOS.writeUTF(config.PROTOCOL_FRIENDS_START+onlineString+config.PROTOCOL_FRIENDS_END);
9 onlineDOS.flush();
關於聊天，我是通過一個自定義加密符來給每個Client做標志的，例如：Client A發出的信息，該條信息的頭部帶有一條服務器和客戶端都會識別的特殊符號，通過字符處理，找出該條信息的用戶信息；以此類推，Client A的通信對象也是用這個方法
我們找到ClientA的目標對象后，找出這個Socket通道，他們就可以一對一的對話了
1 //send msg to friend
2 DataOutputStream ndos = new DataOutputStream (Server.socketMap.get(forname).getOutputStream());
3 ndos.writeUTF(fromname+date+"\n"+forchat);
4 ndos.flush();
關於離線信息，這個主要是服務器承擔的功能，我是使用mySql保存數據的。Client A 向離線狀態的Client B發送一條信息，Server會判斷Client B是否在線，如果是離線狀態，服務器則把該信息先保存在mySql里；當Client B上線時，服務器會查找它的離線信息，如果有未讀信息，則會及時發送。Client B就能收到離線信息了 (￣ˇ￣)
客戶端 Clients
關於聊天，為了能夠實現同時與多個好友聊天（不同窗口線程），這里用了ContentProvider監視聊天數據的變化，使不在當前聊天窗口的Activity也能收到好友的信息拼打印。
1 //監視聊天數據的變化
2 getContentResolver().registerContentObserver(DataChangeProvider.CONTENT_URI,true, cob);
那后台是怎么樣接收好友發來的信息的呢？上面Server里說過，有一個SocketMap的集合，而這個集合就是記錄用戶的通信Socket，當有信息的時候，客戶端后台的WaitMsg()會接到發來的信息並做處理。
1 private Runnable waitThread = new Runnable() {
2 public void run() {
3 System.out.println("wait running!");
4 WaitMsg();
5 }
6 };
關於Online/Offline狀態，好友列表Activity ReceiveMsg()會監視Server發送的好友狀態信息，及時更新好友列表ListActivity。
1 //更新好友數據庫
2 fanDS.updateData(reMsg,name);
3 //獲取好友列表
4 fansArray = fanDS.getFans();
5
6 friends = new Friends(fansArray,reMsg,name);
7 friendList = friends.getFriends();
我的新浪微博