Dubbo探索（五）

事件通知

在调用之前，调用之后，出现异常时，会触发oninvoke, onreturn, onthrow三个事件，可以配置当事件发生时，通知哪个类的哪个方法。

消费方实现Notify接口，如下：

/**
 * Version: 3.0
 * Author: pattywgm
 * Time: 17/6/29 下午11:01
 * Desc: 事件通知接口
 */
public interface Notify {
    /**
     *
     * @param res 返回值
     * @param args 入参
     */
    public void onreturn(Object res, Object... args);

    /**
     *
     * @param ex 异常对象
     * @param args 入参
     */
    public void onthrow(Throwable ex, Object... args);

    /**
     *
     * @param args 入参
     */
    public void oninvoke(Object... args);
}


@Service("notifyImpl")
public class NotifyImpl implements Notify {
    @Override
    public void onreturn(Object res, Object... args) {
        System.out.println("onreturn:" + res.toString());

    }

    @Override
    public void onthrow(Throwable ex, Object... args) {

        System.out.println("onthrow: " + ex.getMessage());
    }

    @Override
    public void oninvoke(Object... args) {
        System.out.println("oninvoke: " + args[0]);
    }

配置UserService的findUserById()方法，添加事件通知，如下：

<dubbo:reference id="userService" group="db" interface="com.patty.dubbo.api.service.UserService"
                     timeout="10000" retries="3" mock="true" check="false">
        <dubbo:method name="findAllUsers" merger="myMerger" cache="lru">
        </dubbo:method>
        <dubbo:method name="findUserById" async="false" onreturn="notifyImpl.onreturn" onthrow="notifyImpl.onthrow">
        </dubbo:method>
</dubbo:reference>

onreturn指定调用notifyImpl的onreturn方法， onthrow指定调用notifyImpl的onthrow方法。运行中打印结果信息为：

onreturn: UserVo info: name-> 李丽, age -> 23, phoneNo -> 17709801256
onthrow: null pointer happend （在UserService的实现中，模拟抛出一个空指针异常）

代码参考：https://github.com/pattywgm/dubbo-demo.git