在本地用idea连接虚拟机上的hbase集群的实现代码

 更新时间:2020年10月17日 12:05:56   作者:轻描丶幸福的旋律  
这篇文章主要介绍了在本地用idea连接虚拟机上的hbase集群的实现代码,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下

1、用maven添加依赖(看清自己hbase版本)

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

2、将虚拟机上的hbase-site.xml文件放到resourcs目录下

在这里插入图片描述

3、修改本机的hosts文件(在C:\Windows\System32\drivers\etc下)
添加集群的IP 名称
192.168.124.116 Master
192.168.124.115 Slave1
192.168.124.130 Slave2

4、代码举例,判断表是否存在

package com.zyb.test;

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.HBaseConfiguration;
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 java.io.IOException;

public class TestDemo {


  public static Connection connection=null;
  public static Admin admin=null;
  static {
    try {
      //1、获取配置信息
      Configuration configuration = HBaseConfiguration.create();
      configuration.set("hbase.rootdir", "hdfs://192.168.124.116:9000/HBase");
      configuration.set("hbase.zookeeper.quorum","Master,Slave1,Slave2");
      //2、创建连接对象
      connection= ConnectionFactory.createConnection(configuration);
      //3、创建Admin对象
      admin = connection.getAdmin();
    } catch (IOException e) {
      e.printStackTrace();
    }
  }

  //判断表是否存在
  public static boolean isTableExiat(String tableName) throws IOException {
    boolean exists = admin.tableExists(TableName.valueOf(tableName));
    return exists;
  }

  public static void close(){
    if (admin!=null){
      try {
        admin.close();
      } catch (IOException e) {
        e.printStackTrace();
      }
    }
    if (connection!=null){
      try {
        connection.close();
      } catch (IOException e) {
        e.printStackTrace();
      }
    }
  }
  public static void main(String[] args) throws IOException {
    System.out.println(isTableExiat("student"));
    //关闭资源
    close();
  }
}

到此这篇关于在本地用idea连接虚拟机上的hbase集群的实现代码的文章就介绍到这了,更多相关idea连接虚拟机hbase集群内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!

相关文章

  • java由JABXContext注解读取xml配置文件方式

    java由JABXContext注解读取xml配置文件方式

    这篇文章主要介绍了java由JABXContext注解读取xml配置文件方式,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2023-06-06
  • Mybatis无法获取带有下划线前缀的字段的值问题

    Mybatis无法获取带有下划线前缀的字段的值问题

    这篇文章主要介绍了Mybatis无法获取带有下划线前缀的字段的值问题,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2021-12-12
  • Java详细讲解文件的读写操作方法

    Java详细讲解文件的读写操作方法

    文件读写主要依靠io流完成,流(Stream)是指一连串的数据(字符或字节),是以先进先出的方式发送信息的通道,数据源发送的数据经过这个通道到达目的地,按流向区分为输入流和输出流
    2022-04-04
  • Java安全后端返回文件流方式

    Java安全后端返回文件流方式

    这篇文章主要介绍了Java安全后端返回文件流方式,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2023-07-07
  • 分布式服务Dubbo+Zookeeper安全认证实例

    分布式服务Dubbo+Zookeeper安全认证实例

    下面小编就为大家分享一篇分布式服务Dubbo+Zookeeper安全认证实例,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧
    2017-12-12
  • IDEA反编译出整个jar包源码

    IDEA反编译出整个jar包源码

    InteliJ IDEA默认带反编译插件,那么如何把反编译的jar包整体导出java源码来?本文就来介绍一下,感兴趣的可以了解下
    2021-05-05
  • Spring负载均衡LoadBalancer使用详解

    Spring负载均衡LoadBalancer使用详解

    这篇文章主要介绍了Spring负载均衡LoadBalancer使用详解,Spring Cloud LoadBalancer是Spring Cloud官方自己提供的客户端负载均衡器, 用来替代Ribbon,Spring官方提供了两种客户端都可以使用loadbalancer,需要的朋友可以参考下
    2023-11-11
  • Java不要再使用!=null判空了!

    Java不要再使用!=null判空了!

    这篇文章主要给大家介绍了关于Java不要再使用!=null判空的相关资料,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2020-11-11
  • springmvc—handlermapping三种映射方式

    springmvc—handlermapping三种映射方式

    这篇文章主要介绍了springmvc—handlermapping三种映射方式,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2021-09-09
  • Intellij IDEA创建web项目的超详细步骤记录

    Intellij IDEA创建web项目的超详细步骤记录

    如果刚开始接触IDEA,或者之前使用的是eclipse/myEclipse的话,即使是创建一个JAVA WEB项目,估计也让很多人费了好几个小时,下面这篇文章主要给大家介绍了关于Intellij IDEA创建web项目的超详细步骤,需要的朋友可以参考下
    2022-08-08

最新评论