使用场景：

    • 大数据量支持PB
    • Nosql

    多元索引功能类似es，但是个人用户不建议，因为有预留实例，每小时0.02元，因此，暂时放弃使用。
    二级索引类似mysql，但是没有mysql好用。

    官网控制台
    官方实例
    官方文档

    1. <dependency>
    2.     <groupId>com.aliyun.fc.runtime</groupId>
    3.     <artifactId>fc-java-core</artifactId>
    4.     <version>1.3.0</version>
    5. </dependency>
    1. package com.alvin.service.impl;
    3. import com.alicloud.openservices.tablestore.ClientException;
    4. import com.alicloud.openservices.tablestore.SyncClient;
    5. import com.alicloud.openservices.tablestore.TableStoreException;
    6. import com.alicloud.openservices.tablestore.model.*;
    7. import com.alicloud.openservices.tablestore.model.search.SearchQuery;
    8. import com.alicloud.openservices.tablestore.model.search.SearchRequest;
    9. import com.alicloud.openservices.tablestore.model.search.SearchResponse;
    10. import com.alicloud.openservices.tablestore.model.search.agg.AggregationBuilders;
    11. import com.alicloud.openservices.tablestore.model.search.agg.CountAggregation;
    12. import com.alicloud.openservices.tablestore.model.search.query.QueryBuilder;
    13. import com.alicloud.openservices.tablestore.model.search.query.QueryBuilders;
    14. import com.alvin.entity.Picture;
    15. import com.alvin.entity.PictureVO;
    16. import com.alvin.service.RandomPicService;
    17. import org.apache.commons.io.FileUtils;
    18. import org.springframework.stereotype.Service;
    20. import java.io.*;
    21. import java.util.List;
    22. import java.util.Random;
    24. /**
    25.  * @Description
    26.  * @Author 田云
    27.  * @Date 2020/3/19 21:20
    28.  * @Version 1.0
    29.  */
    30. @Service
    31. public class RandomPicServiceImpl implements RandomPicService {
    33.     public static final String INDEX = "picture_index";
    34.     //static String endPoint = "123";
    35.     static String endPoint = "123";
    36.     static String accessKeyId = "123";
    37.     static String accessKeySecret = "123";
    38.     static String instanceName = "randomPic";
    40.     public static String TABLE_NAME = "picture";
    41.     public static SyncClient client = new SyncClient(endPoint, accessKeyId, accessKeySecret, instanceName);
    43.     /**
    44.      * 随机url
    45.      *
    46.      * @param type
    47.      * @return
    48.      */
    49.     @Override
    50.     public String randomUrl(String type) {
    51.         QueryBuilder builder;
    52.         if (type == null) {
    53.             builder = QueryBuilders.matchAll();
    54.         } else {
    55.             builder = QueryBuilders.term(Picture.Fields.type, type);
    56.         }
    57.         CountAggregation.Builder count1 = AggregationBuilders.count("count", Picture.Fields.type);
    58.         /*
    59.         查询多少条数据
    60.          */
    61.         SearchRequest searchRequest = SearchRequest.newBuilder()
    62.                 .tableName(TABLE_NAME)
    63.                 .indexName(INDEX)
    64.                 .searchQuery(
    65.                         SearchQuery.newBuilder()
    66.                                 .query(builder)
    67.                                 .limit(0)
    68.                                 .addAggregation(count1)
    69.                                 .build())
    70.                 .build();
    71.         System.out.println(searchRequest);
    73.         SearchResponse resp = client.search(searchRequest);
    74.         //获取统计聚合的结果
    75.         long count = resp.getAggregationResults().getAsCountAggregationResult("count").getValue();
    77.         /*
    78.         再次查询
    79.          */
    80.         int i = new Random().nextInt((int) count);
    81.         SearchRequest searchRequest2 = SearchRequest.newBuilder()
    82.                 .tableName(TABLE_NAME)
    83.                 .indexName("picture_index")
    84.                 .addColumnsToGet(Picture.Fields.type)
    85.                 .searchQuery(
    86.                         SearchQuery.newBuilder()
    87.                                 .query(builder)
    88.                                 .limit(1)
    89.                                 .offset(i)
    90.                                 .addAggregation(count1)
    91.                                 .build())
    92.                 .build();
    94.         SearchResponse resp2 = client.search(searchRequest2);
    95.         Row row = resp2.getRows().get(0);
    96.         return String.valueOf(row.getPrimaryKey().getPrimaryKeyColumn("url").getValue());
    97.     }
    99.     private Picture getPicture(Row row) {
    100.         return Picture.builder()
    101.                 .url(String.valueOf(row.getPrimaryKey().getPrimaryKeyColumn("url").getValue()))
    102.                 .type(String.valueOf(row.getColumns()[0].getValue()))
    103.                 .build();
    104.     }
    106.     @Override
    107.     public void inserts(PictureVO pictureVO) {
    108.         BatchWriteRowRequest batchWriteRowRequest = new BatchWriteRowRequest();
    109.         for (String url : pictureVO.getUrls()) {
    110.             //描述主键信息
    111.             PrimaryKeyBuilder primaryKeyBuilder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
    112.             primaryKeyBuilder.addPrimaryKeyColumn(Picture.Fields.url, PrimaryKeyValue.fromString(url));
    113.             PrimaryKey primaryKey = primaryKeyBuilder.build();
    114.             RowPutChange rowPutChange = new RowPutChange(TABLE_NAME, primaryKey);
    116.             //描述属性信息
    117.             rowPutChange.addColumn(new Column(Picture.Fields.type, ColumnValue.fromString(pictureVO.getType())));
    119.             batchWriteRowRequest.addRowChange(rowPutChange);
    121.         }
    122.         batchWrite(batchWriteRowRequest);
    123.     }
    125.     @Override
    126.     public void deletes(PictureVO pictureVO) {
    127.         BatchWriteRowRequest batchWriteRowRequest = new BatchWriteRowRequest();
    128.         for (String url : pictureVO.getUrls()) {
    129.             //描述主键信息
    130.             PrimaryKeyBuilder primaryKeyBuilder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
    131.             primaryKeyBuilder.addPrimaryKeyColumn(Picture.Fields.url, PrimaryKeyValue.fromString(url));
    132.             PrimaryKey primaryKey = primaryKeyBuilder.build();
    133.             RowDeleteChange rowPutChange = new RowDeleteChange(TABLE_NAME, primaryKey);
    134.             batchWriteRowRequest.addRowChange(rowPutChange);
    135.         }
    136.         batchWrite(batchWriteRowRequest);
    137.     }
    139.     @Override
    140.     public Picture queryByUrl(String url) {
    141.         // 构造主键
    142.         PrimaryKeyBuilder primaryKeyBuilder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
    143.         primaryKeyBuilder.addPrimaryKeyColumn(Picture.Fields.url, PrimaryKeyValue.fromString(url));
    144.         PrimaryKey primaryKey = primaryKeyBuilder.build();
    146.         // 读一行
    147.         SingleRowQueryCriteria criteria = new SingleRowQueryCriteria(TABLE_NAME, primaryKey);
    148.         // 设置读取最新版本
    149.         criteria.setMaxVersions(1);
    150.         criteria.addColumnsToGet(Picture.Fields.type);
    151.         GetRowResponse getRowResponse = client.getRow(new GetRowRequest(criteria));
    152.         Row row = getRowResponse.getRow();
    154.         System.out.println("读取完毕，结果为： ");
    155.         System.out.println(row);
    156.         return getPicture(row);
    157.     }
    159.     private void batchWrite(BatchWriteRowRequest batchWriteRowRequest) {
    160.         BatchWriteRowResponse response = client.batchWriteRow(batchWriteRowRequest);
    161.         System.out.println("是否全部成功：" + response.isAllSucceed());
    162.         if (!response.isAllSucceed()) {
    163.             for (BatchWriteRowResponse.RowResult rowResult : response.getFailedRows()) {
    164.                 System.out.println("失败的行：" + batchWriteRowRequest.getRowChange(rowResult.getTableName(), rowResult.getIndex()).getPrimaryKey());
    165.                 System.out.println("失败原因：" + rowResult.getError());
    166.             }
    167.             /**
    168.              * 可以通过createRequestForRetry方法再构造一个请求对失败的行进行重试。这里只给出构造重试请求的部分。
    169.              * 推荐的重试方法是使用SDK的自定义重试策略功能，支持对batch操作的部分行错误进行重试。设定重试策略后，调用接口处即不需要增加重试代码。
    170.              */
    171.             BatchWriteRowRequest retryRequest = batchWriteRowRequest.createRequestForRetry(response.getFailedRows());
    172.         }
    173.     }
    175.     /**
    176.      * 导入数据
    177.      *
    178.      * @param args
    179.      */
    180.     public static void main(String[] args) throws Exception {
    181.         //ExportData("out.txt");
    182.         //importData("out.txt");
    183.     }
    185.     public static void importData(String path) throws IOException {
    186.         List<String> strings = FileUtils.readLines(new File(path), "utf-8");
    187.         for (String string : strings) {
    188.             String[] split = string.split("\t");
    189.             if (split.length != 2) {
    190.                 continue;
    191.             }
    192.             //描述主键信息
    193.             PrimaryKeyBuilder primaryKeyBuilder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
    194.             primaryKeyBuilder.addPrimaryKeyColumn(Picture.Fields.url, PrimaryKeyValue.fromString(split[0]));
    195.             PrimaryKey primaryKey = primaryKeyBuilder.build();
    196.             RowPutChange rowPutChange = new RowPutChange(TABLE_NAME, primaryKey);
    198.             //描述属性信息
    199.             rowPutChange.addColumn(new Column(Picture.Fields.type, ColumnValue.fromString(split[1])));
    201.             //添加新数据到表格
    202.             try {
    203.                 client.putRow(new PutRowRequest(rowPutChange));
    204.                 System.out.println("添加数据成功。");
    205.             } catch (TableStoreException e) {
    206.                 System.err.println("操作失败，详情：" + e.getMessage());
    207.                 System.err.println("Request ID:" + e.getRequestId());
    208.             } catch (ClientException e) {
    209.                 System.err.println("请求失败，详情：" + e.getMessage());
    210.             }
    211.         }
    212.         System.out.println("ok");
    214.     }
    216.     public static void ExportData(String path) throws Exception{
    217.         SearchRequest searchRequest2 = SearchRequest.newBuilder()
    218.                 .tableName(TABLE_NAME)
    219.                 .indexName("picture_index")
    220.                 .addColumnsToGet(Picture.Fields.type)
    221.                 .searchQuery(
    222.                         SearchQuery.newBuilder()
    223.                                 .query(QueryBuilders.matchAll())
    224.                                 .limit(100)
    225.                                 .offset(0)
    226.                                 .build())
    227.                 .build();
    229.         SearchResponse resp2 = client.search(searchRequest2);
    230.         List<Row> rows = resp2.getRows();
    231.         BufferedWriter bw = null;
    232.         bw = new BufferedWriter(new OutputStreamWriter(new FileOutputStream(path)));
    233.         for (Row row : rows) {
    234.             Picture picture = new RandomPicServiceImpl().getPicture(row);
    235.             bw.write(picture.getUrl() + "\t" + picture.getType() + System.lineSeparator());
    236.         }
    237.         bw.close();
    238.         System.out.println("ok");
    239.     }
    240. }