Java：回调机制

1.  什么是回调函数
    回调函数（callback Function），顾名思义，用于回调的函数。  回调函数只是一个功能片段，由用户按照回调函数调用约定来实现的一个函数。回调函数是一个工作流的一部分，由工作流来决定函数的调用（回调）时机。回调函数包含下面几个特性： 
    1、属于工作流的一个部分；
    2、必须按照工作流指定的调用约定来申明（定义）；
    3、他的调用时机由工作流决定，回调函数的实现者不能直接调用回调函数来实现工作流的功能；    

2. 回调机制
    回调机制是一种常见的设计模型，他把工作流内的某个功能，按照约定的接口暴露给外部使用者，为外部使用者提供数据，或要求外部使用者提供数据。

=======================================================

java回调机制：

软件模块之间总是存在着一定的接口，从调用方式上，可以把他们分为三类：同步调用、回调和异步调用。

 

同步调用：一种阻塞式调用，调用方要等待对方执行完毕才返回，它是一种单向调用；

回      调：一种双向调用模式，也就是说，被调用方在接口被调用时也会调用对方的接口；

异步调用：一种类似消息或事件的机制，不过它的调用方向刚好相反，接口的服务在收到某种讯息或发生某种事件时，会主动通知客户方（即调用客户方的接口）。

回调和异步调用的关系非常紧密：使用回调来实现异步消息的注册，通过异步调用来实现消息的通知。

========================================================

 

Java回调实现

 

有个这样的问题：老板（Boss）让工人（Worker）干完活告诉他干的情况如何。

 

实际上是一个典型的回调问题，Java实现如下：

 

/**
* Created by IntelliJ IDEA.
* User: leizhimin
* Date: 2008-7-31 13:18:33
* 事件接口
*/
public interface Event {
    /**
     * 返回发生事件信息
     *
     * @return 事件信息
     */
    public String happendEvent();
}

 

/**
* Created by IntelliJ IDEA.
* User: leizhimin
* Date: 2008-7-31 13:18:14
* 事件A
*/
public class EventA implements Event {
    /**
     * 返回发生事件信息
     *
     * @return 事件信息
     */
    public String happendEvent() {
        return "发生了事件 EventA！";
    }
}

 

/**
* Created by IntelliJ IDEA.
* User: leizhimin
* Date: 2008-7-31 13:18:21
* 事件B
*/
public class EventB implements Event{
    /**
     * 返回发生事件信息
     * @return 事件信息
     */
    public String happendEvent() {
        return "发生了事件 EventB！";
    }
}

 

/**
* Created by IntelliJ IDEA.
* User: leizhimin
* Date: 2008-7-31 13:20:48
* 工人
*/
public class Worker {
    private Event event;    //事件
    private String name;    //工人姓名
    private Boss boss;      //工人所属的老板

    public Worker(String name, Boss boss) {
        this.name = name;
        this.boss = boss;
    }

    /**
     * 干活
     */
    public void doWork() {
        System.out.println(name + " is doing working...");
        //工人挺辛苦，干着枯燥乏味的重复工作，哈哈
        for (int i = 0; i < 2000000; i++) {
            int x = i / 234 + 234;
        }
        System.out.println(name + " was finished work.");
        //向老板说明发生的情况
        boss.getWorkerEvent(this, event);
    }

    public Event getEvent() {
        return event;
    }

    public void setEvent(Event event) {
        this.event = event;
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }
}

 

/**
* Created by IntelliJ IDEA.
* User: leizhimin
* Date: 2008-7-31 13:26:22
* 老板
*/
public class Boss {
    private String name;

    public Boss(String name) {
        this.name = name;
    }

    /**
     * 老板接收工人的事件
     * @param worker 工人
     * @param event  事件
     */
    public void getWorkerEvent(Worker worker, Event event) {
        System.out.println("老板接收到事件信息： "+worker.getName() + ": " + event.happendEvent());
    }
}

 

/**
* Created by IntelliJ IDEA.
* User: leizhimin
* Date: 2008-7-31 13:35:38
* 测试类
*/
public class Test {
    public static void main(String args[]){
        //初始化老板和工人
        Boss boss = new Boss("老板");
        Worker worker1= new Worker("张三",boss);
        Worker worker2= new Worker("李四",boss);

        //捏造两个事件
        Event event1 = new EventA();
        Event event2 = new EventB();

        //事件是工人发出的
        worker1.setEvent(event1);
        worker2.setEvent(event2);

        //工人干活，干完了通知老板干的情况如何
        worker1.doWork();
        worker2.doWork();

    }
}

 

运行结果：

张三 is doing working...
张三 was finished work.
老板接收到事件信息： 张三: 发生了事件 EventA！
李四 is doing working...
李四 was finished work.
老板接收到事件信息： 李四: 发生了事件 EventB！

Process finished with exit code 0

 

呵呵，工人干活完成后，自动将发生的事件汇报给老板。

 

当然，如果工人很多，每个人都汇报的话，老板肯定会烦，那么老板可能会下达，发生了严重问题的员工才需要汇报问题。这个时候，需要做个事件过滤

 

 

 ==================================

1。首先回调方法的概念与“构造方法”的概念是不一样的，它不是指java中某个具有特殊意义或用途的方法。
2。称它为方法的“回调”更恰当一些，它是指方法的一种调用方式。任何一个被“回调”的方法，皆可称之为“回调方法” 
3。方法的回调通常发生在“java接口”和“抽象类”的使用过程中。
假设有接口名为 ICallBack 其中有方法名为postExec()
有类Myclass 实现了该接口，也就是一定实现了postExec()这个方法。现在有另一个类FooBar它有个方法 setCallBack(ICallBack callBack) ,并且setCallBack方法调用了callBack的postExec()方法。
如果现在，我们使用一个Myclass 的实例myClass，将它作为参数带入到setCallBack(ICallBack callBack)方法中，我们就说setCallBack(ICallBack callBack)方法回调了myClass的postExec()方法。 

==========================================================

 

在ibatis-common包中解析xml就是用的java回调机制来解析：

在SqlMapParser类定义addXXXXNodelets()方法 往NodeletParser类中map中添加，比如：

 

private void addSqlNodelets() {
    parser.addNodelet("/sqlMap/sql", new Nodelet() {
      public void process(Node node) throws Exception {
        Properties attributes = NodeletUtils.parseAttributes(node, vars.properties);
        String id = attributes.getProperty("id");
        if (vars.useStatementNamespaces) {
          id = applyNamespace(id);
        }
        vars.sqlIncludes.put(id, node);
      }
    });
  }

在NodeletParser中

public void addNodelet(String xpath, Nodelet nodelet) {
    letMap.put(xpath, nodelet);//把xpath添加到map中
  }

 

在处理的时候回回调接口中的process方法

private void processNodelet(Node node, String pathString) {
    Nodelet nodelet = (Nodelet) letMap.get(pathString);
    if (nodelet != null) {
      try {
        nodelet.process(node);
      } catch (Exception e) {
        throw new NestedRuntimeException("Error parsing XPath '" + pathString + "'.  Cause: " + e, e);
      }
    }
  }

从上面的代码可以看出 add...()这些方法都是将配置文件中各个节点的Xpath及处理这些节点的事件加入到一个HashMap中，ibatis用一个自定义的NedeletParser类来解析Xml，此类类似于Sax API，但不同的是Sax是一个单独的Callback对应所有的节点，而NodeletParser 是通过一系列的Callback对应不同的节点，也就是用Hashmap事先注册节点的XPath和解析它们的事件，以备今后调用。然后在载入用户的SqlMapConfig.xml时，用递归的方法找出里面所有节点（从父节点到所有子节点）的xpath值，然后通过该值（Key）从Hash表获取它们的事件处理方法进行解析。