目录

• 开发环境
• 步骤
• • 下载并安装protobuf
  • 编写 `user.proto`
  • 使用Protobuf编译器将该文件编译成目标语言
  • 测试
• 测试项目地址

开发环境

• Hbase-2.2.7集群
• Hadoop-3.1.1集群
• Zookeeper-3.5.6集群
• protobuf-2.5.0

开发环境的配置见前几篇文章, 软件下载可自行百度，或者关注后端码匠回复电脑环境下载

步骤

下载并安装protobuf

解压 protobuf-2.5.0

进入protobuf-2.5.0

./configur

make

make install

安装编译时间较长，耐心等待⌛️

编写 user.proto

package cn.com.codingce.hbase;message UserDetail {required string username = 1;required string password = 2; }//这是一个类，该类对象中包含很多UserDetail对象，每个UserDetail 对象是一条记录，dayUserDetail类的对象其实就相当于Java的集合。 message dayUserDetail {required UserDetail dayUserDetail=1; //属性名称就是类名，相当于该类是一个集合存放的泛型是UserDetail （写法和Java不同，注意理解即可） }

需要注意的是文件名不能和类名一样

使用Protobuf编译器将该文件编译成目标语言

执行编译

./protoc --java_out=/root/ ./user.proto

生成成功

测试

业务代码

package cn.com.codingce.hbase;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.MasterNotRunningException; import org.apache.hadoop.hbase.TableName; import org.apache.hadoop.hbase.ZooKeeperConnectionException; import org.apache.hadoop.hbase.client.Admin; import org.apache.hadoop.hbase.client.Connection; import org.apache.hadoop.hbase.client.ConnectionFactory; import org.apache.hadoop.hbase.client.Put; import org.apache.hadoop.hbase.client.Table;import java.io.IOException;/*** @author williamma*/ public class ProtoTest {public static void main(String[] args) throws IOException {// createTable("usertest", "info");addRowData("usertest", "1006");}//获取 Configuration 对象public static Configuration conf;static {//使用 HBaseConfiguration 的单例方法实例化conf = HBaseConfiguration.create();conf.set("hbase.zookeeper.quorum", "你的ip");conf.set("hbase.zookeeper.property.clientPort", "2181");}/*** 获取连接** @return* @throws IOException*/public static Connection getConnection() throws IOException {Connection connection = ConnectionFactory.createConnection(conf);System.out.println("创建连接。。。" + connection);return connection;}/*** 向表中插入数据** @param tableName* @param rowKey* @throws IOException*/public static void addRowData(String tableName,String rowKey) throws IOException {Connection connection = getConnection();//查询数据//获取指定表对象Table table = connection.getTable(TableName.valueOf(tableName));User.UserDetail.Builder userDetail = User.UserDetail.newBuilder(); // userDetail.setUsername("Mike"); // userDetail.setPassword("Mike");userDetail.setUsername("HEHE");userDetail.setPassword("HEHE");Put put = new Put(rowKey.getBytes());put.addColumn("info".getBytes(), "userDetail".getBytes(), userDetail.build().toByteArray());table.put(put);System.out.println("插入成功。。。");}/*** 创建表** @param tableName* @param columnFamily* @throws MasterNotRunningException* @throws ZooKeeperConnectionException* @throws IOException*/public static void createTable(String tableName, String... columnFamily) throwsMasterNotRunningException, ZooKeeperConnectionException, IOException {Connection connection = getConnection();Admin admin = connection.getAdmin();//判断表是否存在if (isTableExist(tableName)) {System.out.println("表 " + tableName + "已存在");//System.exit(0);} else {//创建表//创建表属性对象,表名需要转字节HTableDescriptor descriptor = new HTableDescriptor(TableName.valueOf(tableName));//创建多个列族for (String cf : columnFamily) {descriptor.addFamily(new HColumnDescriptor(cf));}//根据对表的配置，创建表admin.createTable(descriptor);System.out.println("表 " + tableName + "创建成功!");}}/*** 判断表是否存在** @param tableName* @return* @throws MasterNotRunningException* @throws ZooKeeperConnectionException* @throws IOException*/public static boolean isTableExist(String tableName) throws MasterNotRunningException,ZooKeeperConnectionException, IOException {//在 HBase 中管理、访问表需要先创建 HBaseAdmin 对象//Connection connection = ConnectionFactory.createConnection(conf);// HBaseAdmin admin = (HBaseAdmin) connection.getAdmin();Connection connection = getConnection();Admin admin = connection.getAdmin();boolean result = admin.tableExists(TableName.valueOf(tableName));System.out.println("表是否存在：" + result);return result;} }

测试项目地址

[Github]：https://github.com/xzMhehe/codingce-java

[Gitee]：https://gitee.com/codingce/codingce-java

如有问题欢迎评论区讨论

总结

以上是生活随笔为你收集整理的Hbase之protobuf的使用的全部内容，希望文章能够帮你解决所遇到的问题。

如果觉得生活随笔网站内容还不错，欢迎将生活随笔推荐给好友。