连接 hbase、关闭连接

package top.malaoshi;

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.HBaseConfiguration;
import org.apache.hadoop.hbase.TableName;
import org.apache.hadoop.hbase.client.*;
import org.apache.hadoop.hbase.util.Bytes;
import org.apache.log4j.Logger;

import java.io.IOException;

public class HbaseUtils {
    private static final Logger LOG=Logger.getLogger(TableOP.class);

    private Connection conn;

    /**
     * 
     * @param zkAddr zookeeper集群地址，多个用 , 分割
     * @param port zookeeper端口号，默认是2181
     * @throws IOException
     */
    public void connect(String zkAddr,String port) throws IOException {
        //创建hbase配置对象
        Configuration conf = HBaseConfiguration.create();
        conf.set("hbase.zookeeper.quorum", zkAddr);// zookeeper地址
        conf.set("hbase.zookeeper.property.clientPort", port);// zookeeper端口
        //通过配置对象创建连接
        conn = ConnectionFactory.createConnection(conf);
    }


    /**
     * 关闭连接
     * @throws IOException
     */
    public void close() throws IOException {
        if (conn!=null && !conn.isClosed()){
            conn.close();
        }
    }

    public static void main(String[] args) throws IOException {
        HbaseUtils utils=new HbaseUtils();
        utils.connect("hadoop1,hadoop2,hadoop3","2181");
        System.out.println("连接成功！");
        utils.close();
    }
}

原文出处：/show_1GW1fY91EsRx.html