Java MiniKdc类代码示例

OStack程序员社区-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Java中org.apache.hadoop.minikdc.MiniKdc类的典型用法代码示例。如果您正苦于以下问题：Java MiniKdc类的具体用法？Java MiniKdc怎么用？Java MiniKdc使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

MiniKdc类属于org.apache.hadoop.minikdc包，在下文中一共展示了MiniKdc类的16个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: setUpMiniKdc

import org.apache.hadoop.minikdc.MiniKdc; //导入依赖的package包/类
@BeforeClass
public static void setUpMiniKdc() throws Exception {
  File kdcDir = getTestDir();
  Properties kdcConf = MiniKdc.createConf();
  kdc = new MiniKdc(kdcConf, kdcDir);
  kdc.start();
  keytab = new File(kdcDir, "keytab");
  List<String> principals = new ArrayList<String>();
  principals.add("HTTP/localhost");
  principals.add("client");
  principals.add("hdfs");
  principals.add("otheradmin");
  principals.add("client/host");
  principals.add("client1");
  for (KMSACLs.Type type : KMSACLs.Type.values()) {
    principals.add(type.toString());
  }
  principals.add("CREATE_MATERIAL");
  principals.add("ROLLOVER_MATERIAL");
  kdc.createPrincipal(keytab,
      principals.toArray(new String[principals.size()]));
}

开发者ID:nucypher，项目名称:hadoop-oss，代码行数:23，代码来源:TestKMS.java

示例2: startMiniKdc

import org.apache.hadoop.minikdc.MiniKdc; //导入依赖的package包/类
@BeforeClass
public static void startMiniKdc() throws Exception {
  workDir = new File(System.getProperty("test.dir", "target"),
          TestFlumeAuthenticator.class.getSimpleName());
  flumeKeytab = new File(workDir, "flume.keytab");
  aliceKeytab = new File(workDir, "alice.keytab");
  conf = MiniKdc.createConf();

  kdc = new MiniKdc(conf, workDir);
  kdc.start();

  kdc.createPrincipal(flumeKeytab, flumePrincipal);
  flumePrincipal = flumePrincipal + "@" + kdc.getRealm();

  kdc.createPrincipal(aliceKeytab, alicePrincipal);
  alicePrincipal = alicePrincipal + "@" + kdc.getRealm();
}

开发者ID:moueimei，项目名称:flume-release-1.7.0，代码行数:18，代码来源:TestFlumeAuthenticator.java

示例3: initKdc

import org.apache.hadoop.minikdc.MiniKdc; //导入依赖的package包/类
@BeforeClass
public static void initKdc() throws Exception {
  baseDir = new File(System.getProperty("test.build.dir", "target/test-dir"),
    SaslDataTransferTestCase.class.getSimpleName());
  FileUtil.fullyDelete(baseDir);
  assertTrue(baseDir.mkdirs());

  Properties kdcConf = MiniKdc.createConf();
  kdc = new MiniKdc(kdcConf, baseDir);
  kdc.start();

  String userName = UserGroupInformation.getLoginUser().getShortUserName();
  File keytabFile = new File(baseDir, userName + ".keytab");
  keytab = keytabFile.getAbsolutePath();
  kdc.createPrincipal(keytabFile, userName + "/localhost", "HTTP/localhost");
  hdfsPrincipal = userName + "/[email protected]" + kdc.getRealm();
  spnegoPrincipal = "HTTP/[email protected]" + kdc.getRealm();
}

开发者ID:naver，项目名称:hadoop，代码行数:19，代码来源:SaslDataTransferTestCase.java

示例4: setUp

import org.apache.hadoop.minikdc.MiniKdc; //导入依赖的package包/类
@BeforeClass
public static void setUp() throws Exception {
  Properties conf = MiniKdc.createConf();
  conf.put(MiniKdc.DEBUG, true);
  KDC = new MiniKdc(conf, new File(TEST_UTIL.getDataTestDir("kdc").toUri().getPath()));
  KDC.start();
  USERNAME = UserGroupInformation.getLoginUser().getShortUserName();
  PRINCIPAL = USERNAME + "/" + HOST;
  HTTP_PRINCIPAL = "HTTP/" + HOST;
  KDC.createPrincipal(KEYTAB_FILE, PRINCIPAL, HTTP_PRINCIPAL);
  TEST_UTIL.startMiniZKCluster();

  HBaseKerberosUtils.setKeytabFileForTesting(KEYTAB_FILE.getAbsolutePath());
  HBaseKerberosUtils.setPrincipalForTesting(PRINCIPAL + "@" + KDC.getRealm());
  HBaseKerberosUtils.setSecuredConfiguration(TEST_UTIL.getConfiguration());
  setHdfsSecuredConfiguration(TEST_UTIL.getConfiguration());
  UserGroupInformation.setConfiguration(TEST_UTIL.getConfiguration());
  TEST_UTIL.getConfiguration().setStrings(CoprocessorHost.REGION_COPROCESSOR_CONF_KEY,
    TokenProvider.class.getName());
  TEST_UTIL.startMiniDFSCluster(1);
  Path rootdir = TEST_UTIL.getDataTestDirOnTestFS("TestGenerateDelegationToken");
  FSUtils.setRootDir(TEST_UTIL.getConfiguration(), rootdir);
  CLUSTER = new LocalHBaseCluster(TEST_UTIL.getConfiguration(), 1);
  CLUSTER.startup();
}

开发者ID:fengchen8086，项目名称:ditb，代码行数:26，代码来源:TestGenerateDelegationToken.java

示例5: initKdc

import org.apache.hadoop.minikdc.MiniKdc; //导入依赖的package包/类
@BeforeClass
public static void initKdc() throws Exception {
  baseDir = new File(System.getProperty("test.build.dir", "target/test-dir"),
    SaslDataTransferTestCase.class.getSimpleName());
  FileUtil.fullyDelete(baseDir);
  assertTrue(baseDir.mkdirs());

  Properties kdcConf = MiniKdc.createConf();
  kdc = new MiniKdc(kdcConf, baseDir);
  kdc.start();

  String userName = RandomStringUtils.randomAlphabetic(8);
  File userKeytabFile = new File(baseDir, userName + ".keytab");
  userKeyTab = userKeytabFile.getAbsolutePath();
  kdc.createPrincipal(userKeytabFile, userName + "/localhost");
  userPrincipal = userName + "/[email protected]" + kdc.getRealm();

  String superUserName = "hdfs";
  File hdfsKeytabFile = new File(baseDir, superUserName + ".keytab");
  hdfsKeytab = hdfsKeytabFile.getAbsolutePath();
  kdc.createPrincipal(hdfsKeytabFile, superUserName + "/localhost", "HTTP/localhost");
  hdfsPrincipal = superUserName + "/[email protected]" + kdc.getRealm();
  spnegoPrincipal = "HTTP/[email protected]" + kdc.getRealm();
}

开发者ID:aliyun-beta，项目名称:aliyun-oss-hadoop-fs，代码行数:25，代码来源:SaslDataTransferTestCase.java

示例6: initKdc

import org.apache.hadoop.minikdc.MiniKdc; //导入依赖的package包/类
@BeforeClass
public static void initKdc() throws Exception {
  baseDir = new File(System.getProperty("test.build.dir", "target/test-dir"));
  FileUtil.fullyDelete(baseDir);
  assertTrue(baseDir.mkdirs());
  Properties kdcConf = MiniKdc.createConf();
  kdc = new MiniKdc(kdcConf, baseDir);
  kdc.start();

  File keytabFile = new File(baseDir, "hdfs" + ".keytab");
  keytab = keytabFile.getAbsolutePath();
  kdc.createPrincipal(keytabFile, "hdfs" + "/localhost", "HTTP/localhost");
  hdfsPrincipal = "hdfs" + "/[email protected]" + kdc.getRealm();
  spnegoPrincipal = "HTTP/[email protected]" + kdc.getRealm();

  keytabFile = new File(baseDir, "connect-hdfs" + ".keytab");
  connectorKeytab = keytabFile.getAbsolutePath();
  kdc.createPrincipal(keytabFile, "connect-hdfs/localhost");
  connectorPrincipal = "connect-hdfs/[email protected]" + kdc.getRealm();
}

开发者ID:qubole，项目名称:streamx，代码行数:21，代码来源:TestWithSecureMiniDFSCluster.java

示例7: setUpKerberos

import org.apache.hadoop.minikdc.MiniKdc; //导入依赖的package包/类
@Before
public void setUpKerberos() throws Exception {
   kdc = new MiniKdc(MiniKdc.createConf(), temporaryFolder.newFolder("kdc"));
   kdc.start();

   // hard coded match, default_keytab_name in minikdc-krb5.conf template
   File userKeyTab = new File("target/test.krb5.keytab");
   kdc.createPrincipal(userKeyTab, "client", "amqp/localhost");

   if (debug) {
      java.util.logging.Logger logger = java.util.logging.Logger.getLogger("javax.security.sasl");
      logger.setLevel(java.util.logging.Level.FINEST);
      logger.addHandler(new java.util.logging.ConsoleHandler());
      for (java.util.logging.Handler handler : logger.getHandlers()) {
         handler.setLevel(java.util.logging.Level.FINEST);
      }
   }
}

开发者ID:apache，项目名称:activemq-artemis，代码行数:19，代码来源:JMSSaslGssapiTest.java

示例8: setUpKdcServer

import org.apache.hadoop.minikdc.MiniKdc; //导入依赖的package包/类
private static void setUpKdcServer() throws Exception {
  Properties conf = MiniKdc.createConf();
  conf.put(MiniKdc.DEBUG, true);
  File kdcFile = new File(UTIL.getDataTestDir("kdc").toUri().getPath());
  KDC = new MiniKdc(conf, kdcFile);
  KDC.start();
  USERNAME = UserGroupInformation.getLoginUser().getShortUserName();
  SERVER_PRINCIPAL = USERNAME + "/" + LOCALHOST;
  HTTP_PRINCIPAL = "HTTP/" + LOCALHOST;
  KDC.createPrincipal(KEYTAB_FILE,
    SERVER_PRINCIPAL,
    HTTP_PRINCIPAL,
    USER_ADMIN + "/" + LOCALHOST,
    USER_OWNER + "/" + LOCALHOST,
    USER_RX + "/" + LOCALHOST,
    USER_RO + "/" + LOCALHOST,
    USER_XO + "/" + LOCALHOST,
    USER_NONE + "/" + LOCALHOST);
}

开发者ID:apache，项目名称:hbase，代码行数:20，代码来源:TestSecureExport.java

示例9: startMiniKdc

import org.apache.hadoop.minikdc.MiniKdc; //导入依赖的package包/类
@Before
public void startMiniKdc() throws Exception {
  // This setting below is required. If not enabled, UGI will abort
  // any attempt to loginUserFromKeytab.
  Configuration conf = new Configuration();
  conf.set(CommonConfigurationKeys.HADOOP_SECURITY_AUTHENTICATION,
      "kerberos");
  UserGroupInformation.setConfiguration(conf);
  workDir = folder.getRoot();
  kdc = new MiniKdc(MiniKdc.createConf(), workDir);
  kdc.start();
}

开发者ID:nucypher，项目名称:hadoop-oss，代码行数:13，代码来源:TestUGILoginFromKeytab.java

示例10: startMiniKdc

import org.apache.hadoop.minikdc.MiniKdc; //导入依赖的package包/类
@BeforeClass
public static void startMiniKdc() throws Exception {
  workDir = new File(System.getProperty("test.dir", "target"));
  securityProperties = MiniKdc.createConf();
  kdc = new MiniKdc(securityProperties, workDir);
  kdc.start();
  keytab = createKeytab("foo");
  conf = new Configuration();
  conf.set(HADOOP_SECURITY_AUTHENTICATION, "KERBEROS");
}

开发者ID:nucypher，项目名称:hadoop-oss，代码行数:11，代码来源:TestKDiag.java

示例11: setUp

import org.apache.hadoop.minikdc.MiniKdc; //导入依赖的package包/类
@BeforeClass
public static void setUp() {
  try {
    testMiniKDC = new MiniKdc(MiniKdc.createConf(), testRootDir);
    setupKDC();
    setupAndStartRM();
  } catch (Exception e) {
    assertTrue("Couldn't create MiniKDC", false);
  }
}

开发者ID:naver，项目名称:hadoop，代码行数:11，代码来源:TestRMWebServicesDelegationTokenAuthentication.java

示例12: setUp

import org.apache.hadoop.minikdc.MiniKdc; //导入依赖的package包/类
@BeforeClass
public static void setUp() {
  try {
    testMiniKDC = new MiniKdc(MiniKdc.createConf(), testRootDir);
    setupKDC();
  } catch (Exception e) {
    assertTrue("Couldn't create MiniKDC", false);
  }
}

开发者ID:naver，项目名称:hadoop，代码行数:10，代码来源:TestRMWebappAuthentication.java

示例13: setupKDC

import org.apache.hadoop.minikdc.MiniKdc; //导入依赖的package包/类
@BeforeClass
public static void setupKDC() throws Exception {
  testRootDir = new File("target",
    TestRMWebServicesDelegationTokens.class.getName() + "-root");
  testMiniKDC = new MiniKdc(MiniKdc.createConf(), testRootDir);
  testMiniKDC.start();
  testMiniKDC.createPrincipal(httpSpnegoKeytabFile, "HTTP/localhost",
    "client", "client2", "client3");
}

开发者ID:naver，项目名称:hadoop，代码行数:10，代码来源:TestRMWebServicesDelegationTokens.java

示例14: setUp

import org.apache.hadoop.minikdc.MiniKdc; //导入依赖的package包/类
@BeforeClass
public static void setUp() {
  try {
    testMiniKDC = new MiniKdc(MiniKdc.createConf(), testRootDir);
    setupKDC();
    setupAndStartRM();
  } catch (Exception e) {
    fail("Couldn't create MiniKDC");
  }
}

开发者ID:naver，项目名称:hadoop，代码行数:11，代码来源:TestRMWebServicesHttpStaticUserPermissions.java

示例15: setupKDCAndPrincipals

import org.apache.hadoop.minikdc.MiniKdc; //导入依赖的package包/类
/**
 * Sets up the KDC and a set of principals in the JAAS file
 *
 * @throws Exception
 */
public static void setupKDCAndPrincipals() throws Exception {
  // set up the KDC
  File target = new File(System.getProperty("test.dir", "target"));
  kdcWorkDir = new File(target, "kdc");
  kdcWorkDir.mkdirs();
  if (!kdcWorkDir.mkdirs()) {
    assertTrue(kdcWorkDir.isDirectory());
  }
  kdcConf = MiniKdc.createConf();
  kdcConf.setProperty(MiniKdc.DEBUG, "true");
  kdc = new MiniKdc(kdcConf, kdcWorkDir);
  kdc.start();

  keytab_zk = createKeytab(ZOOKEEPER, "zookeeper.keytab");
  keytab_alice = createKeytab(ALICE, "alice.keytab");
  keytab_bob = createKeytab(BOB, "bob.keytab");
  zkServerPrincipal = Shell.WINDOWS ? ZOOKEEPER_1270001 : ZOOKEEPER_LOCALHOST;

  StringBuilder jaas = new StringBuilder(1024);
  jaas.append(registrySecurity.createJAASEntry(ZOOKEEPER_CLIENT_CONTEXT,
      ZOOKEEPER, keytab_zk));
  jaas.append(registrySecurity.createJAASEntry(ZOOKEEPER_SERVER_CONTEXT,
      zkServerPrincipal, keytab_zk));
  jaas.append(registrySecurity.createJAASEntry(ALICE_CLIENT_CONTEXT,
      ALICE_LOCALHOST , keytab_alice));
  jaas.append(registrySecurity.createJAASEntry(BOB_CLIENT_CONTEXT,
      BOB_LOCALHOST, keytab_bob));

  jaasFile = new File(kdcWorkDir, "jaas.txt");
  FileUtils.write(jaasFile, jaas.toString());
  LOG.info("\n"+ jaas);
  RegistrySecurity.bindJVMtoJAASFile(jaasFile);
}

开发者ID:naver，项目名称:hadoop，代码行数:39，代码来源:AbstractSecureRegistryTest.java

示例16: setUp

import org.apache.hadoop.minikdc.MiniKdc; //导入依赖的package包/类
@BeforeClass
public static void setUp() throws Exception {
  Properties conf = MiniKdc.createConf();
  conf.put(MiniKdc.DEBUG, true);
  KDC = new MiniKdc(conf, new File(TEST_UTIL.getDataTestDir("kdc").toUri().getPath()));
  KDC.start();
  PRINCIPAL = "hbase/" + HOST;
  KDC.createPrincipal(KEYTAB_FILE, PRINCIPAL);
  HBaseKerberosUtils.setKeytabFileForTesting(KEYTAB_FILE.getAbsolutePath());
  HBaseKerberosUtils.setPrincipalForTesting(PRINCIPAL + "@" + KDC.getRealm());
}

开发者ID:fengchen8086，项目名称:ditb，代码行数:12，代码来源:TestUsersOperationsWithSecureHadoop.java

注：本文中的org.apache.hadoop.minikdc.MiniKdc类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。

鲜花

握手

雷人

路过

鸡蛋

该文章已有0人参与评论

请发表评论

全部评论

专题导读

More+

10-27 六六分期app的软件客服如何联系？(六六分期

11-06 可心卡盟:win10系统火狐flash插件崩溃怎么

11-06 亲亲特价:怎么删除回收站图标

11-06 济南大学虚拟社区:鲁大师节能降温的具体办

11-06 xlueops.exe:无线网络安装向导

11-06 女斗合众国:win7系统cf与主机连接不稳定怎

11-06 0xc000022-[cf烟雾头]cf怎么调烟雾头

11-06 qizideyouhuo:应用程序无法正常启动0xc0000

11-06 ipz-185:win7系统vcf文件怎么打开

11-06 傻哥蹦迪:win10系统s4怎么打开usb调试

11-06 八神浩树gtaste:回收站清空了怎么恢复

11-06 妖尾之黑色守护:win10系统电脑没有1440x900

11-06 校园至尊魔王小说:win7系统浏览网页时字体

11-06 女斗合众国:win10系统访问共享文件夹提示请

11-06 tokyo hot n0654:恢复win7系统默认字体一招

11-06 雨酷仙境:设置win7系统转移临时文件夹腾出

11-06 阿穆纳伊之杖:win7系统开始菜单在右边还原

11-06 tunespotting:win10系统火狐flash插件总是

11-06 甘尔葛分析师：计谋网站seo关键词暴涨有什

11-06 蔡贵霖: 计谋网站seo关键词暴涨有什么秘密

11-06 博益网首页:ao3网页版进入不了解决方法

11-06 漏斗子专栏: 网站数据分析小白易懂精华篇

11-06 见证双虹怎么做:win7系统开启telnet命令的

11-06 颾狐蝶蜋:系统资源不足无法完成请求的服务

11-06 国光中学校歌:提交网站到alexa查询详细步骤

11-06 西安有情天:静态网页和动态网页的区别

11-06 红木雅尚斋:外部链接构造对网站的好处

11-06 前官礼遇：防止域名劫持–增强域安全性的10

11-06 密传二转答案: 中文分词算法有哪些

11-06 金泉家园邮编:百度快照劫持的表现及应对方

Java CompletableTransformer类代码示例发布时间：2022-05-21

Java SplitParentFirstComparator类代码示例发布时间：2022-05-21

剪的笔顺,诠释剪的笔画,认识剪的部首

1 六六分期app的软件客服如何联系？(六六分期

六六分期app的软件客服如何联系？不知道吗？加qq群【895510560】即可！标题：六六分期

阅读：19143|2023-10-27

2 可心卡盟:win10系统火狐flash插件崩溃怎么

今天小编告诉大家如何处理win10系统火狐flash插件总是崩溃的问题，可能很多用户都不知

阅读：9973|2022-11-06

3 亲亲特价:怎么删除回收站图标

今天小编告诉大家如何对win10系统删除桌面回收站图标进行设置，可能很多用户都不知道

阅读：8317|2022-11-06

4 济南大学虚拟社区:鲁大师节能降温的具体办

今天小编告诉大家如何对win10系统电脑设置节能降温的设置方法，想必大家都遇到过需要

阅读：8686|2022-11-06

5 xlueops.exe:无线网络安装向导

我们在使用xp系统的过程中,经常需要对xp系统无线网络安装向导设置进行设置，可能很多

阅读：8627|2022-11-06

6 女斗合众国:win7系统cf与主机连接不稳定怎

今天小编告诉大家如何处理win7系统玩cf老是与主机连接不稳定的问题，可能很多用户都不

阅读：9643|2022-11-06

7 0xc000022-[cf烟雾头]cf怎么调烟雾头

电脑对日常生活的重要性小编就不多说了，可是一旦碰到win7系统设置cf烟雾头的问题，很

阅读：8611|2022-11-06

8 qizideyouhuo:应用程序无法正常启动0xc0000

我们在日常使用电脑的时候，有的小伙伴们可能在打开应用的时候会遇见提示应用程序无法

阅读：7991|2022-11-06

9 ipz-185:win7系统vcf文件怎么打开

今天小编告诉大家如何对win7系统打开vcf文件进行设置，可能很多用户都不知道怎么对win

阅读：8642|2022-11-06

10 傻哥蹦迪:win10系统s4怎么打开usb调试

今天小编告诉大家如何对win10系统s4开启USB调试模式进行设置，可能很多用户都不知道怎

阅读：7527|2022-11-06

客服电话

电子邮件

Java MiniKdc类代码示例

示例1: setUpMiniKdc

示例2: startMiniKdc

示例3: initKdc

示例4: setUp

示例5: initKdc

示例6: initKdc

示例7: setUpKerberos

示例8: setUpKdcServer

示例9: startMiniKdc

示例10: startMiniKdc

示例11: setUp

示例12: setUp

示例13: setupKDC

示例14: setUp

示例15: setupKDCAndPrincipals

示例16: setUp

请发表评论

全部评论

上一篇：

下一篇：

tunespotting:win10系统火狐flash插件总是

CVE-2022-35378

watterott/Arduino-Libs: Arduino Libs &am

armancodv/building-energy-model-matlab:

FGRibreau/import-tweets-to-mastodon: How

剪的笔顺,诠释剪的笔画,认识剪的部首

六六分期app的软件客服如何联系？(六六分期

florent37/ViewAnimator: A fluent Android

florent37/Shrine-MaterialDesign2: implem

CVE-2020-36276

SimpleSoftwareIO/simple-sms: Send and re

关于我们

产品与服务

解决方案

139-2527-9053