手机版
你好,游客 登录 注册
背景:
阅读新闻

ZooKeeper异步调用命令

[日期:2019-08-30] 来源:Linux社区  作者:codestory [字体: ]

在ZooKeeper中,所有的同步调用命令,都会有一个相应的异步调用方法。异步调用能在一个单独线程中同时提交更多的命令,也能在一定程度上简化代码实现。

1 异步create方法

如创建zNode的命令create,同步方法的定义是

/**
 * @param path 创建节点的路径
 * @param data 创建节点的初始值
 * @param acl 创建节点的ACL
 * @param createMode 创建节点使用永久还是临时模式
 * @return 创建节点的真实路径
 * @throws KeeperException 服务器返回了非0的错误代码
 * @throws KeeperException.InvalidACLException ACL非法或者为空
 * @throws InterruptedException 事务被中断
 * @throws IllegalArgumentException 路径非法
 */
public String create(final String path,
    byte data[],
    List<ACL> acl,
    CreateMode createMode);

对应的异步调用方法

/**
 * create方法的异步调用方法
 * @param path 创建节点的路径
 * @param data 创建节点的初始值
 * @param acl 创建节点的ACL
 * @param createMode 创建节点使用永久还是临时模式
 * @param cb 包括回调函数的对象
 * @param ctx 上下文对象(异步回调时会传递给callback,方便出错时重新调用)
 */
public void create(final String path,
    byte data[],
    List<ACL> acl,
    CreateMode createMode,
    StringCallback cb,
    Object ctx);

StringCallback的定义

interface StringCallback extends AsyncCallback {
    /**
     * 处理异步调用的结果
     * @param rc   调用的返回码
     * @param path 异步调用时的路径参数
     * @param ctx  异步调用时的上下文对象
     * @param name 实际创建的节点名
     *             成功时通常同path相同,除非创建的是sequential节点
     */
    public void processResult(int rc,
        String path,
        Object ctx,
        String name);
}

异步调用与同步调用的两个主要区别:

  1. 异步调用没有返回值(void)
  2. 异步调用不抛出异常,异常情况都通过rc参数传递

2 部分rc代码定义

回调函数的第一个参数 rc ,是调用的返回值。ZooKeeper在枚举org.apache.zookeeper.KeeperException.Code中做了定义。从源码中摘出一些我们可能会经常使用的Code

/** 一切安好 */
OK (Ok),

/** 服务器连接丢失 */
CONNECTIONLOSS (ConnectionLoss),
/** 操作超时 */
OPERATIONTIMEOUT (OperationTimeout),
/** 参数错误 */
BADARGUMENTS (BadArguments),
 
/** 节点不存在 */
NONODE (NoNode),
/** 临时节点没有子节点 */
NOCHILDRENFOREPHEMERALS (NoChildrenForEphemerals),
/** 节点已经存在 */
NODEEXISTS (NodeExists),
/** 节点有子节点 */
NOTEMPTY (NotEmpty),
/** 会话超时 */
SESSIONEXPIRED (SessionExpired),
/** 请求超时*/
REQUESTTIMEOUT (-122),

3 回调函数的一般用法

下面是一个创建节点的简单例子。注意,ctx参数传递的是data,这个参数会直接传递到callback函数中,这样就可以直接重新调用create命令。

void createNode(String path, byte[] data) {
  zooKeeper.create(nodePath, data,
    ZooDefs.Ids.OPEN_ACL_UNSAFE,
    CreateMode.EPHEMERAL,
    nodeCreateCallback,
    data);
}
 
AsyncCallback.StringCallback nodeCreateCallback = new AsyncCallback.StringCallback() {
  public void processResult(int rc, String path, Object ctx, String name) {
    switch (KeeperException.Code.get(rc)) {
      case OK:
        // 创建节点成功
        break;
      case CONNECTIONLOSS:
        // 连接丢失,重新发布命令
        createNode(path, ctx);
        return;
      default:
        // 其他异常,抛出或记录异常
        KeeperException e = KeeperException.create(KeeperException.Code.get(rc), path);
        log.error("create node error", e);
    }
  }
};
复制代码

4 异步回调接口定义

ZooKeeper在org.apache.zookeeper.AsyncCallback中定义了几个回调接口

回调接口

说明

适用的异步命令

StatCallback

用于获取节点的状态

void exists()

void setData()

DataCallback

用于获取节点的值和状态

void getData()

void getConfig()

ACLCallback

用于获取节点的ACL信息和状态

void getACL()

ChildrenCallback

用于获取节点的子节点列表

void getChildren()

Children2Callback

用于获取节点的子节点列表和状态

void getChildren()

Create2Callback

用于获取节点的名称和状态

void create()

StringCallback

用于获取节点的名称

void create()

VoidCallback

不返回任何信息

void delete()

void sync()

void removeWatches()

void removeAllWatches()

MultiCallback

用于多命令请求的返回值

void multi()

可以看到,有些异步命令,可以选择使用多个不同的Callback,见下表

异步命令

可选的回调接口

接口说明

void create()

Create2Callback

用于获取节点的名称和状态

StringCallback

用于获取节点的名称

void getChildren()

ChildrenCallback

用于获取节点的子节点列表

Children2Callback

用于获取节点的子节点列表和状态

linux
相关资讯       ZooKeeper命令  异步调用命令 
本文评论   查看全部评论 (0)
表情: 表情 姓名: 字数

       

评论声明
  • 尊重网上道德,遵守中华人民共和国的各项有关法律法规
  • 承担一切因您的行为而直接或间接导致的民事或刑事法律责任
  • 本站管理人员有权保留或删除其管辖留言中的任意内容
  • 本站有权在网站内转载或引用您的评论
  • 参与本评论即表明您已经阅读并接受上述条款