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

ZooKeeper.register介绍

[英]Specify the default watcher for the connection (overrides the one specified during construction).
[中]指定连接的默认观察者（覆盖构造期间指定的观察者）。

代码示例

代码示例来源：origin: NGDATA/hbase-indexer

@Override
public void register(Watcher watcher) {
  delegate.register(watcher);
}

代码示例来源：origin: com.ngdata/hbase-sep-impl-common

@Override
public void register(Watcher watcher) {
  delegate.register(watcher);
}

代码示例来源：origin: com.linkedin.pegasus/d2

@Override
public void register(Watcher watcher)
{
 _zk.register(watcher);
}

代码示例来源：origin: NGDATA/lilyproject

@Override
public void register(Watcher watcher) {
  delegate.register(watcher);
}

代码示例来源：origin: indeedeng/util

public void register(final Watcher watcher) {
  zooKeeper.register(watcher);
}

代码示例来源：origin: org.pongasoft/org.linkedin.zookeeper-impl

@Override
public void register(Watcher watcher)
{
 getZk().register(watcher);
}

代码示例来源：origin: griddynamics/jagger

@Override
public void register(Watcher watcher) {
  getDelegate().register(watcher);
}

代码示例来源：origin: org.apache.pulsar/pulsar-zookeeper-utils

public void start() throws IOException {
  CompletableFuture<ZooKeeper> zkFuture = zlClientFactory.create(globalZkConnect, SessionType.AllowReadOnly,
      zkSessionTimeoutMillis);
  // Initial session creation with global ZK must work
  try {
    ZooKeeper newSession = zkFuture.get(10, TimeUnit.SECONDS);
    // Register self as a watcher to receive notification when session expires and trigger a new session to be
    // created
    newSession.register(this);
    zkSession.set(newSession);
  } catch (InterruptedException | ExecutionException | TimeoutException e) {
    LOG.error("Failed to establish global zookeeper session: {}", e.getMessage(), e);
    throw new IOException(e);
  }
}

代码示例来源：origin: xiancloud/xian

private void internalClose() throws Exception
  {
    try
    {
      ZooKeeper zooKeeper = (helper != null) ? helper.getZooKeeper() : null;
      if ( zooKeeper != null )
      {
        Watcher dummyWatcher = new Watcher()
        {
          @Override
          public void process(WatchedEvent event)
          {
          }
        };
        zooKeeper.register(dummyWatcher);   // clear the default watcher so that no new events get processed by mistake
        zooKeeper.close();
      }
    }
    catch ( InterruptedException dummy )
    {
      Thread.currentThread().interrupt();
    }
  }
}

代码示例来源：origin: org.apache.sentry/sentry-provider-db

private void internalClose() throws Exception
  {
    try
    {
      ZooKeeper zooKeeper = (helper != null) ? helper.getZooKeeper() : null;
      if ( zooKeeper != null )
      {
        Watcher dummyWatcher = new Watcher()
        {
          @Override
          public void process(WatchedEvent event)
          {
          }
        };
        zooKeeper.register(dummyWatcher);   // clear the default watcher so that no new events get processed by mistake
        zooKeeper.close();
      }
    }
    catch ( InterruptedException dummy )
    {
      Thread.currentThread().interrupt();
    }
  }
}

代码示例来源：origin: com.netflix.curator/curator-client

private void internalClose() throws Exception
  {
    try
    {
      ZooKeeper zooKeeper = (helper != null) ? helper.getZooKeeper() : null;
      if ( zooKeeper != null )
      {
        Watcher dummyWatcher = new Watcher()
        {
          @Override
          public void process(WatchedEvent event)
          {
          }
        };
        zooKeeper.register(dummyWatcher);   // clear the default watcher so that no new events get processed by mistake
        zooKeeper.close();
      }
    }
    catch ( InterruptedException dummy )
    {
      Thread.currentThread().interrupt();
    }
  }
}

代码示例来源：origin: apache/sentry

private void internalClose() throws Exception
  {
    try
    {
      ZooKeeper zooKeeper = (helper != null) ? helper.getZooKeeper() : null;
      if ( zooKeeper != null )
      {
        Watcher dummyWatcher = new Watcher()
        {
          @Override
          public void process(WatchedEvent event)
          {
          }
        };
        zooKeeper.register(dummyWatcher);   // clear the default watcher so that no new events get processed by mistake
        zooKeeper.close();
      }
    }
    catch ( InterruptedException dummy )
    {
      Thread.currentThread().interrupt();
    }
  }
}

代码示例来源：origin: pravega/pravega

@Override
  @Synchronized
  public ZooKeeper newZooKeeper(String connectString, int sessionTimeout, Watcher watcher, boolean canBeReadOnly) throws Exception {
    // prevent creating a new client, stick to the same client created earlier
    // this trick prevents curator from re-creating ZK client on session expiry
    if (client == null) {
      Exceptions.checkNotNullOrEmpty(connectString, "connectString");
      Preconditions.checkArgument(sessionTimeout > 0, "sessionTimeout should be a positive integer");
      Preconditions.checkNotNull(watcher, "watcher");
      this.connectString = connectString;
      this.sessionTimeout = sessionTimeout;
      this.canBeReadOnly = canBeReadOnly;
      this.client = new ZooKeeper(connectString, sessionTimeout, watcher, canBeReadOnly);
      return this.client;
    } else {
      Preconditions.checkArgument(this.connectString.equals(connectString), "connectString differs");
      Preconditions.checkArgument(this.sessionTimeout == sessionTimeout, "sessionTimeout differs");
      Preconditions.checkArgument(this.canBeReadOnly == canBeReadOnly, "canBeReadOnly differs");
      Preconditions.checkNotNull(watcher, "watcher");
      this.client.register(watcher);
      return this.client;
    }
  }
}

代码示例来源：origin: org.apache.curator/curator-client

zooKeeper.register(dummyWatcher);   // clear the default watcher so that no new events get processed by mistake
if ( waitForShutdownTimeoutMs == 0 )

代码示例来源：origin: com.github.jiayuhan-it/hadoop-yarn-server-resourcemanager

@VisibleForTesting
@Private
@Unstable
protected synchronized ZooKeeper getNewZooKeeper()
  throws IOException, InterruptedException {
 ZooKeeper zk = new ZooKeeper(zkHostPort, zkSessionTimeout, null);
 zk.register(new ForwardingWatcher(zk));
 return zk;
}

代码示例来源：origin: org.apache.bookkeeper/bookkeeper-server

@Override
  public void setSessionStateListener(SessionStateListener sessionStateListener) {
    zk.register((event) -> {
      // Check for expired connection.
      if (event.getType().equals(EventType.None) && event.getState().equals(KeeperState.Expired)) {
        sessionStateListener.onSessionExpired();
      }
    });
  }
}

代码示例来源：origin: ch.cern.hadoop/hadoop-yarn-server-resourcemanager

@VisibleForTesting
@Private
@Unstable
protected synchronized ZooKeeper getNewZooKeeper()
  throws IOException, InterruptedException {
 ZooKeeper zk = new ZooKeeper(zkHostPort, zkSessionTimeout, null);
 zk.register(new ForwardingWatcher(zk));
 return zk;
}

代码示例来源：origin: LableOrg/java-uniqueid

public ZooKeeperConnection(String quorumAddresses) throws IOException {
  this.zookeeper = connect(quorumAddresses);
  this.quorumAddresses = quorumAddresses;
  zookeeper.register(new ConnectionWatcher(this));
}

代码示例来源：origin: org.apache.pulsar/pulsar-zookeeper-utils

public void start(ShutdownService shutdownService) throws IOException {
  // Connect to local ZK
  CompletableFuture<ZooKeeper> zkFuture = zkClientFactory.create(zkConnect, SessionType.ReadWrite,
      (int) zkSessionTimeoutMillis);
  try {
    localZooKeeper = zkFuture.get(zkSessionTimeoutMillis, TimeUnit.MILLISECONDS);
    localZooKeeperSessionWatcher = new ZooKeeperSessionWatcher(localZooKeeper, zkSessionTimeoutMillis,
        shutdownService);
    localZooKeeperSessionWatcher.start();
    localZooKeeper.register(localZooKeeperSessionWatcher);
  } catch (Exception e) {
    throw new IOException("Failed to establish session with local ZK", e);
  }
}

代码示例来源：origin: org.apache.bookkeeper/bookkeeper-server

public ZKRegistrationManager(ServerConfiguration conf,
               ZooKeeper zk,
               String ledgersRootPath,
               RegistrationListener listener) {
  this.conf = conf;
  this.zk = zk;
  this.zkAcls = ZkUtils.getACLs(conf);
  this.ledgersRootPath = ledgersRootPath;
  this.cookiePath = ledgersRootPath + "/" + COOKIE_NODE;
  this.bookieRegistrationPath = ledgersRootPath + "/" + AVAILABLE_NODE;
  this.bookieReadonlyRegistrationPath = this.bookieRegistrationPath + "/" + READONLY;
  this.zkTimeoutMs = conf.getZkTimeout();
  this.layoutManager = new ZkLayoutManager(
    zk,
    ledgersRootPath,
    zkAcls);
  this.zk.register(event -> {
    if (!zkRegManagerInitialized) {
      // do nothing until first registration
      return;
    }
    // Check for expired connection.
    if (event.getType().equals(EventType.None)
      && event.getState().equals(KeeperState.Expired)) {
      listener.onRegistrationExpired();
    }
  });
}