docker --hbase部署

拉取镜像

docker pull harisekhon/hbase

启动容器

docker run -d -h 127.0.0.1 -p 2181:2181 -p 8080:8080 -p 8085:8085 -p 9090:9090 -p 9000:9000  -p 9095:9095  -p 16000:16000  -p 16010:16010  -p 16201:16201  -p 16301:16301 -p 16020:16020 --name hbase  harisekhon/hbase

golang操作hbase

golang库

"github.com/tsuna/gohbase"

var GVA_HBASE_CLIENT gohbase.Client
funcinitHbaseClient(){
    GVA_HBASE_CLIENT = gohbase.NewClient("loclahost:2181")}funcHbasePut(){
    ctx, cancel := context.WithTimeout(context.Background(),30*time.Second)defercancel()// 将数据存储到 HBase
    putRequest, err := hrpc.NewPutStr(ctx, GVA_CONFIG.HbaseConfig.Dbname,"row_key",map[string]map[string][]byte{family:{"name3":[]byte("Tom3")}})if err !=nil{
        fmt.Println("Put 操作失败：", err)return}
    result, err := GVA_HBASE_CLIENT.Put(putRequest)if err !=nil{
        fmt.Println("数据存储失败：", err)return}
    fmt.Println(result)
    fmt.Printf("数据已存储到表 '%s' 中，行键为 'row_key'，列族为 '%s'\n", GVA_CONFIG.HbaseConfig.Dbname, family)}funcHbaseGet(){// 从 HBase 中查询数据
    getRequest, err := hrpc.NewGetStr(context.Background(), GVA_CONFIG.HbaseConfig.Dbname,"row_key")if err !=nil{
        fmt.Println("Get 操作失败：", err)return}
    getResp, err := GVA_HBASE_CLIENT.Get(getRequest)if err !=nil{
        fmt.Println("数据查询失败：", err)return}
    fmt.Printf("%+v:\n", getResp)// result := getResp.Result()// for _, cell := range result.Cells {//     fmt.Printf("列族：%s，列名：%s，值：%s\n", cell.Family, cell.Qualifier, cell.Value)// }}