解決Java?API不能遠(yuǎn)程訪(fǎng)問(wèn)HBase的問(wèn)題

更新時(shí)間：2022年06月15日 17:07:08 作者：涂有

這篇文章主要介紹了解決Java?API不能遠(yuǎn)程訪(fǎng)問(wèn)HBase的問(wèn)題，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教

Java API不能遠(yuǎn)程訪(fǎng)問(wèn)HBase

今天我在虛擬機(jī)里面安裝了Hbase 1.2.4，說(shuō)在windows上Java API調(diào)用訪(fǎng)問(wèn)下玩玩，結(jié)果始終連接不上。

現(xiàn)象是啟動(dòng)程序后，程序出現(xiàn)卡死的狀態(tài)，沒(méi)報(bào)錯(cuò)也不停止，大約半分鐘后才打印一堆日志出來(lái)，說(shuō)連接重試了多次也連接不上，截圖如下：

這個(gè)問(wèn)題糾結(jié)了我半天，一查看發(fā)現(xiàn)HBase綁定的是本地IP：127.0.0.1，這當(dāng)然訪(fǎng)問(wèn)不了

然后我想可以把HBase的綁定在指定IP上，去查Hbase官網(wǎng)，卻沒(méi)有這樣的配置項(xiàng)

后面百度下，發(fā)現(xiàn)HBase的這個(gè)問(wèn)題要特殊處理

分下面三步走，即可訪(fǎng)問(wèn)

1、配置Linux的hostname

2、配置Linux的hosts，映射ip的hostname的關(guān)系

3、配置訪(fǎng)問(wèn)windows的hosts

配置Llinux的hostname和hosts，這樣HBase啟動(dòng)的時(shí)候，就會(huì)自動(dòng)把HBase綁定到Linux域名對(duì)應(yīng)的ip上去

配置Linux的hostname

這里配置的hostname要Linux重啟才生效，為了不重啟就生效，我們可以執(zhí)行：hostname master命令，暫時(shí)設(shè)置hostname

配置Linux的hosts

映射ip的hostname的關(guān)系

配置完Linux的這兩項(xiàng)，啟動(dòng)HBase就發(fā)現(xiàn)HBase綁定到了我們想暴露的ip上了

配置訪(fǎng)問(wèn)windows的hosts

路徑為：C:\Windows\System32\drivers\etc\hosts

配置完這三項(xiàng)Java API就可以遠(yuǎn)程訪(fǎng)問(wèn)HBase了，切記最后配置windows的hosts也是必須的

最后附上Java代碼示例

package priv.tuyou.HBase;
import java.io.IOException;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.HBaseConfiguration;
import org.apache.hadoop.hbase.HColumnDescriptor;
import org.apache.hadoop.hbase.HTableDescriptor;
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;
 
/**
 * HBase 1.2.4
 * @author：涂有
 * @date 2017年7月12日 下午2:17:44
 */
public class HBase {
	
	public static Configuration conf;
	public static Connection connection;
	public static Admin admin;
 
	public static void main(String[] args) throws IOException {
 
		conf = HBaseConfiguration.create();
		conf.set("hbase.master", "192.168.142.129:16000");
		
		connection = ConnectionFactory.createConnection(conf);
		admin = connection.getAdmin();
		
		HTableDescriptor table = new HTableDescriptor(TableName.valueOf("table1"));
		table.addFamily(new HColumnDescriptor("group1")); //創(chuàng)建表時(shí)至少加入一個(gè)列組
		
		if(admin.tableExists(table.getTableName())){
			admin.disableTable(table.getTableName());
			admin.deleteTable(table.getTableName());
		}
		admin.createTable(table);
	}
 
}

POM文件，依賴(lài)HBase-client庫(kù)

	<dependencies>
		<!-- https://mvnrepository.com/artifact/org.apache.hbase/hbase-client -->
		<dependency>
		    <groupId>org.apache.hbase</groupId>
		    <artifactId>hbase-client</artifactId>
		    <version>1.2.4</version>
		</dependency>
	</dependencies>