云计算技术实验五 Hbase的安装和基础编程

您所在的位置：网站首页 › 云计算的总结和体会 › 云计算技术实验五 Hbase的安装和基础编程

云计算技术实验五 Hbase的安装和基础编程

#云计算技术实验五 Hbase的安装和基础编程| 来源: 网络整理| 查看: 265

参考资料为：

教材代码-林子雨编著《大数据基础编程、实验和案例教程（第2版）》教材所有章节代码_厦大数据库实验室博客

1.实验学时

4学时

2.实验目的

熟悉Hbase的安装和配置。熟悉Hbase的相关命令。实现Hbase的Java编程调用。

3.实验内容

（一）安装Hbase，能够查询Hbase的版本。

首先将压缩包传入linux中进行压缩：

后面把文件名改了，将hbash目录的权限赋值给hadoop用户：

然后在hbash路径下修改文件，配置环境变量：

先改变路径到hbash文件夹：

然后vim编译文件，加入路径名字：

然后使修改立刻生效：

然后添加用户权限：

将HBase安装目录下的所有文件所有者改成hadoop

然后查看版本号：

安装成功。

（二）单机运行Hbase系统。

先配置环境：(单机环境)

先配置java环境变量：

使用命令进入hbse-env.sh文件(vim进入)：路径为/usr/local/hbase/conf/hbase-env.sh

找到这两行修改：

修改成：

export JAVA_HOME=/usr/lib/jvm/jdk1.8.0_162

export HBASE_MANAGES_ZK=true

然后修改hbase-site.xml，使用下面指令进入文件。

vim /usr/local/hbase/conf/hbase-site.xml

添加配置：

然后测试运行hbase

先打开目录，然后再启动Hbase

启动成功：

然后可以停止运行hBase:

（三）实现Hbase的伪分布式启动。

进入要修改的文件

先配置hbase-env.sh文件，修改路径

然后再配置hbase-site.xml

然后启动hbase :

先登录ssh

然后启动hadoop :

输入jps命令，然后发现进程namenode、secondarynamenode、datanode都启动了

切换目录之后再启动hbase

出现以下进程说明启动成功：

进入hbase 的shell命令，

然后关闭hbase :

（四）运行Hbase相关的Shell命令，实现表的创建，数据插入，数据删除，以及数据查看等操作。

先启动hadoop:

然后启动hbase:

然后进入hbase的shell命令

1.创建表：

然后可以查看建完的表的信息：

2.然后是添加数据

3.添加多组数据

4.查看数据，这里返回95001行的数据；

这里使用get命令

使用scan命令

5.删除数据：

已经删除了这个信息：

删除全部信息：

6.然后是删除表的操作：

先让表不可使用

删除student表

7.查询历史信息：

先建立一个teacher表保存信息

插入数据后更新数据：

然后指定查询信息：

退出数据库，完成操作。

（五）实现Hbase的Java编程，在eclipse中创建项目，ExampleForHbase。java代码。

先启动hadoop，然后启动hbase

然后启动eclipse:

创建新的项目：

然后next之后在下一个界面点击libraries，之后选择add external jars

然后在usr/local/hbase/lib目录下选择要导入的jar包

然后进入最上面的目录导入剩下的jar包

完成之后点击finsh

之后右键新创建的hbaseexmaple创建一个新的class

然后输入代码：下面为java代码

import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.hbase.*; import org.apache.hadoop.hbase.client.*; import org.apache.hadoop.hbase.util.Bytes; import java.io.IOException; public class ExampleForHBase { public static Configuration configuration; public static Connection connection; public static Admin admin; public static void main(String[] args)throws IOException{ init(); createTable("student",new String[]{"score"}); insertData("student","zhangsan","score","English","69"); insertData("student","zhangsan","score","Math","86"); insertData("student","zhangsan","score","Computer","77"); getData("student", "zhangsan", "score","English"); close(); } public static void init(){ configuration = HBaseConfiguration.create(); configuration.set("hbase.rootdir","hdfs://localhost:9000/hbase"); try{ connection = ConnectionFactory.createConnection(configuration); admin = connection.getAdmin(); }catch (IOException e){ e.printStackTrace(); } } public static void close(){ try{ if(admin != null){ admin.close(); } if(null != connection){ connection.close(); } }catch (IOException e){ e.printStackTrace(); } } public static void createTable(String myTableName,String[] colFamily) throws IOException { TableName tableName = TableName.valueOf(myTableName); if(admin.tableExists(tableName)){ System.out.println("talbe is exists!"); }else { TableDescriptorBuilder tableDescriptor = TableDescriptorBuilder.newBuilder(tableName); for(String str:colFamily){ ColumnFamilyDescriptor family = ColumnFamilyDescriptorBuilder.newBuilder(Bytes.toBytes(str)).build(); tableDescriptor.setColumnFamily(family); } admin.createTable(tableDescriptor.build()); } } public static void insertData(String tableName,String rowKey,String colFamily,String col,String val) throws IOException { Table table = connection.getTable(TableName.valueOf(tableName)); Put put = new Put(rowKey.getBytes()); put.addColumn(colFamily.getBytes(),col.getBytes(), val.getBytes()); table.put(put); table.close(); } public static void getData(String tableName,String rowKey,String colFamily, String col)throws IOException{ Table table = connection.getTable(TableName.valueOf(tableName)); Get get = new Get(rowKey.getBytes()); get.addColumn(colFamily.getBytes(),col.getBytes()); Result result = table.get(get); System.out.println(new String(result.getValue(colFamily.getBytes(),col==null?null:col.getBytes()))); table.close(); } }