hbase2.1.x java 连接Hbase、关闭连接-马育民老师

# 连接 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();
    }
}

```

原文出处：http://www.malaoshi.top/show_1GW1fY91EsRx.html