委托在观察者模式中的java实现

最近在看《大话设计模式》这本书,书中内容浅显易懂,遗憾的是,书中的代码实现用的是c#,虽然作为java程序员能看懂大致的意思,但是在遇到委托这样的语言级别隔阂的时候,还是感觉很吃力。那么在c#中一行代码就能实现的委托,在java中怎么实现呢?

本文参考观察者设计模式 Vs 事件委托(java)

一:为什么要在观察者模式中使用委托

观察者模式如果不使用委托,就面临着观察者需要通过实现接口来统一update方法。这对于已经封装完成的功能来说,要求过于苛刻。那么如果在观察者模式中使用委托,就可以摆脱掉实现接口统一方法的必要,从而完成真正意义上的类与类之间的解耦,满足开闭原则。

二:委托在观察者模式中的实现原理。

java中的委托说到底还是通过反射来实现。当观察者(observer)需要订阅某一主题(subject)时,之前是仅需要传递观察者对象本身,而此时要使用委托,就额外需要传递观察者接到通知后需要调用的方法名称以及方法需要的实际参数。形如

notifier.addListener(doa, "doaUpdate", 123,"spring");

第一个参数是观察者自己,第二个参数字符串就是需要传递的方法名,第三个就是需要传递的实际参数组成的数组。反射正是通过这样的订阅获得了需要的类名,方法名和参数类型,从而实现了反射,实现了不需要接口统一方法名称就可以动态实现通知。

三:委托在java中的代码实现。

1:Event事件类

主要是通过获取到的类名,方法名,参数类型完成反射调用

public class Event {
    private Object object;
    private String methodName;
    private Object [] params;
    private Class [] paramTypes;
    
    public Event(Object object,String methodName,Object...objects ){
        this.object=object;
        this.methodName=methodName;
        this.params=objects;
        contractParamTypes(this.params);
    }

    private void contractParamTypes(Object [] params){
        if(params==null){
            return;
        }
        paramTypes=new Class[params.length];
        for(int i=0;i<params.length;i++){
            paramTypes[i]=params[i].getClass();
        }
    }
    
    // EventHandler通过nofityx()调用该方法,
    //该方法通拿到每一个具体的传入的对象和传入的方法名,经过反射调用对应的方法
    public void invoke() throws Exception{
        Method method =object.getClass().getMethod(methodName, paramTypes);
        if(method==null){
            
        }else{
            method.invoke(object, params);
        }
    }

}
2:EventHandler

主要用来保存观察者,以及提供通知观察者的方法。

public class EventHandler {
    private List<Event> objects;
    
    public EventHandler(){
        objects=new ArrayList<Event>();
        
    }
    
    public void addEvent(Object object,String methodName,Object...args){
        Event event=new Event(object,methodName,args);
        objects.add(event);
    }
    
    public void notifyx() throws Exception{
        for(Event e:objects){
            // 通过反射调用对应的方法
            e.invoke();
        }
    }
}

上面的objects.add(event)实际上就是在保存传进来的观察者。

3:Notifier

提供了订阅的抽象主题,主题持有EventHandler,用来传递参数给Event,以及提供了何时调用通知的抽象方法。

public abstract class Notifier {

    private EventHandler eventHandler=new EventHandler();
    
    public EventHandler getEventHandler() {
        return eventHandler;
    }
  
    public  void addListener(Object object,String methodName,Object...args){
        //讲传递进来的参数交由EventHandler,EventHandler交由event处理。
            eventHandler.addEvent(object, methodName, args);
    }
    //具体的实现类规定了何时开始通知观察者。
    public abstract void notifyx();
}
4:GoodNofitier

只关心何时需要通知观察者就可以了。

public class GoodNofitier extends Notifier{
    @Override
     public  void notifyx(){
        try {
            getEventHandler().notifyx();
        } catch (Exception e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }   
}
5:具体的观察者
public class DeleObserverA {

    public void doaUpdate(int name,String month){
        System.out.println("DeleObserverA 开始更新:"+name+":"+month);
    }
}


public class DeleObserverB {
    public void dobUpdate(int name,String month){
        System.out.println("DeleObserverB 开始更新:"+name+":"+month);
    }
}
6:main方法调用
//委托 观察者
Notifier notifier=new GoodNofitier();
DeleObserverA doa=new DeleObserverA();
DeleObserverB dob=new DeleObserverB();
Student studnet=new Student();
//      notifier.addListener(doa, "doaUpdate", new Object[]{123,"spring"});
//      notifier.addListener(dob, "dobUpdate", new Object[]{456,"summer"});
notifier.addListener(doa, "doaUpdate", 123,"springg");
notifier.addListener(dob, "dobUpdate", 456,"summerr");

notifier.notifyx();
7:JDK8反射时int类型参数导致NoSuchMethodException
java.lang.NoSuchMethodException: observer.delete.DeleObserverA.doaUpdate(java.lang.Integer, java.lang.String)
    at java.lang.Class.getMethod(Class.java:1786)
    at observer.delete.Event.invoke(Event.java:31)
    at observer.delete.EventHandler.notifyx(EventHandler.java:22)
    at observer.delete.GoodNofitier.notifyx(GoodNofitier.java:9)
    at factorymode.MainActivity.main(MainActivity.java:139)

这个时候我们只需要把具体观察者的方法中的int改为Integer类型就可以了。

public class DeleObserverA {

    public void doaUpdate(Integer name,String month){
        System.out.println("DeleObserverA 开始更新:"+name+":"+month);
    }
}

这样就实现了委托在观察者模式中的使用。

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
【社区内容提示】社区部分内容疑似由AI辅助生成,浏览时请结合常识与多方信息审慎甄别。
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容

  • 1 场景问题# 1.1 订阅报纸的过程## 来考虑实际生活中订阅报纸的过程,这里简单总结了一下,订阅报纸的基本流程...
    七寸知架构阅读 10,129评论 5 57
  • Spring Cloud为开发人员提供了快速构建分布式系统中一些常见模式的工具(例如配置管理,服务发现,断路器,智...
    卡卡罗2017阅读 135,796评论 19 139
  • Android 自定义View的各种姿势1 Activity的显示之ViewRootImpl详解 Activity...
    passiontim阅读 175,856评论 25 709
  • 我要写一串文字来纪念我年少的轻狂,可能是乱七八糟、毫无头绪的,没什么写作技巧,我就是随心写,看明白就好了,...
    刘芋圆的西瓜味雪糕阅读 3,477评论 0 3
  • 作为一个小散,最重要的是应该避免散户思维。总是寄希望于亏损的恢复盈利,却不去观察那些发展潜力大的牛股总是一骑绝尘,...
    kasitravel阅读 3,262评论 0 0