`

java回调与观察者模式,与反应堆,前摄器

 
阅读更多

 

1、回调:invoker给A的方法传递一个接口B的变量声明,A的方法可以调用这个接口的方法。

invoker可以是A的对象,A的子类对象,或者其他能调用A的方法的对象

 

 

正常调用

调用者调用方法时,该方法已经实现

回调时

调用者调用方法时,该方法还未实现,其他与正常调用一样(所以一般是接口的方法),多态的体现。

“回”:返回、反向的意思,时间概念上的反向。

把匿名内部类改成外部类,就能看出来了。

何时用回调

需要调用方法时,该方法内部实现不能确定时。

 

 

public interface ICallbackB {
    // 两个回调方法
    public void doB();
    public void doB(ClassA a);//还可以再回传A的引用
}

 

 

 

public class ClassA {
    private String news;
    public ClassA( String news ) {
        this.news = news;
    }
    public String getNews() {
        return news;
    }
    //①,给A传递一个接口B的变量声明,A可以调用这个接口的方法。    
    public void doA(ICallbackB callback){
        System.out.println("running in ClassA.doA method");
        System.out.println("start callback...");
        //②,调用这个接口B的方法
        callback.doB();
        callback.doB(this);
    }
    public static void main( String[] args ) {
        ClassA a = new ClassA( "郑州90后房妹一家有29套房子" );
        //③,new匿名内部类对象,相当于"观察者模式中的注册"
        //④,invoker调用a.doA相当于"观察者模式中的事件触发"
        a.doA( new ICallbackB() {
            @Override
            public void doB( ClassA a ) {
                System.out.println("callback doB( ClassA a )... "+a.getNews());
            }
            @Override
            public void doB() {
                System.out.println("callback doB...");
            }
        } );
    }
}

 

 

真实例子:

 

// 1, swing-UI开发中
// JMenuItem menuOpen是ClassA的角色
// ActionListener是ICallbackB的角色
menuOpen.addActionListener(new ActionListener() {
    public void actionPerformed(ActionEvent e) {
        openFile();
    }
});
//------------------------------------------------
//2, Netty中的例子
channelFuture.addListener( new ChannelFutureListener() {
    @Override
    public void operationComplete( ChannelFuture future )throws Exception {
        future.channel();
    }
});
//------------------------------------------------
//3, Netty中的例子,带返回值   
private ChannelHandler operateHandler(IChannelHandlerFactory handlerFactory ) {
    // 还可以做其他操作,这里省略
    return handlerFactory.newHandler();
}
public void a(){
    AHandler = (AHandler) operateHandler( new IChannelHandlerFactory() {
        @Override
        public ChannelHandler newHandler() {
            return new AHandler( ... );
        }
    } );
}

 

2、演变为-->观察者模式

 

观察者模式,有4个角色

ClassA变为抽象事件源

并持有List<ICallbackB> callbackBList;

提供register(ICallbackB b),ICallbackB的实现类借此

doA方法,遍历callbackBList,循环调用doB,do

新增sub-ClassA,作为新的事件源,

如果需要就重写doA方法

setXxx()方法中调用doA方法//xxx是被观察的事件,

ICallbackB作为观察者的接口定义

新增ICallbackB的实现类,作为观察者

 

 

3、百科和自己的理解,未整理

http://baike.baidu.com/view/414773.htm还有这里的。

a.do(){... b.doB(this)}

b.doB(A a){...}

这样的更像是回调

4种都是事件源(有未知因素,)的。processHandler有必要,因为不确定需不要new。改

processHandler是父类的,但依赖未知未实现的子类。。。。。。。。。。回指的这个意思?

 

软件模块之间总是存在着一定的接口,从调用方式上,可以把他们分为三类:同步调用、回调和异步调用。同步调用是一种阻塞式调用,调用方要等待对方执行完毕才返回,它是一种单向调用;回调是一种双向调用模式,也就是说,被调用方在接口被调用时也会调用对方的接口;异步调用是一种类似消息或事件的机制,不过它的调用方向刚好相反,接口的服务在收到某种讯息或发生某种事件时,会主动通知客户方(即调用客户方的接口)。回调和异步调用的关系非常紧密,通常我们使用回调来实现异步消息的注册,通过异步调用来实现消息的通知。同步调用是三者当中最简单的,而回调又常常是异步调用的基础,因此,下面我们着重讨论回调机制在不同软件架构中的实现。

对于不同类型的语言(如结构化语言和对象语言)、平台(Win32、JDK)或构架(CORBA、DCOM、WebService),客户和服务的交互除了同步方式以外,都需要具备一定的异步通知机制,让服务方(或接口提供方)在某些情况下能够主动通知客户,而回调是实现异步的一个最简捷的途径。

对于一般的结构化语言,可以通过回调函数来实现回调。回调函数也是一个函数或过程,不过它是一个由调用方自己实现,供被调用方使用的特殊函数。

在面向对象的语言中,回调则是通过接口或抽象类来实现的,我们把实现这种接口的类称为回调类,回调类的对象成为回调对象。对于象C++或Object Pascal这些兼容了过程特性的对象语言,不仅提供了回调对象、回调方法等特性,也能兼容过程语言的回调函数机制。

Windows平台的消息机制也可以看作是回调的一种应用,我们通过系统提供的接口注册消息处理函数(即回调函数),从而实现接收、处理消息的目的。由于Windows平台的API是用C语言来构建的,我们可以认为它也是回调函数的一个特例。

对于分布式组件代理体系CORBA,异步处理有多种方式,如回调、事件服务、通知服务等。事件服务和通知服务是CORBA用来处理异步消息的标准服务,他们主要负责消息的处理、派发、维护等工作。对一些简单的异步处理过程,我们可以通过回调机制来实现。

分享到:
评论

相关推荐

Global site tag (gtag.js) - Google Analytics