《Smack开发总结 (四)消息管理》
转载请注明来自 傻小孩b_移动开发(http://www.jianshu.com/users/d388bcf9c4d3)喜欢的可以关注我,不定期总结文章!您的支持是我的动力哈!
消息管理
首先在即时通讯中,当然少不了核心的消息管理机制了。在smack中,对于消息管理的机制基础应用还是相当简单的。了解过的smack的程序猿都清楚,samck中是通过XMPP协议进行消息传递的。(不了解的请跳转百科XMPP协议)因此,我们可以了解到,他是由一组XML的数据封装的消息类型,其中smack中的基本消息由org.jivesoftware.smack.packet.Message组成,消息内容存储在body标签里面。
接下来直接总结下Smack,如何对消息的管理。
一、在线消息
(一)获取聊天管理器
ChatManager mChatManager = ChatManager.getInstanceFor(mConnection);
(二)创建聊天会话
public Chat createChat(String userJid) {
Chat curChat = null;
curChat = mChatManager.createChat(userJid);
return curChat;
}
(三) 消息发送
public void sendMessage(Chat chat, Message message) {
try {
chat.sendMessage(message);
} catch (SmackException.NotConnectedException e) {
e.printStackTrace();
}
}
(四)消息接收
说到消息接收,这里首先需要说明两个回调监听ChatManagerListener和ChatMessageListener
ChatManagerListener:
/**
* Event fired when a new chat is created.
*
* @param chat the chat that was created.
* @param createdLocally true if the chat was created by the local user and false if it wasn't.
*/
void chatCreated(Chat chat, boolean createdLocally); // 聊天会话被创建回调
ChatMessageListener:
void processMessage(Chat chat, Message message); // 消息接收回调
在实际开发中,我们可以在监听到消息会话chat创建的时候进行消息监听
public void chatCreated(Chat chat, boolean createdLocally) {
chat.addMessageListener(this);
}
@Override
public void processMessage(Chat chat, Message message) {
MessageModel msg = MessageDealUtil.dealMessage(message);
if (msg.getBody() != null) {
Intent intent = new Intent();
Bundle bundle = new Bundle();
bundle.putParcelable("message", msg);
intent.putExtras(bundle);
intent.setAction(MessageReceiver.SNAKE_MESSAGE_ACTION);
SnakeUtilKit.getSnakeApp().sendBroadcast(intent);
if (listener != null){
listener.onRecevie(msg,message.getBody());
}
}
}
二、离线消息
离线消息即是如果对方不在线状态的情况,openfire的处理策略:如果对方不在线状态,会暂时将消息存入在offline表。所以这里要求客户端,在登录成功的时候进行离线消息读取,并且读取成功后,主动向openfire请求删除离线消息缓存。
(一)获取离线消息管理器
OfflineMessageManager mOfflineMessageManager = new OfflineMessageManager(mConnection);
(二)获取离线消息
public void getOfflineMessage(){
LogTool.d("获取离线消息..");
if (mOfflineMessageManager != null){
try {
if (mOfflineMessageManager.getMessageCount() >0){
List<Message> messages = mOfflineMessageManager.getMessages();
for (Message message : messages){
processMessage(null,message);
}
}
mOfflineMessageManager.deleteMessages();
} catch (Exception e) {
e.printStackTrace();
}
}
}
基础应用不难,如果要扩展新的消息类型,这里就需要对message的类型做消息类型协议定义了。原理大概:文件-》上传服务器地址-响应拿到文件地址-》组装到meesage的标签body(例如json形式{“type”:”img”,”content”:”地址”})。这样在接收到消息的时候,做消息转化即可。
有兴趣的可以一起交流哈
傻小孩b mark共勉,写给在成长路上奋斗的你