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用来处理异步消息的标准服务，他们主要负责消息的处理、派发、维护等工作。对一些简单的异步处理过程，我们可以通过回调机制来实现。