设为首页 加入收藏

TOP

java代码连接HBase(开启Kerberos和Sentry)
2018-12-18 17:47:03 】 浏览:74
Tags:java 代码 连接 HBase 开启 Kerberos Sentry

创建一个ZH_WG/wldatanode019的principal,并生成ZH_WG.keytab文件。
将hbase-site.xml和ZH_WG.keytab文件拷贝到conf目录下。注意,运行HBase代码的jar包放在当前目录下,而conf目录是当前目录的一个子目录。具体代码如下:

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.Path;
import org.apache.hadoop.hbase.HBaseConfiguration;
import org.apache.hadoop.hbase.HColumnDescriptor;
import org.apache.hadoop.hbase.HTableDescriptor;
import org.apache.hadoop.hbase.TableName;
import org.apache.hadoop.hbase.client.Admin;
import org.apache.hadoop.hbase.client.Connection;
import org.apache.hadoop.hbase.client.ConnectionFactory;
import org.apache.hadoop.security.UserGroupInformation;

import java.io.File;
import java.io.IOException;

public class HBaseSimple {
    private static Configuration conf = null;
    private static String confPath = System.getProperty("user.dir") + File.separator + "conf";

    public static void main(String[] args) throws IOException{
        String principal = "ZH_WG/wldatanode019@HXDI.COM";
        String keytabPath = confPath + File.separator + "ZH_WG.keytab";

        conf = HBaseConfiguration.create();

        System.setProperty("java.security.krb5.conf", confPath + File.separator + "krb5.conf");
        conf.addResource(new Path(confPath + File.separator + "hbase-site.xml"));
        conf.set("hadoop.security.authentication" , "Kerberos" );

        UserGroupInformation. setConfiguration(conf);
        try {
            UserGroupInformation ugi = UserGroupInformation.loginUserFromKeytabAndReturnUGI(principal, keytabPath);
            UserGroupInformation.setLoginUser(ugi);
        }
        catch (IOException e) {
            throw new RuntimeException("Kerberos 身份认证失败:" + e.getMessage(), e);
        }

        createTable();

    }

    public static void createTable() throws IOException {
        Connection connection = ConnectionFactory.createConnection(conf);
        System.out.println("HBase connected");
        Admin admin = connection.getAdmin();
        TableName tableName = TableName.valueOf("test1");

        HTableDescriptor tableDescriptor = new HTableDescriptor(tableName);
        HColumnDescriptor columnDescriptor1 = new HColumnDescriptor("c1");
        HColumnDescriptor columnDescriptor2 = new HColumnDescriptor("c2");

        tableDescriptor.addFamily(columnDescriptor1);
        tableDescriptor.addFamily(columnDescriptor2);

        admin.createTable(tableDescriptor);
        System.out.println("Table created");

        admin.close();
        connection.close();
    }
}
】【打印繁体】【投稿】【收藏】 【推荐】【举报】【评论】 【关闭】 【返回顶部
上一篇[HBase进阶]-- 基本API操作详解 下一篇HBase入门基本:命名空间、建表、..

最新文章

热门文章

Hot 文章

Python

C 语言

C++基础

大数据基础

linux编程基础

C/C++面试题目