互信场景多实例认证

        List<String> confDirectorys = new ArrayList<>();
        List<Configuration> confs = new LinkedList<>();
        try {
            // conf directory
            confDirectorys.add("hadoopDomain");[1]
            confDirectorys.add("hadoop1Domain");[2]
 
            for (String confDir : confDirectorys) {
                confs.add(init(confDir));[3]
            }
 
            login(confs.get(0), confDirectorys.get(0));[4]
        } catch (IOException e) {
            LOG.error("Failed to login because ", e);
            return;
        }

[1]此处hadoopDomain为保存用户凭证和其中一个集群的配置文件目录名称，该目录相对路径为hbase-example/src/main/resources/hadoopDomain，可根据需要进行变更。

[2]此处hadoop1Domain为保存另一个集群配置文件的目录名称，该目录相对路径为hbase-example/src/main/resources/hadoop1Domain，可根据需要进行变更。

[3]依次初始化conf对象。

[4]进行登录认证。

private static Configuration init(String confDirectoryName) throws IOException {
        // Default load from conf directory
        Configuration conf = HBaseConfiguration.create();
        //In Windows environment
        String userdir = TestMain.class.getClassLoader().getResource(confDirectoryName).getPath() + File.separator;
        //In Linux environment
        //String userdir = System.getProperty("user.dir") + File.separator + confDirectoryName + File.separator;
        conf.addResource(new Path(userdir + "core-site.xml"), false);
        conf.addResource(new Path(userdir + "hdfs-site.xml"), false);
        conf.addResource(new Path(userdir + "hbase-site.xml"), false);
        return conf;
}

请根据实际情况，修改“userName”为实际用户名，例如“developuser”。

private static void login(Configuration conf, String confDir) throwsIOException {      

        if (User.isHBaseSecurityEnabled(conf)) {
           userName = " developuser ";

           //In Windows environment
           String userdir = TestMain.class.getClassLoader().getResource(confDir).getPath() + File.separator;
           //In Linux environment
           //String userdir = System.getProperty("user.dir") + File.separator + confDir + File.separator;

           userKeytabFile = userdir + "user.keytab";
           krb5File = userdir + "krb5.conf";
  
           /*  

            * if need to connect zk, please provide jaas info about zk. of course,
            * you can do it as below:
            * System.setProperty("java.security.auth.login.config",confDirPath +
            * "jaas.conf"); but the demo can help you more : Note: if this process
            * will connect more than one zk cluster, the demo may be not proper. you
            * can contact us for more help
            */

            LoginUtil.setJaasConf(ZOOKEEPER_DEFAULT_LOGIN_CONTEXT_NAME, userName,userKeytabFile);
            LoginUtil.login(userName, userKeytabFile, krb5File, conf);
        }
}