java观察者模式

2021-11-14 10:49:32

我下面简要概括一下观察者模式的思想要点：

1、需要被观察者，第一可以发布通知，第二可以触发观察者的回调方法

2、需要观察者，提供回调方法供被观察者触发

用微信公众号的逻辑简单说明：

用户关注微信公众号，用户就是观察者，微信公众号就是被观察者，微信公众号得知道有多少用户关注了它（得保存起来），当微信公众号发布文章时（发布通知），通知关注它的用户（触发观察者的回调方法）。

下面看看简单代码实现以上逻辑：

观察者接口：

package com.nobt.observer;

/**

定义一个观察者接口，只提供了更新方法，当被观察者触发更新方法时，会触发被观察者保存的所有观察者update();
@author nobt
@date 2018年12月25日下午8:30:26

*/
public interface Observer {


public void update(String message);

}
被观察者接口：

package com.nobt.observer;

/**

被观察者接口，声明添加、移除、通知观察者
@author nobt
@date 2018年12月25日下午8:33:34

*/
public interface Observerable {


public void addObserver(Observer o);
public void removeObserver(Observer o);
public void notifyObserver();

}
观察者接口的实现类，就是公众号例子中的用户：

package com.nobt.observer;

/**

模拟用户，实现观察者接口
@author nobt
@date 2018年12月25日下午8:40:06

*/
public class User implements Observer {


private String userName;

public User(String userName) {
    super();
    this.userName = userName;
}

@Override
public void update(String message) {
    System.out.println(userName + " 收到推送消息： " + message);
}

}
被观察者接口的实现类，就是公众号例子中的公众号：

package com.nobt.observer;

import java.util.ArrayList;
import java.util.List;

/**

模拟微信公众号，实现被观察者接口
@author nobt
@date 2018年12月25日下午8:35:28

*/
public class Wechat implements Observerable {


//被观察者保存所有观察者的集合
private List<Observer> observerList;
private String message;



public Wechat() {
    observerList = new ArrayList<Observer>();
}

@Override
public void addObserver(Observer o) {
    observerList.add(o);
}

@Override
public void removeObserver(Observer o) {
    if(!observerList.isEmpty()){
        observerList.remove(o);
    }

}

@Override
public void notifyObserver() {
    for(Observer o : observerList){
        o.update(message);
    }
}

public void topicMsg(String message) {
    this.message = message;
    System.out.println("微信公众号发布文章： " + message);
    //发布文章，通知所有观察者
    notifyObserver();
}

}
简单测试类，模拟3个用户关注公众号，第一次发布消息3个用户得到通知，第二次让其中一个用户取消关注，将只有两个用户得到通知：

package com.nobt.observer;

/**

测试类
@author nobt
@date 2018年12月25日下午8:41:42

*/
public class TestObserver {


public static void main(String[] args) {
    Wechat wc = new Wechat();
    
    User u1 = new User("user1");
    User u2 = new User("user2");
    User u3 = new User("user3");
    
    wc.addObserver(u1);
    wc.addObserver(u2);
    wc.addObserver(u3);
    
    wc.topicMsg("我发布了一篇公众号文章：《java观察者模式Demo》");
    
    System.out.println("用户user1取消了订阅...");
    
    wc.removeObserver(u1);
    
    wc.topicMsg("my name is nobt...");
}

}
打印结果如下：

以上源码：observer_demo: java观察者模式demo

码农公寓

相关文章