连接Hbase客户端工具，可视化界面

cd %cd%

D:\work\jdk1.8.0_181\bin\java.exe -jar "hbase-1.2-browser-rc.jar"

pause

# localhost name resolution is handled within DNS itself.

#     127.0.0.1       localhost

#     ::1             localhost

192.168.100.15  cln-wpms8

192.168.100.16  cln-yydu61

public class ConnectionManager implements IHbConnectionManager {
    private Connection connection;

    public ConnectionManager() {
    }

    public Connection getConnection() throws ConnectionException {
        return this.connection;
    }

    public boolean connect(Map parameters) throws ConnectionException {
        Configuration config = HBaseConfiguration.create();
        config.clear();
        String hbaseZookeeperQuorum = (String)parameters.get("zkq");
        String hbaseZookeperClientPort = (String)parameters.get("zkPort");
        config.set("hbase.zookeeper.quorum", hbaseZookeeperQuorum);
        config.set("hbase.zookeeper.property.clientPort", hbaseZookeperClientPort);
        try {
            HBaseAdmin.checkHBaseAvailable(config);
            this.connection = ConnectionFactory.createConnection(config);
            return true;
        } catch (Throwable var6) {
            logger.error("Connecting to HBase Failed." + var6);
            throw new ConnectionException("Could not connect to HBase Cluster " + parameters, var6);
        }
    }

    public boolean close() {
        try {
            if (this.connection != null) {
                this.connection.close();
                return true;
            }
        } catch (IOException var2) {
            logger.warn("There was an error in closing the connection");
        }

        return false;
    }
}