在hbase中添加测试数据 见《实验3-HBase安装及配置》的5、Hbase的基本使用 添加一张student表 修改配置文件 登录centos，用hadoop用户登录 ①修改hadoop核心配置 sudo vi /usr/local/hadoop/etc/hadoop/core-site.xml 结果如下 IP地址要根据自己的情况改成自己的centos系统IP地址。

保存退出（esc键，输入:wq） ②修改hbase核心配置文件hbase-site.xml sudo vi /usr/local/hbase/conf/hbase-site.xml IP地址要根据自己的情况改成自己的centos系统IP地址。

修改centos主机名 hostnamectl set-hostname hbasehost bash ?#及时生效

将配置文件拷贝出来 将hadoop的hdfs-site.xml、core-site.xml和hbase的hbase-site.xml拷贝出来，将来放到java项目中。 启动hadoop和hbase ssh localhost ①启动hadoop cd /usr/local/hadoop ./sbin/start-dfs.sh

查看是否启动完成 jps

②启动hbase cd /usr/local/hbase ./bin/start-hbase.sh

查看是否启动成功

进入shell界面 bin/hbase shell 在shell模式下输入help可以查看HBase相关的命令。 HBase中用create命令创建表，具体如下 create 'student','Sname','Ssex','Sage','Sdept','course'

此时，即创建了一个“student”表，属性有：Sname,Ssex,Sage,Sdept,course。因为HBase的表中会有一个系统默认的属性作为主键，故主键无需自行创建。创建完“student”表后，可通过describe命令查看“student”表的基本信息。 设置防火墙 Hbase启动后会占用60010端口，需要防火墙规则放过该端口，也可以暂时关闭防火墙（实际生产中这是很危险的） 查看防火墙状态 systemctl status firewalld.service

Ctrl+c 关闭防火墙 systemctl stop firewalld.service

修改windows的hosts 本次实验是在windows10中安装VMware虚拟机，建立了centos8的虚拟机，而后用windows版的idea建立java项目连接centos中的hbase，因此还需要修改hosts文件 C:WindowsSystem32driversetc 用文本编辑器打开该文件，在文件的最后添加： 192.168.1.5 hbasehost-server hbasehost IP地址要根据自己的情况改成自己的centos系统IP地址。 建立maven项目 ①设置Idea 拷贝settings.xml（该文件是Apache maven的配置文件可以自行下载，也可以拷贝老师的），修改settings.xml， 修改本地库存放路径 <localRepository>E:\Program Files\apache-maven-3.6.3\repository</localRepository>

在<mirrors>标签中添加下面内容 ? <mirror> ? ? ? <id>alimaven</id> ? ? ? <name>aliyun maven</name> ? ? ? <url>http://maven.aliyun.com/nexus/content/groups/public/</url> ? ? ? <mirrorOf>central</mirrorOf> ? ? ? ? ? ? </mirror> ? </mirrors>

如图：

在idea的设置中选择该文件：

②建立项目

③建立源代码目录和资源文件目录

将从虚拟机中拷贝出来的三个配置文件复制到resource目录下

修改pom.xml 在项目的配置文件中添加项目依赖库 在如下位置添加内容（阴影部分） <dependencies> ? <dependency> ? ? <groupId>junit</groupId> ? ? <artifactId>junit</artifactId> ? ? <version>4.11</version> ? ? <scope>test</scope> ? </dependency> ? <dependency> ? ? <groupId>org.apache.hbase</groupId> ? ? <artifactId>hbase-client</artifactId> ? ? <version>2.0.5</version> ? </dependency> ? <dependency> ? ? <groupId>com.alibaba</groupId> ? ? <artifactId>fastjson</artifactId> ? ? <version>1.2.75</version> ? </dependency> </dependencies>

编写程序 public class Main { ? ? public static void main(String[] args) { ? ? ? ? try { ? ? ? ? ? ? List<String> tables= getTables(); ? ? ? ? ? ? for(String table:tables){ ? ? ? ? ? ? ? ? System.out.println(table); ? ? ? ? ? ? } ? ? ? ? } catch (IOException e) { ? ? ? ? ? ? e.printStackTrace(); ? ? ? ? } ? ? } ? ? /** ? ? ?<br>功能描述: ?初始化配置 ? ? ?<br>处理逻辑: ? ? ?<br>修改记录: {修改人 修改原因 修改时间} ? ? ?* @param ? ? ?* @throws ? ? ?* @return org.apache.hadoop.conf.Configuration ? ? ?* @see # ? ? ?*/ ? ? public static Configuration initConfig(){ ? ? ? ? Configuration config = new Configuration(); ? ? ? ? //记住 ?写服务名 ?192.168.1.5 hbasehost-server hbasehost ? ? ? ? config.set("hbase.zookeeper.quorum","hbasehost"); ? ? ? ? return config; ? ? } ? ? /** ? ? ?<br>功能描述: ?获取数据库管理员对象 ? ? ?<br>处理逻辑: ? ? ?* @throws ? ? ?* @return org.apache.hadoop.hbase.client.Admin ? ? ?* @see # ? ? ?*/ ? ? public static Admin getAdmin() throws IOException { ? ? ? ? Configuration conf = initConfig(); ? ? ? ? Connection connection = ConnectionFactory.createConnection(conf); ? ? ? ? Admin admin = connection.getAdmin(); ? ? ? ? return admin; ? ? }

? ? /** ? ? ?<br>功能描述: ?检查hbase是否可用 ? ? ?<br>处理逻辑: ? ? ?<br>修改记录: {修改人 修改原因 修改时间} ? ? ?* @param ? ? ?* @throws ? ? ?* @return void ? ? ?* @see # ? ? ?*/ ? ? public static void isAvailable() throws IOException { ? ? ? ? Configuration conf = initConfig(); ? ? ? ? HBaseAdmin.available(conf); ? ? } ? ? /** ? ? ?<br>功能描述: ?获取表名集合 ? ? ?<br>处理逻辑: ? ? ?<br>修改记录: {修改人 修改原因 修改时间} ? ? ?* @param ? ? ?* @throws ? ? ?* @return java.util.List<java.lang.String> ? ? ?* @see # ? ? ?*/ ? ? public ?static List<String> getTables() throws IOException { ? ? ? ? Admin admin = getAdmin(); //获取hbase中所有的表名 ? ? ? ? TableName[] tableNames = admin.listTableNames(); ? ? ? ? List<String> tables = new ArrayList<String>(); ? ? ? ? for(TableName tableName:tableNames){ ? ? ? ? ? ? tables.add(tableName.getNameAsString()); ? ? ? ? } ? ? ? ? return tables; ? ? } }

运行结果：显示出里hbase中所有表 ?

?