本文整理了Java中com.krpc.common.entity.ZookeeperInfo.getConnectionTimeOut()方法的一些代码示例，展示了ZookeeperInfo.getConnectionTimeOut()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。ZookeeperInfo.getConnectionTimeOut()方法的具体详情如下：
包路径：com.krpc.common.entity.ZookeeperInfo
类名称：ZookeeperInfo
方法名：getConnectionTimeOut

ZookeeperInfo.getConnectionTimeOut介绍

暂无

代码示例

代码示例来源：origin: yangzhenkun/krpc

public static void init(ZookeeperInfo zookeeperInfo) {
  if (zc != null) {
    return;
  }
  try {
    zc = new ZkClient(zookeeperInfo.getAddr(), zookeeperInfo.getSessionTimeOut(), zookeeperInfo.getConnectionTimeOut());
  } catch (Exception e) {
    e.printStackTrace();
    log.error("zk init error!", e);
  }
}

代码示例来源：origin: yangzhenkun/krpc

public static void register() {
  try {
    ZookeeperInfo zookeeperInfo = Global.getInstance().getZookeeperInfo();
    zc = new ZkClient(zookeeperInfo.getAddr(), zookeeperInfo.getSessionTimeOut(), zookeeperInfo.getConnectionTimeOut());
    StringBuffer stringBuffer = new StringBuffer("/krpc");
    if (!zc.exists(stringBuffer.toString())) {
      zc.create(stringBuffer.toString(), "", CreateMode.PERSISTENT);
      log.info("创建根节点krpc");
    }
    stringBuffer.append("/").append(Global.getInstance().getServiceName());
    if (!zc.exists(stringBuffer.toString())) {
      zc.create(stringBuffer.toString(), "", CreateMode.PERSISTENT);
      log.info("创建{}服务节点", Global.getInstance().getServiceName());
    }
    stringBuffer.append("/").append(Global.getInstance().getIp()).append(":").append(Global.getInstance().getPort());
    zc.create(stringBuffer.toString(), Global.getInstance().getServiceName(), CreateMode.EPHEMERAL);
  } catch (Exception e) {
    log.error("register error!", e);
  }
}