強烈推薦:
eoeandroid wiki
http://wiki.eoeandroid.com/%E9%A6%96%E9%A1%B5
eoeandroid 招聘
http://zhaopin.eoe.cn/?from=forum
Android資源匯總貼,給力!
http://www.eoeandroid.com/thread-49334-1-1.html
還是先放上圖,在說下做法。
具體做法就是,開啟一個服務,在后台每隔10秒鍾訪問一起(Socket)服務器,如果有數據,則返回數據,客戶端進行解析,然后發送廣播,即可接收到消息。
發送消息,則是由服務器提供接口來發送。然后,服務器與客戶端建立一個簡單的通信協議。
如:MSG|發送人ID|2012-2-12 07:25:12|發送類型 MSG是個標識,類型包括文本(包含表情),圖片,語音,位置等。
圖片和語音的發送,都是通過FTP先上傳文件到服務器,然后把本地存儲的路徑發送給對方。
在聊天的頁面中,用戶的頭像都是在本地存的。包括聊天的信息,也是本地數據庫存的。這樣就能記錄信息。也可以擴展把聊天記錄導出。
在本地創建的 消息數據庫中。要定義好聊天信心的字段,包括自己ID,好友ID,消息類型,文本內容,時間,是否已讀等(可擴展)
private String table = "CREATE TABLE IF NOT EXISTS message(" +
"_id integer PRIMARY KEY," +
"TtmType integer ," +
"TtmTuID integer ," +
"TtmToUserId integer ," +
"TtmContent text ," +
"TtmTime varchar(200) ," +
"isRead integer ," +
"isReplyLocation integer )";
這樣再次進入聊天頁面就可以把數據庫的內容讀出來,匹配到適配器
public List<DetailEntity> getdatas(int TtmTuID, int TtmToUserId) { List<DetailEntity> de = new ArrayList<DetailEntity>(); SQLiteDatabase database = dbmanger.getWritableDatabase(); Cursor cursor = database.rawQuery( "select * from message where (TtmTuID = ? and TtmToUserId = ?) or (TtmToUserId = ? and TtmTuID = ?) order by _id", new String[] { String.valueOf(TtmTuID), String.valueOf(TtmToUserId), String.valueOf(TtmTuID), String.valueOf(TtmToUserId)}); while (cursor.moveToNext()) { de.add(new DetailEntity(cursor.getInt(1), cursor.getInt(2), cursor .getInt(3), cursor.getString(4), cursor.getString(5),cursor.getInt(6),cursor.getInt(7))); } cursor.close(); database.close(); return de; }
圖片的查看和語音的播放,都需要從數據庫里取出文件保存的路徑,不然的會顯示和播放都不正確。
仔細看源碼的話發現,在進入頁面適配數據的時候已經從數據庫讀取內容了,而在適配器中查看圖片,又重新讀取了一次,
主要是因為,不這樣做還是不能正確顯示和播放。 對這個問題很費解。
進入到聊天頁面,換取到數據,很據數據類型來加載對應的layout,當然還要判斷用戶ID,信息的讀取是根據用戶ID來獲取的
messageList = MessageSQLService.getInstance(this).getdatas( Integer.valueOf(UserInfomation.getUserID(TalkMessageAct.this)), Integer.valueOf(TFuid)); for (int i = 0; i < messageList.size(); i++) { switch (messageList.get(i).getTtmType()) { case 1: int id = Integer.valueOf(messageList.get(i).getTtmTuID()); if (id == Integer.valueOf(TFuid)) { } else if (id == Integer.valueOf(UserInfomation .getUserID(TalkMessageAct.this))) { } break; case 2: int ids = Integer.valueOf(messageList.get(i).getTtmTuID()); if (ids == Integer.valueOf(TFuid)) { } else if (ids == Integer.valueOf(UserInfomation .getUserID(TalkMessageAct.this))) { } break; case 3: int idsx = Integer.valueOf(messageList.get(i).getTtmTuID()); if (idsx == Integer.valueOf(TFuid)) { } else if (idsx == Integer.valueOf(UserInfomation .getUserID(TalkMessageAct.this))) { } break; case 5: break; case 6: int idsxx = Integer.valueOf(messageList.get(i).getTtmTuID()); if (idsxx == Integer.valueOf(TFuid)) { } else if (idsxx == Integer.valueOf(UserInfomation .getUserID(TalkMessageAct.this))) { } break; } }
之前在測試中,用socket實現不了長連接。主要是因為不加上 socket.shutdownOutput();就收不到消息,而加上了即接收完消息斷了連接。所以每隔10秒就要訪問次Socket服務器
socket = new Socket(Constants.SOCKET_IP, Constants.SOCKET_PORT); if (socket.isConnected()) { out = new PrintWriter(new BufferedWriter( new OutputStreamWriter(socket.getOutputStream())), true); out.write("Lgn|"+ UserInfomation.getUserID(TalkMessageServer.this)+"|"+ UserInfomation.getUserPW(TalkMessageServer.this)); out.flush(); socket.shutdownOutput(); } reader = new BufferedReader(new InputStreamReader( socket.getInputStream())); while ((line = reader.readLine()) != null) { if (line != null) { //截取字符,讀取信息的操作 }
雖然實現了,但在實際的應用中,效果不好。費電,丟包。
當然了,現在正在往長連接方向該,也修改了通信協議(很規范),(SocketChannel,Selector)
最后放上源碼
原文鏈接:http://www.eoeandroid.com/thread-188604-1-1.html