联系人列表为空，请先登录

  1. 查询
  2. 包列表
  3. 类列表
  4. 方法
  5. org.apache.zookeeper.KeeperException#NoAuthException ( )

org.apache.zookeeper.KeeperException#NoAuthException ( )源码实例Demo

下面列出了org.apache.zookeeper.KeeperException#NoAuthException ( ) 实例代码，或者点击链接到github查看源代码，也可以在右侧发表评论。

源代码1 项目： hadoop   文件： TestZKFailoverController.java 
/**
 * Test that, if ACLs are specified in the configuration, that
 * it sets the ACLs when formatting the parent node.
 */
@Test(timeout=15000)
public void testFormatSetsAcls() throws Exception {
  // Format the base dir, should succeed
  DummyHAService svc = cluster.getService(1);
  assertEquals(0, runFC(svc, "-formatZK"));

  ZooKeeper otherClient = createClient();
  try {
    // client without auth should not be able to read it
    Stat stat = new Stat();
    otherClient.getData(ZKFailoverController.ZK_PARENT_ZNODE_DEFAULT,
        false, stat);
    fail("Was able to read data without authenticating!");
  } catch (KeeperException.NoAuthException nae) {
    // expected
  }
}
源代码2 项目： big-c   文件： TestZKFailoverController.java 
/**
 * Test that, if ACLs are specified in the configuration, that
 * it sets the ACLs when formatting the parent node.
 */
@Test(timeout=15000)
public void testFormatSetsAcls() throws Exception {
  // Format the base dir, should succeed
  DummyHAService svc = cluster.getService(1);
  assertEquals(0, runFC(svc, "-formatZK"));

  ZooKeeper otherClient = createClient();
  try {
    // client without auth should not be able to read it
    Stat stat = new Stat();
    otherClient.getData(ZKFailoverController.ZK_PARENT_ZNODE_DEFAULT,
        false, stat);
    fail("Was able to read data without authenticating!");
  } catch (KeeperException.NoAuthException nae) {
    // expected
  }
}
源代码3 项目： lucene-solr   文件： ZkCLITest.java 
@Test
public void testUpdateAcls() throws Exception {
  try {
    System.setProperty(SolrZkClient.ZK_ACL_PROVIDER_CLASS_NAME_VM_PARAM_NAME, VMParamsAllAndReadonlyDigestZkACLProvider.class.getName());
    System.setProperty(VMParamsAllAndReadonlyDigestZkACLProvider.DEFAULT_DIGEST_READONLY_USERNAME_VM_PARAM_NAME, "user");
    System.setProperty(VMParamsAllAndReadonlyDigestZkACLProvider.DEFAULT_DIGEST_READONLY_PASSWORD_VM_PARAM_NAME, "pass");

    String[] args = new String[]{"-zkhost", zkServer.getZkAddress(), "-cmd", "updateacls", "/"};
    ZkCLI.main(args);
  } finally {
    // Need to clear these before we open the next SolrZkClient
    System.clearProperty(SolrZkClient.ZK_ACL_PROVIDER_CLASS_NAME_VM_PARAM_NAME);
    System.clearProperty(VMParamsAllAndReadonlyDigestZkACLProvider.DEFAULT_DIGEST_READONLY_USERNAME_VM_PARAM_NAME);
    System.clearProperty(VMParamsAllAndReadonlyDigestZkACLProvider.DEFAULT_DIGEST_READONLY_PASSWORD_VM_PARAM_NAME);
  }

  boolean excepted = false;
  try (SolrZkClient zkClient = new SolrZkClient(zkServer.getZkAddress(), AbstractDistribZkTestBase.DEFAULT_CONNECTION_TIMEOUT)) {
    zkClient.getData("/", null, null, true);
  } catch (KeeperException.NoAuthException e) {
    excepted = true;
  }
  assertTrue("Did not fail to read.", excepted);
}
源代码4 项目： distributedlog   文件： TestZooKeeperClient.java 
@Test(timeout = 60000)
public void testAclCreatePerms() throws Exception {
    ZooKeeperClient zkcAuth = buildAuthdClient("test");
    zkcAuth.get().create("/test", new byte[0], ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
    zkcAuth.get().create("/test/key1", new byte[0], ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
    zkcAuth.get().create("/test/key2", new byte[0],
            DistributedLogConstants.EVERYONE_READ_CREATOR_ALL, CreateMode.PERSISTENT);

    ZooKeeperClient zkcNoAuth = buildClient();
    zkcNoAuth.get().create("/test/key1/key1", new byte[0], ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
    try {
        zkcNoAuth.get().create("/test/key2/key1", new byte[0], ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
        fail("create should fail on acl protected key");
    } catch (KeeperException.NoAuthException ex) {
        LOG.info("caught exception writing to protected key", ex);
    }

    rmAll(zkcAuth, "/test");
}
源代码5 项目： distributedlog   文件： TestZooKeeperClient.java 
@Test(timeout = 60000)
public void testAclCreatePerms() throws Exception {
    ZooKeeperClient zkcAuth = buildAuthdClient("test");
    zkcAuth.get().create("/test", new byte[0], ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
    zkcAuth.get().create("/test/key1", new byte[0], ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
    zkcAuth.get().create("/test/key2", new byte[0], DistributedLogConstants.EVERYONE_READ_CREATOR_ALL, CreateMode.PERSISTENT);

    ZooKeeperClient zkcNoAuth = buildClient();
    zkcNoAuth.get().create("/test/key1/key1", new byte[0], ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
    try {
        zkcNoAuth.get().create("/test/key2/key1", new byte[0], ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
        fail("create should fail on acl protected key");
    } catch (KeeperException.NoAuthException ex) {
        LOG.info("caught exception writing to protected key", ex);
    }

    rmAll(zkcAuth, "/test");
}
源代码6 项目： hadoop   文件： ZKRMStateStore.java 
T runWithRetries() throws Exception {
  int retry = 0;
  while (true) {
    try {
      return runWithCheck();
    } catch (KeeperException.NoAuthException nae) {
      if (HAUtil.isHAEnabled(getConfig())) {
        // NoAuthException possibly means that this store is fenced due to
        // another RM becoming active. Even if not,
        // it is safer to assume we have been fenced
        throw new StoreFencedException();
      }
    } catch (KeeperException ke) {
      if (ke.code() == Code.NODEEXISTS) {
        LOG.info("znode already exists!");
        return null;
      }
      if (hasDeleteNodeOp && ke.code() == Code.NONODE) {
        LOG.info("znode has already been deleted!");
        return null;
      }

      LOG.info("Exception while executing a ZK operation.", ke);
      if (shouldRetry(ke.code()) && ++retry < numRetries) {
        LOG.info("Retrying operation on ZK. Retry no. " + retry);
        Thread.sleep(zkRetryInterval);
        createConnection();
        continue;
      }
      LOG.info("Maxed out ZK retries. Giving up!");
      throw ke;
    }
  }
}
源代码7 项目： big-c   文件： ZKRMStateStore.java 
T runWithRetries() throws Exception {
  int retry = 0;
  while (true) {
    try {
      return runWithCheck();
    } catch (KeeperException.NoAuthException nae) {
      if (HAUtil.isHAEnabled(getConfig())) {
        // NoAuthException possibly means that this store is fenced due to
        // another RM becoming active. Even if not,
        // it is safer to assume we have been fenced
        throw new StoreFencedException();
      }
    } catch (KeeperException ke) {
      if (ke.code() == Code.NODEEXISTS) {
        LOG.info("znode already exists!");
        return null;
      }
      if (hasDeleteNodeOp && ke.code() == Code.NONODE) {
        LOG.info("znode has already been deleted!");
        return null;
      }

      LOG.info("Exception while executing a ZK operation.", ke);
      if (shouldRetry(ke.code()) && ++retry < numRetries) {
        LOG.info("Retrying operation on ZK. Retry no. " + retry);
        Thread.sleep(zkRetryInterval);
        createConnection();
        continue;
      }
      LOG.info("Maxed out ZK retries. Giving up!");
      throw ke;
    }
  }
}
源代码8 项目： lucene-solr   文件： SolrZkClientTest.java 
private static boolean canRead(SolrZkClient zkClient, String path) throws KeeperException, InterruptedException {
  try {
    zkClient.getData(path, null, null, true);
    return true;
  } catch (KeeperException.NoAuthException e) {
    return false;
  }
}
源代码9 项目： yuzhouwan   文件： AuthIPExample.java 
@Test
public void ipAcl() throws Exception {
    /*
    $ zkCli.sh -server localhost:2181
    [zk: localhost:2181(CONNECTED) 16] ls /
    [leader, election, zookeeper, origin, ip, auth_test, benchmark]

    [zk: localhost:2181(CONNECTED) 17] ls /ip
    Authentication is not valid : /ip

    [zk: localhost:2181(CONNECTED) 18] getAcl /ip
      'ip,'10.24.40.178
      : cdrwa
      'ip,'127.0.0.1
      : cdrwa


    $ zkCli.sh -server 127.0.0.1:2181
    [zk: 127.0.0.1:2181(CONNECTED) 1] ls /ip
      []

    [zk: 127.0.0.1:2181(CONNECTED) 2] get /ip
      ip
      cZxid = 0x10000c43b
      ctime = Tue Aug 22 16:50:37 CST 2017
      mZxid = 0x10000c43b
      mtime = Tue Aug 22 16:50:37 CST 2017
      pZxid = 0x10000c43b
      cversion = 0
      dataVersion = 0
      aclVersion = 0
      ephemeralOwner = 0x0
      dataLength = 2
      numChildren = 0
     */
    if (zoo.exists(IP_PATH, null) != null) zoo.delete(IP_PATH, -1);
    if (zoo.exists(IP_PATH_NO_AUTH, null) != null) zoo.delete(IP_PATH_NO_AUTH, -1);
    zoo.create(IP_PATH, IP.getBytes(), acls, CreateMode.PERSISTENT);
    assertEquals(IP, new String(zoo.getData(IP_PATH, false, null)));
    zoo.create(IP_PATH_NO_AUTH, IP.getBytes(), aclsNoAuth, CreateMode.PERSISTENT);
    try {
        zoo.getData(IP_PATH_NO_AUTH, false, null);
    } catch (KeeperException.NoAuthException e) {
        assertEquals("KeeperErrorCode = NoAuth for ".concat(IP_PATH_NO_AUTH), e.getMessage());
    }
}
 方法所在类
org.apache.zookeeper.KeeperException
 同类方法
NoNodeException ( )
code ( )
NodeExistsException ( )
create ( )
BadVersionException ( )
OperationTimeoutException ( )
NotEmptyException ( )
ConnectionLossException ( )
initCause ( )
NoAuthException ( )