實(shí)時(shí)聊天
一直在仿微信界面，今天終于有幸利用百度云推送仿一仿微信聊天了~~~
首先特別感謝:weidi1989分享的Android之基于百度云推送IM ，大家可以直接下載；省了很多事哈，本例中也使用了weidi的部分代碼，凡是@author way的就是weidi1989的代碼~~
![]()
1、效果圖
核心功能也就上面的兩張圖了~~~我拿著手機(jī)和模擬器聊天，同時(shí)感謝群里的兄弟姐妹幫忙測試（好友列表中）。
![]()
2、原理
下面通過幾個(gè)問題來說明下實(shí)現(xiàn)的原理：
1、如何實(shí)現(xiàn)給某個(gè)用戶發(fā)送消息呢？
其實(shí)就是利用百度云提供的REST API，直接通過發(fā)送Http請求的形式給某個(gè)用戶推送一條消息；
網(wǎng)址：http://developer.baidu.com/wiki/index.php?title=docs/cplat/push/api/list
實(shí)例：
push_msg
功能
推送消息，該接口可用于推送單個(gè)人、一群人、所有人以及固定設(shè)備的使用場景。
HTTP請求方式
POST
URL
http[s]://channel.api.duapp.com/rest/2.0/channel/channel
....
2、的確可以實(shí)現(xiàn)給某個(gè)用戶或者一群用戶推送消息，那么用戶的昵稱神馬的咋獲取的呢，我印象中百度云中沒法存這樣的數(shù)據(jù)？
嗯，其實(shí)用了一個(gè)比較巧妙的方式；在用戶首次安裝軟件的時(shí)候，會(huì)要求用戶填寫注冊信息，也就是昵稱等；當(dāng)用戶填寫完畢時(shí)，點(diǎn)擊登錄的時(shí)候：
1、發(fā)送一條比較特殊的消息，比如這個(gè)消息攜帶一個(gè)hello的字段，廣播給所有用戶；
2、其他用戶在收到消息時(shí)，首先判斷hello這個(gè)字段是否有值，有值則說明新用戶加入，把該新用戶存入本地?cái)?shù)據(jù)庫，然后更新用戶列表；
3、其他用戶給這個(gè)新用戶回一條消息，附帶一個(gè)特殊字段，比如welcome，當(dāng)新用戶收到攜帶welcome字段的消息時(shí)，表明這是對(duì)新用戶hello的答復(fù)，然后將已存在用戶添加到該新用戶的用戶列表。
基本原理就這樣了，大家甚至可以利用上述的原理添加一些刪除好友的功能；比如當(dāng)用戶點(diǎn)擊刪除好友，則發(fā)送一條特殊消息給被刪除的對(duì)象，然后對(duì)方收到該消息，也將發(fā)送發(fā)刪除。
相信大家在了解原理之后，這個(gè)例子瞬間從高大尚變成矮矬窮了，這尼瑪，so easy，誰不會(huì)啊~~~
![]()
3、核心代碼解析
由于代碼量還是相當(dāng)大的，也不想拆成幾篇博客，所以準(zhǔn)備將核心代碼進(jìn)行講解下，其他的大家自己看源碼~
關(guān)于這個(gè)例子的主界面，可以參考： 高仿微信5.2.1主界面架構(gòu) 包含消息通知
關(guān)于百度云推送的入門，可以參考：Android推送 百度云推送 入門篇
好了，最主要就是收到百度云推送的Receiver
![]()
1、onBind
首先是用戶第一次登錄時(shí)候綁定的回調(diào)
[java] view plaincopy
-
@Override
-
public void onBind(final Context context, int errorCode, String appid,
-
String userId, String channelId, String requestId)
-
{
-
String responseString = "onBind errorCode=" + errorCode + " appid="
-
+ appid + " userId=" + userId + " channelId=" + channelId
-
+ " requestId=" + requestId;
-
Log.e(TAG, responseString);
-
-
if (errorCode == 0)
-
{
-
SharePreferenceUtil util = PushApplication.getInstance()
-
.getSpUtil();
-
util.setAppId(appid);
-
util.setChannelId(channelId);
-
util.setUserId(userId);
-
-
} else
-
// 如果網(wǎng)絡(luò)正常，則重試
-
{
-
if (NetUtil.isNetConnected(context))
-
{
-
-
T.showLong(context, "啟動(dòng)失敗，正在重試...");
-
new Handler().postDelayed(new Runnable()
-
{
-
@Override
-
public void run()
-
{
-
PushManager.startWork(context,
-
PushConstants.LOGIN_TYPE_API_KEY,
-
PushApplication.API_KEY);
-
}
-
}, 2000);// 兩秒后重新開始驗(yàn)證
-
} else
-
{
-
T.showLong(context, R.string.net_error_tip);
-
}
-
}
-
// 回調(diào)函數(shù)
-
for (int i = 0; i < bindListeners.size(); i++)
-
bindListeners.get(i).onBind(userId, errorCode);
-
}
初次綁定的時(shí)候，如果綁定成功則使用SharedPreferences存儲(chǔ)userId，channelId等數(shù)據(jù)
然后回調(diào)：bindListeners.get(i).onBind(userId, errorCode);給所有注冊該事件的發(fā)出通知
下面看listener.onBind
[java] view plaincopy
-
/**
-
* 收到通知
-
*/
-
@Override
-
public void onBind(String userId, int errorCode)
-
{
-
Log.e("TAG", "Login Activity onBind ");
-
if (errorCode == 0)
-
{
-
Log.e("TAG", "Login Activity onBind success ");
-
// 如果綁定賬號(hào)成功，由于第一次運(yùn)行，給同一tag的人推送一條新人消息
-
User u = new User(mSpUtil.getUserId(), mSpUtil.getChannelId(),
-
mSpUtil.getNick(), mSpUtil.getHeadIcon(), 0);
-
mUserDB.addUser(u);// 把自己添加到數(shù)據(jù)庫
-
Message firstSendMsg = new Message(System.currentTimeMillis(), "");
-
firstSendMsg.setHello("hello");
-
task = new SendMsgAsyncTask(mGson.toJson(firstSendMsg), "");
-
task.setOnSendScuessListener(new OnSendScuessListener()
-
{
-
@Override
-
public void sendScuess()
-
{
-
if (mLoadingDialog != null && mLoadingDialog.isVisible())
-
mLoadingDialog.dismiss();
-
mHandler.removeCallbacks(mConnTimeoutCallback);
-
finish();
-
Intent intent = new Intent(LoginActivity.this,
-
MainActivity.class);
-
startActivity(intent);
-
}
-
});
-
task.send();
-
}
-
}
首先將自己保存到本地?cái)?shù)據(jù)庫，然后發(fā)送一個(gè)Message給所有的用戶，設(shè)置一個(gè)特殊字段hello；也就是上述的原理分析中的部分~
![]()
2、onMessage
收到百度云推送的Receiver中的onMessage
[java] view plaincopy
-
@Override
-
public void onMessage(Context context, String message,
-
String customContentString)
-
{
-
String messageString = "收到消息 message=\"" + message
-
+ "\" customContentString=" + customContentString;
-
Log.e(TAG, messageString);
-
Message receivedMsg = PushApplication.getInstance().getGson()
-
.fromJson(message, Message.class);
-
// 對(duì)接收到的消息進(jìn)行處理
-
parseMessage(receivedMsg);
-
-
}
-
-
/**
-
* 消息：1、攜帶hello，表示新人加入，應(yīng)該自動(dòng)回復(fù)一個(gè)world 消息； 2、普通消息；
-
*
-
* @param msg
-
*/
-
private void parseMessage(Message msg)
-
{
-
String userId = msg.getUserId();
-
// 自己的消息
-
if (userId
-
.equals(PushApplication.getInstance().getSpUtil().getUserId()))
-
return;
-
if (checkHasNewFriend(msg) || checkAutoResponse(msg))
-
return;
-
// 普通消息
-
UserDB userDB = PushApplication.getInstance().getUserDB();
-
User user = userDB.selectInfo(userId);
-
// 漏網(wǎng)之魚
-
if (user == null)
-
{
-
user = new User(userId, msg.getChannelId(), msg.getNickname(), 0, 0);
-
userDB.addUser(user);
-
// 通知監(jiān)聽的面板
-
for (onNewFriendListener listener : friendListeners)
-
listener.onNewFriend(user);
-
}
-
if (msgListeners.size() > 0)
-
{// 有監(jiān)聽的時(shí)候，傳遞下去
-
for (int i = 0; i < msgListeners.size(); i++)
-
msgListeners.get(i).onNewMessage(msg);
-
} else
-
// 當(dāng)前沒有任何監(jiān)聽，即處理后臺(tái)狀態(tài)
-
{
-
// 將新來的消息進(jìn)行存儲(chǔ)
-
ChatMessage chatMessage = new ChatMessage(msg.getMessage(), true,
-
userId, msg.getHeadIcon(), msg.getNickname(), false,
-
TimeUtil.getTime(msg.getTimeSamp()));
-
PushApplication.getInstance().getMessageDB()
-
.add(userId, chatMessage);
-
showNotify(msg);
-
}
-
}
-
-
/**
-
* 檢測是否是自動(dòng)回復(fù)
-
*
-
* @param msg
-
*/
-
private boolean checkAutoResponse(Message msg)
-
{
-
String world = msg.getWorld();
-
String userId = msg.getUserId();
-
if (!TextUtils.isEmpty(world))
-
{
-
User u = new User(userId, msg.getChannelId(), msg.getNickname(),
-
msg.getHeadIcon(), 0);
-
PushApplication.getInstance().getUserDB().addUser(u);// 存入或更新好友
-
// 通知監(jiān)聽的面板
-
for (onNewFriendListener listener : friendListeners)
-
listener.onNewFriend(u);
-
-
return true;
-
}
-
return false;
-
}
-
-
/**
-
* 檢測是否是新人加入
-
*
-
* @param msg
-
*/
-
private boolean checkHasNewFriend(Message msg)
-
{
-
String userId = msg.getUserId();
-
String hello = msg.getHello();
-
// 新人發(fā)送的消息
-
if (!TextUtils.isEmpty(hello))
-
{
-
Log.e("checkHasNewFriend", msg.getUserId());
-
// 新人
-
User u = new User(userId, msg.getChannelId(), msg.getNickname(),
-
msg.getHeadIcon(), 0);
-
PushApplication.getInstance().getUserDB().addUser(u);// 存入或更新好友
-
T.showShort(PushApplication.getInstance(), u.getNick() + "加入");
-
-
// 給新人回復(fù)一個(gè)應(yīng)答
-
Message message = new Message(System.currentTimeMillis(), "");
-
message.setWorld("world");
-
new SendMsgAsyncTask(PushApplication.getInstance().getGson()
-
.toJson(message), userId);
-
// 通知監(jiān)聽的面板
-
for (onNewFriendListener listener : friendListeners)
-
listener.onNewFriend(u);
-
-
return true;
-
}
-
-
return false;
-
}
當(dāng)收到一個(gè)新的消息：
1、首先判斷是不是自己發(fā)的，是，忽略；
2、判斷是否攜帶hello字段，代表新人加入，攜帶，則保存到好友列表，且回復(fù)一個(gè)攜帶welcome字段的消息；
3、判斷是否包含welcome字段，包含，存入好友列表
4、不是1、2、3則肯定是普通消息，將消息保存到本地?cái)?shù)據(jù)庫，然后為所有設(shè)置消息監(jiān)聽的發(fā)送回調(diào)即可~
MainTabFriends.java用戶列表中收到新消息的回調(diào)：
[java] view plaincopy
-
/**
-
* 收到新消息時(shí)
-
*/
-
@Override
-
public void onNewMessage(Message message)
-
{
-
// 如果是自己發(fā)送的，則直接返回
-
if (message.getUserId() == mSpUtils.getUserId())
-
return;
-
// 如果該用戶已經(jīng)有未讀消息，更新未讀消息的個(gè)數(shù)，并通知更新未讀消息接口，最后notifyDataSetChanged
-
String userId = message.getUserId();
-
if (mUserMessages.containsKey(userId))
-
{
-
mUserMessages.put(userId, mUserMessages.get(userId) + 1);
-
} else
-
{
-
mUserMessages.put(userId, 1);
-
}
-
mUnReadedMsgs++;
-
notifyUnReadedMsg();
-
// 將新來的消息進(jìn)行存儲(chǔ)
-
ChatMessage chatMessage = new ChatMessage(message.getMessage(), true,
-
userId, message.getHeadIcon(), message.getNickname(), false,
-
TimeUtil.getTime(message.getTimeSamp()));
-
mApplication.getMessageDB().add(userId, chatMessage);
-
// 通知listview數(shù)據(jù)改變
-
mAdapter.notifyDataSetChanged();
-
}
1、如果是自己發(fā)的不做任何處理
2、如果當(dāng)前消息發(fā)送用戶已有未讀消息，則更新該用戶未讀消息個(gè)數(shù)（用戶Item上顯示未讀消息通知數(shù)），更新所有未讀消息總和（朋友Tab上顯示未讀消息總和），然后存儲(chǔ)該消息
3、刷新界面
ChattingActivity.java聊天界面的新消息回調(diào)
[java] view plaincopy
-
@Override
-
public void onNewMessage(Message message)
-
{
-
-
// 獲得回復(fù)的消息
-
if (mFromUser.getUserId().equals(message.getUserId()))
-
{
-
ChatMessage chatMessage = new ChatMessage();
-
chatMessage.setComing(true);
-
chatMessage.setDate(new Date(message.getTimeSamp()));
-
chatMessage.setMessage(message.getMessage());
-
chatMessage.setUserId(message.getUserId());
-
chatMessage.setNickname(message.getNickname());
-
chatMessage.setReaded(true);
-
mDatas.add(chatMessage);
-
mAdapter.notifyDataSetChanged();
-
mChatMessagesListView.setSelection(mDatas.size() - 1);
-
// 存入數(shù)據(jù)庫，當(dāng)前聊天記錄
-
mApplication.getMessageDB().add(mFromUser.getUserId(), chatMessage);
-
}
-
}
首先判斷是否是正在聊天的用戶發(fā)的消息，如果是，直接存入數(shù)據(jù)庫，刷新聊天界面；
穩(wěn)定
產(chǎn)品高可用性高并發(fā)貼心
項(xiàng)目群及時(shí)溝通專業(yè)
產(chǎn)品經(jīng)理1v1支持快速
MVP模式小步快跑承諾
我們選擇聲譽(yù)堅(jiān)持
10年專注高端品質(zhì)開發(fā)