Android之观察者/被观察者模式Observer/Observable
2024-10-21 11:28:43
Android 本身也是有观察者模式的。虽然项目中很多需要通知数据改变的地方，用了EventBus，但是不得不说这个观察者模式还是很好用的。最近在开发新版本的时候引用了腾讯的IM，之前写直播的时候就用了，当时只在TCChatRoomMgr中注册了消息的监听，因为当时只在直播中用了收发消息，且是单一的聊天室。但是项目的聊天整体接入IM后这个问题就变得棘手了，因为很多界面要接收消息，包括首页，推送，聊天列表，还有直播，这该怎么办呢？模仿腾讯聊天IM的demo，demo中用的就是观察者模式，即只注册一次消息监听（腾讯的文档的代码），然后在所有需要观察的地方注册观察者，根据消息类型进行判断和过滤，问题就迎刃而解了。
观察者模式：简单来说，就是当对象A对对象B进行进行了类似“订阅”关系，当对象B的数据发生改变时，就要通知对象A进行相应。很简单也很好理解。Android中的观察者需要实现Observer接口，当数据发生改变时，观察者的update()方法就会被调用，被观察者继承Observable类，在数据发生改变时，需要调用setChanged(); this.notifyObservers(obj);这两个方法才可以通知观察者：你想要知道的数据发生了变化了。好了，废话不多说了，下面直接上代码，我都在代码里头做了注释了，各位看官请直接看下面的代码。
注册观察者：
public class MessageEvent extends Observable implements TIMMessageListener {
private volatile static MessageEvent instance;
private MessageEvent(){
//注册消息监听器
TIMManager.getInstance().addMessageListener(this);
}
public static MessageEvent getInstance(){
if (instance == null) {
synchronized (MessageEvent.class) {
if (instance == null) {
instance = new MessageEvent();
}
}
}
return instance;
}
@Override
public boolean onNewMessages(List<TIMMessage> list) {
for (TIMMessage item:list){
setChanged();
notifyObservers(item);
}
return false;
}
/**
* 主动通知新消息
*/
public void onNewMessage(TIMMessage message){
setChanged();
notifyObservers(message);
}
/**
* 清理消息监听
*/
public void clear(){
instance = null;
}
}
在任何想要接收消息的地方注册观察这就可以了比如ActivityHome:
public class ActivityHome extends ThinksnsAbscractActivity implements OnChatListener, UnreadMessageListener, OnClickListener, Observer {...
//在登陆后调用这个
MessageEvent.getInstance().addObserver(ActivityHome.this);
@Override
public void update(Observable observable, Object data) {
if (observable instanceof MessageEvent) {
TIMMessage msg = (TIMMessage) data;
//系统消息，自己发的消息，程序在前台的时候不通知
if (msg == null || Foreground.get().isForeground() ||
(msg.getConversation().getType() != TIMConversationType.Group &&
msg.getConversation().getType() != TIMConversationType.C2C) ||
msg.isSelf() ||
msg.getRecvFlag() == TIMGroupReceiveMessageOpt.ReceiveNotNotify ||
(MessageFactory.getMessage(msg) instanceof CustomMessage &&
((CustomMessage) MessageFactory.getMessage(msg)).getType() == CustomMessage.Type.TYPING))
return;
int im_unread_num = PreferenceUtils.getInt(Thinksns.getMy().getUid()+"im_unread_num", 0);
if (msg.getConversation().getType() == TIMConversationType.C2C) {
PreferenceUtils.putInt(Thinksns.getMy().getUid()+"im_unread_num", ++im_unread_num);
if (mdNotification != null) {
setUnReadUi(mdNotification);
} else {
fg_my.setUnReadMsg(0);
}
} else if(msg.getConversation().getType() == TIMConversationType.Group && !msg.getConversation().getPeer().contains("@")){
PreferenceUtils.putInt(Thinksns.getMy().getUid()+"im_unread_num", ++im_unread_num);
if (mdNotification != null) {
setUnReadUi(mdNotification);
} else {
fg_my.setUnReadMsg(0);
}
}
// ToastUtils.t("123456789");
}
}
再比如聊天列表页的Presenter里：
public class ConversationPresenter implements Observer {
private static final String TAG = "ConversationPresenter";
private ConversationView view;
public ConversationPresenter(ConversationView view){
//注册消息监听
MessageEvent.getInstance().addObserver(this);
//注册刷新监听
RefreshEvent.getInstance().addObserver(this);
//注册好友关系链监听
FriendshipEvent.getInstance().addObserver(this);
//注册群关系监听
GroupEvent.getInstance().addObserver(this);
this.view = view;
}
//在这个地方处理消息即可
@Override
public void update(Observable observable, Object data) {
if (observable instanceof MessageEvent){
TIMMessage msg = (TIMMessage) data;
view.updateMessage(msg);
}else if (observable instanceof FriendshipEvent){
FriendshipEvent.NotifyCmd cmd = (FriendshipEvent.NotifyCmd) data;
switch (cmd.type){
case ADD_REQ:
case READ_MSG:
case ADD:
view.updateFriendshipMessage();
break;
}
}else if (observable instanceof GroupEvent){
GroupEvent.NotifyCmd cmd = (GroupEvent.NotifyCmd) data;
switch (cmd.type){
case UPDATE:
case ADD:
view.updateGroupInfo((TIMGroupCacheInfo) cmd.data);
break;
case DEL:
view.removeConversation((String) cmd.data);
break;
}
}else if (observable instanceof RefreshEvent){
view.refresh();
}
}
...
}
使用了这种方法后，上面的困扰就解决了，注册abserver的地方还包括推送，直播页面，注意直播页面的TCChatroomMgr里面收消息一定要进行过滤后判断会话是否为空，因为这里就只收相应聊天室的消息，如果正常操作，退出直播后会退出聊天室，聊天室的消息就不收了，除非遇到闪退的情况（极少），用户还在这个聊天室中，那只能等到聊天解散了，其他对应界面也过滤了直播聊天室的消息。主要是开发起来比较麻烦，张杰磊同学辛苦了！！
Created by WangXiaotao
最新文章
- 第 29 章 CSS3 弹性伸缩布局[上]
- AngularJS内置指令
- ByteArrayInputStream和ByteArrayOutputStream
- FineUI疑难杂症
- Apache与Nginx的区分比较
- Python单元测试——深入理解unittest (转)
- [转]Web UI 设计命名规范
- 使用正则表达式限制TextBox输入
- cocos2d基础篇笔记四
- HTTP学习笔记--HTTP报文
- 熟人Dubbo 系列1-Dubbo什么
- （转ORCLE导入导出命令）
- Mac OSX中的@executable_path, @load_path和@rpath的理解(网摘)
- 关于APIcloud对应C#的 wcf框架作为后台,实现多库功能
- 学习一下DOM中的cloneNode（）与cloneNode（true）的基础知识
- Python 私有变量的访问和赋值
- js判断当前内容是否为空
- MyBatis+Hibernate+JDBC对比分析
- appium +ios 判断元素是否存在，排除visible=“false”的数据
- 一个非常有意思的蜜罐T-Pot 16.10