Kerberos认证下: hbase,hive连接

逃离我推掉我的手 2023-07-01 08:47 32阅读 0赞

### 文章目录 ###

*  1, hbase java api
 *   *  a, 使用kerberos认证: UserGroupInformation.loginUserFromKeytab(kerberosUser, keytabPath)
     *  2, 具体代码
 *  2, hive java api

# 1, hbase java api #

## a, 使用kerberos认证: UserGroupInformation.loginUserFromKeytab(kerberosUser, keytabPath) ##

import org.apache.hadoop.security.UserGroupInformation;

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2V5ZW9mZWFnbGU_size_16_color_FFFFFF_t_70]

## 2, 具体代码 ##

*  maven依赖

<dependency>
        <groupId>org.apache.hbase</groupId>
        <artifactId>hbase-client</artifactId>
        <version>1.2.0</version>
    </dependency>
    <dependency>
        <groupId>org.apache.hbase</groupId>
        <artifactId>hbase-server</artifactId>
        <version>1.2.0</version>
    </dependency>

import com.google.protobuf.ServiceException;
    import org.apache.hadoop.conf.Configuration;
    import org.apache.hadoop.hbase.HBaseConfiguration;
    import org.apache.hadoop.hbase.KeyValue;
    import org.apache.hadoop.hbase.client.*;
    import org.apache.hadoop.security.UserGroupInformation;
    import java.io.IOException;
    
    public class TestKerberosHbase { 
        public static void main(String[] args) throws IOException, ServiceException { 
            // 注意加载:hbase-site.xml等配置文件到resources目录下，并打入jar包
            System.setProperty("java.security.krb5.realm","CDH.COM");
            System.setProperty("java.security.krb5.kdc","cdh-node2");
            Configuration conf = HBaseConfiguration.create();
            UserGroupInformation.setConfiguration(conf);
    
            final String user = "hbase/cdh-node1@CDH.COM";
            final String keyPath = "/hbase.keytab";
            UserGroupInformation.loginUserFromKeytab(user, keyPath);
    
            HTable table = new HTable(conf, "t1");
            System.out.println("tablename:" + new String(table.getTableName()));
            Scan s = new Scan();
            ResultScanner rs = table.getScanner(s);
    
            for (Result r : rs) { 
                System.out.println(r.toString());
            }
        }
    }

# 2, hive java api #

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2V5ZW9mZWFnbGU_size_16_color_FFFFFF_t_70 1]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2V5ZW9mZWFnbGU_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/20200121093905202.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2V5ZW9mZWFnbGU=,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2V5ZW9mZWFnbGU_size_16_color_FFFFFF_t_70 1]: https://img-blog.csdnimg.cn/20200121120054816.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2V5ZW9mZWFnbGU=,size_16,color_FFFFFF,t_70