最近有需求說是根據多個RowKey返回結果集：

public static Configuration conf = null;
    public static Connection connection = null;
    public static Admin admin = null;
    static {
        conf = HBaseConfiguration.create();
 
        conf.set("hbase.zookeeper.quorum", "10.120.193.800,10.120.193.810");
        conf.set("hbase.master", "10.120.193.730:60010");
        conf.set("hbase.zookeeper.property.clientPort", "2181"); 
        //conf.set("zookeeper.znode.parent", "/hbase-unsecure");
        //conf.set("hbase.client.keyvalue.maxsize", "1048576000"); //1G
        conf = HBaseConfiguration.create(conf);
        try {
            connection = ConnectionFactory.createConnection(conf);
            admin = connection.getAdmin();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
 

Hbase表操作

    public static List<String> qurryTableTest(List<String> rowkeyList) throws IOException {
        String tableName = "xxxxx";
        Table table = connection.getTable( TableName.valueOf(tableName));// 獲取表
        for (String rowkey : rowkeyList){
            Get get = new Get(Bytes.toBytes(rowkey));
            Result result = table.get(get);
            for (Cell kv : result.rawCells()) {
                String value = Bytes.toString(CellUtil.cloneValue(kv));
                list.add(value);
            }
        }
        return list;
    }
 

Hbase的get原碼如下：

public Result[] get(List<Get> gets) throws IOException {
        if(gets.size() == 1) {
            return new Result[]{this.get((Get)gets.get(0))};
        } else {
            try {
                Object[] r1 = this.batch(gets);
                Result[] results = new Result[r1.length];
                int i = 0;
                Object[] arr$ = r1;
                int len$ = r1.length;
 
                for(int i$ = 0; i$ < len$; ++i$) {
                    Object o = arr$[i$];
                    results[i++] = (Result)o;
                }
 
                return results;
            } catch (InterruptedException var9) {
                throw (InterruptedIOException)(new InterruptedIOException()).initCause(var9);
            }
        }
    }
 

實現 多RowKey方式如下：

public static List<String> qurryTableTestBatch(List<String> rowkeyList) throws IOException {
        List<Get> getList = new ArrayList();
        String tableName = "table_a";
        Table table = connection.getTable( TableName.valueOf(tableName));// 獲取表
        for (String rowkey : rowkeyList){//把rowkey加到get裡，再把get裝到list中
            Get get = new Get(Bytes.toBytes(rowkey));
            getList.add(get);
        }
        Result[] results = table.get(getList);//重點在這，直接查getList<Get>
        for (Result result : results){//對返回的結果集進行操作
            for (Cell kv : result.rawCells()) {
                String value = Bytes.toString(CellUtil.cloneValue(kv));
                list.add(value);
            }
        }
        return list;
    }