【Hbase】Java 远程连接 Hbase 并处理表数据

本文涉及的产品
云原生网关 MSE Higress,422元/月
服务治理 MSE Sentinel/OpenSergo,Agent数量 不受限
注册配置 MSE Nacos/ZooKeeper,118元/月
简介: 【Hbase】Java 远程连接 Hbase 并处理表数据

1、在你的window系统下 找到c:/window/system32/drivers/etc/hosts 在末尾添加 虚拟机IP 虚拟机的hostname(如 192.168.56.100 gg)


2、在java代码中添加:


Configuration config = HBaseConfiguration.create();

config.set(“hbase.rootdir”,“hdfs://192.168.56.100:9000/hbase”);//和你的hadoop中core-site.xml中信息相同

config.set(“hbase.zookeeper.quorum”,“192.168.56.100”);//zookeeper地址

config.set(“hbase.zookeeper.property.clientPort”,“2181”);//zookeeper 端口


3、修改远程hbase中的hbase-site.xml文件末尾添加:


<property>
  <name>hbase.zookeeper.quorum</name>
  <value>192.168.56.100</value>
  </property>


4、重启远程hbase


5、代码测试:


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.Put;
import org.apache.hadoop.hbase.client.Table;
import org.apache.zookeeper.server.ConnectionBean;
import java.io.IOException;
public class MyHbase {
    public static void main(String[] args) throws IOException {
        Configuration config = HBaseConfiguration.create();
        config.set("hbase.rootdir","hdfs://192.168.56.100:9000/hbase");
        config.set("hbase.zookeeper.quorum","192.168.56.100");
        config.set("hbase.zookeeper.property.clientPort","2181");
        Connection connection = ConnectionFactory.createConnection(config);
        Table table = connection.getTable(TableName.valueOf("mtest:demo"));
        Put put = new Put("1".getBytes());
        put.addColumn("base".getBytes(),"name".getBytes(),"hehe".getBytes());
        put.addColumn("base".getBytes(),"sex".getBytes(),"female".getBytes());
        table.put(put);
    }
}


6、远程hbase查看数据


image.png


相关实践学习
云数据库HBase版使用教程
&nbsp; 相关的阿里云产品:云数据库 HBase 版 面向大数据领域的一站式NoSQL服务,100%兼容开源HBase并深度扩展,支持海量数据下的实时存储、高并发吞吐、轻SQL分析、全文检索、时序时空查询等能力,是风控、推荐、广告、物联网、车联网、Feeds流、数据大屏等场景首选数据库,是为淘宝、支付宝、菜鸟等众多阿里核心业务提供关键支撑的数据库。 了解产品详情:&nbsp;https://cn.aliyun.com/product/hbase &nbsp; ------------------------------------------------------------------------- 阿里云数据库体验:数据库上云实战 开发者云会免费提供一台带自建MySQL的源数据库&nbsp;ECS 实例和一台目标数据库&nbsp;RDS实例。跟着指引,您可以一步步实现将ECS自建数据库迁移到目标数据库RDS。 点击下方链接,领取免费ECS&amp;RDS资源,30分钟完成数据库上云实战!https://developer.aliyun.com/adc/scenario/51eefbd1894e42f6bb9acacadd3f9121?spm=a2c6h.13788135.J_3257954370.9.4ba85f24utseFl
目录
相关文章
|
9天前
|
存储 分布式计算 监控
Java一分钟之-Hazelcast:内存数据网格
【6月更文挑战第17天】**Hazelcast是开源的内存数据网格(IMDG),加速分布式环境中的数据访问,提供内存存储、分布式计算、线性扩展及高可用性。常见挑战包括内存管理、网络分区和数据分布不均。通过配置内存限制、优化网络和分区策略可避免问题。示例展示如何创建Hazelcast实例并使用分布式Map。使用Hazelcast提升性能和扩展性,关键在于理解和调优。**
22 1
|
12天前
|
缓存 NoSQL Java
Java高并发实战:利用线程池和Redis实现高效数据入库
Java高并发实战:利用线程池和Redis实现高效数据入库
32 0
|
1天前
|
Java
Java树状结构数据构建(基于hutool)
Java树状结构数据构建(基于hutool)
10 2
|
9天前
|
Java
在 Java 中,类是一种定义对象的模板,它包含数据成员(字段)和方法。
在 Java 中,类是一种定义对象的模板,它包含数据成员(字段)和方法。
|
14天前
|
JSON Java 数据格式
java读取接口返回的json数据 (二)
java读取接口返回的json数据 (二)
21 5
|
14天前
|
JSON Java 数据格式
java读取接口返回的json数据
java读取接口返回的json数据
22 5
|
14天前
|
Java 大数据 API
【大数据】HDFS、HBase操作教程(含指令和JAVA API)
【大数据】HDFS、HBase操作教程(含指令和JAVA API)
52 0
【大数据】HDFS、HBase操作教程(含指令和JAVA API)
|
1天前
|
JSON JavaScript Java
如何在Java中处理JSON数据?
如何在Java中处理JSON数据?
|
1天前
|
XML JavaScript Java
Java中如何处理XML数据?
Java中如何处理XML数据?
|
2天前
|
存储 Java 数据库连接
Java基础之数据载体定义及场景
Java开发中,对象按角色分为:PO(持久化对象,对应数据库表),DTO(数据传输对象,跨层传输数据),VO(值对象,用于页面展示),RO(资源对象,如文件连接)。此外,还有Entity(ORM实体),BO(业务对象),DAO(数据访问对象),SO(服务对象),FO(外观对象),AO(应用对象),EO(实体对象)和TO(传输对象),它们在不同场景下负责不同的职责,促进代码组织和解耦。
7 0