手写简单的观察者模式

Posted 2023-02-07 Anonymous-OS

1、创建回调接口

public interface IObserver 
    void onResult(String result);

2、创建调度中心

public class Observer 

    private Observer() 
    

    private static class SingleTon 
        static Observer INSTANCE = new Observer();
    

    public static Observer getInstance() 
        return SingleTon.INSTANCE;
    

    private Map<String, IObserver> map = new ConcurrentHashMap<>();

    public void regist(String key, IObserver callback) 
        map.put(key, callback);
    

    public void notify(String key, String str) 
        if (map.containsKey(key)) 
            IObserver callback = map.get(key);
            callback.onResult(str);
        
    

3、发送通知

Observer.getInstance().notify("notify","我是一条新消息");

4、注册并响应通知

Observer.getInstance().regist("notify", new IObserver() 
    @Override
    public void onResult(String result) 
                
    
);

到此就是观察者模式的雏形，我也不想写太多，省的各位看官看着烦，只要理解了这几行代码的思想，至于怎么扩展，自己完全可以搞得定！