欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

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

程序员文章站 2022-03-11 14:37:13
1、用maven添加依赖(看清自己hbase版本)org.apache.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目录下

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

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集群内容请搜索以前的文章或继续浏览下面的相关文章希望大家以后多多支持!