Authored by wangning

update

package com.monitor.other.maliciousip.util;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.HBaseConfiguration;
import org.apache.hadoop.hbase.client.Connection;
import org.apache.hadoop.hbase.client.ConnectionFactory;
import java.io.IOException;
/**
* Created by wangning on 2017/9/22.
*/
public class HbasePool {
private static final String QUORUM = "10.66.80.5";
private static final String CLIENTPORT = "2181";
private static Configuration conf = null;
private static Connection conn = null;
static{
try {
conf = HBaseConfiguration.create();
conf.set("hbase.zookeeper.quorum", QUORUM);
conf.set("hbase.zookeeper.property.clientPort", CLIENTPORT);
conn = ConnectionFactory.createConnection(conf);
} catch (IOException e) {
e.printStackTrace();
}
}
public static synchronized Connection getConnection()
{
try{
if(conn == null || conn.isClosed())
{
conn = ConnectionFactory.createConnection(conf);
}
}catch (Exception e){
e.printStackTrace();
}
return conn;
}
}
... ...