centos hbase如何实现实时查询

在CentOS上实现HBase的实时查询，可以通过以下步骤来完成：

1. 安装和配置HBase

安装HBase

1. 下载HBase：

   wget https://archive.apache.org/dist/hbase/2.4.9/hbase-2.4.9-bin.tar.gz
   

2. 解压并移动到合适的位置：

   tar -zxvf hbase-2.4.9-bin.tar.gz
   mv hbase-2.4.9 /opt/hbase
   

3. 配置环境变量： 编辑/etc/profile.d/hbase.sh文件，添加以下内容：

   export HBASE_HOME=/opt/hbase
   export PATH=$PATH:$HBASE_HOME/bin
   

   然后使配置生效：

   source /etc/profile.d/hbase.sh
   

配置HBase

1. 编辑hbase-site.xml： 在$HBASE_HOME/conf目录下编辑hbase-site.xml文件，添加以下配置：

   <configuration>
       <property>
           <name>hbase.rootdir</name>
           <value>hdfs://namenode:8020/hbase</value>
       </property>
       <property>
           <name>hbase.cluster.distributed</name>
           <value>true</value>
       </property>
       <property>
           <name>hbase.zookeeper.quorum</name>
           <value>zookeeper1,zookeeper2,zookeeper3</value>
       </property>
       <property>
           <name>hbase.zookeeper.property.dataDir</name>
           <value>/var/lib/zookeeper</value>
       </property>
   </configuration>
   

2. 编辑core-site.xml： 在$HBASE_HOME/conf目录下编辑core-site.xml文件，添加以下配置：

   <configuration>
       <property>
           <name>fs.defaultFS</name>
           <value>hdfs://namenode:8020</value>
       </property>
   </configuration>
   

3. 编辑hdfs-site.xml： 在$HBASE_HOME/conf目录下编辑hdfs-site.xml文件，添加以下配置：

   <configuration>
       <property>
           <name>dfs.replication</name>
           <value>3</value>
       </property>
   </configuration>
   

2. 启动HBase集群

1. 格式化HDFS（如果尚未格式化）：

   hdfs namenode -format
   

2. 启动HDFS：

   start-dfs.sh
   

3. 启动Zookeeper：

   $HBASE_HOME/bin/start-zookeeper.sh
   

4. 启动HBase Master：

   $HBASE_HOME/bin/start-master.sh
   

5. 启动HBase RegionServer： 在其他节点上执行：

   $HBASE_HOME/bin/start-regionserver.sh
   

3. 创建表并插入数据

1. 创建表：

   hbase shell
   create 'my_table', 'cf1'
   

2. 插入数据：

   put 'my_table', 'row1', 'cf1:col1', 'value1'
   

4. 实时查询

使用HBase Shell进行实时查询

1. 打开HBase Shell：

   hbase shell
   

2. 扫描表：

   scan 'my_table'
   

使用Java API进行实时查询

1. 添加依赖： 在你的Java项目中添加HBase客户端依赖：

   <dependency>
       <groupId>org.apache.hbase</groupId>
       <artifactId>hbase-client</artifactId>
       <version>2.4.9</version>
   </dependency>
   

2. 编写Java代码：

   import org.apache.hadoop.conf.Configuration;
   import org.apache.hadoop.hbase.HBaseConfiguration;
   import org.apache.hadoop.hbase.TableName;
   import org.apache.hadoop.hbase.client.Connection;
   import org.apache.hadoop.hbase.client.ConnectionFactory;
   import org.apache.hadoop.hbase.client.Result;
   import org.apache.hadoop.hbase.client.Scan;
   import org.apache.hadoop.hbase.client.Table;
   import org.apache.hadoop.hbase.util.Bytes;
   
   public class HBaseRealTimeQuery {
       public static void main(String[] args) throws Exception {
           Configuration config = HBaseConfiguration.create();
           config.set("hbase.zookeeper.quorum", "zookeeper1,zookeeper2,zookeeper3");
           config.set("hbase.zookeeper.property.clientPort", "2181");
   
           try (Connection connection = ConnectionFactory.createConnection(config)) {
               Table table = connection.getTable(TableName.valueOf("my_table"));
               Scan scan = new Scan();
               ResultScanner scanner = table.getScanner(scan);
   
               for (Result result : scanner) {
                   System.out.println(result);
               }
           }
       }
   }
   

通过以上步骤，你可以在CentOS上实现HBase的实时查询。根据具体需求，你可以选择使用HBase Shell或Java API进行查询。