五、通过 Elasticsearch 对 HBase 中的数据建立索引

1，数据字段分析

比较项	是否建立索引	是否存储
文章 ID（id)	是	是
标题（title)	是	是
来源（src)	否	是
正文（content)	是	否
时间（time)	否	是

2，创建索引库 article。

{
  "settings": {
    "number_of_shards": 5,
    "number_of_replicas": 1
  },
  "mappings": {
    "dynamic": "false",
    "_source": {
      "excludes": ["content"]
    },
    "properties": {
      "title": {
        "type": "text", "analyzer": "ik_max_word"
      },
      "src": {
        "type": "text", "index": false
      },
      "content": {
        "type": "text", "analyzer": "ik_max_word"
      },
      "time": {
        "type": "date", "index": false, "format": "yyyy-MM-dd'T'HH:mm:ss"
      }
    }
  }
}

（2）接着执行如下命令创建索引库 article：

curl -H "Content-Type:application/json" -XPUT 'http://node1:9200/article' -d @article.json

（3）创建完毕后，执行如下命令确认索引库 article 的 mapping 信息：

curl -XGET 'http://node1:9200/article/_mapping?pretty'

3，代码实现

@Document(indexName = "article", createIndex = false)
@Data
public class Article {
  @Id
  private String id; // 文章的唯一标识符

  @Field(type = FieldType.Text, analyzer = "ik_max_word")
  private String title; // 书籍的标题

  @Field(type = FieldType.Text, index = false)
  private String src; // 文章的来源

  @Field(type = FieldType.Text, analyzer = "ik_max_word")
  private String content; // 文章的内容

  @Field(type = FieldType.Date, index = false, format = DateFormat.date_hour_minute_second)
  @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "Asia/Shanghai")
  private Date time; // 文章的时间
}

（2）接着需要编写 Elasticsearch Repository 接口 在 Spring Data Elasticsearch 中，可以使用 Repository 接口来定义 Elasticsearch 的增删改查操作。下面我们定义一个 ArticleRepository 接口，继承自 ElasticsearchRepository，并指定实体类（Article）和主键的类型（String）

public interface ArticleRepository extends ElasticsearchRepository<Article, String> {
}

（3）最后则是建立索引的业务代码，具体逻辑是不断从 Redis 列表中获取文章的 ID，然后通过该 ID 从 HBase 数据库中获取文章的详细信息，将获取到的数据转换为一个 Article 对象，并将其保存到 Elasticsearch 中建立索引。循环直到 Redis 列表为空，完成对所有文章的处理。

@GetMapping("/index")
public void index() throws ParseException {
  // 循环直到列表为空
  while (true) {
    // 从Redis获取一个Rowkey
    String id = stringRedisTemplate.opsForList().rightPop("l_article_ids");

    if (id != null) {
      // HBase表名为"article"，列族为"info"
      String tableName = "article";
      String cf = "info";

      // 根据Rowkey从HBase获取数据的详细信息
      Map<String, String> data = hbaseUtils.getData(tableName, id);

      // 在ES中对数据建立索引
      if (data != null) {
        Article article = new Article();
        article.setId(id);
        article.setTitle(data.get(cf + ":title"));
        article.setSrc(data.get(cf + ":src"));
        article.setContent(data.get(cf + ":content"));
        // 将日期字符串转换为日期对象
        LocalDateTime localDateTime = LocalDateTime.parse(data.get(cf + ":time")+"T00:00:00");
        ZonedDateTime zonedDateTime = ZonedDateTime.of(localDateTime, ZoneId.of("Asia/Shanghai"));
        Date date = Date.from(zonedDateTime.toInstant());
        article.setTime(date);

        // 记录索引数据
        articleRepository.save(article);
        System.out.println(article.getTitle() + " - 保存成功");
      } else {
        System.out.println("未找到ID为" + id + "的数据");
      }
    } else {
      // 如果列表为空，则中断循环
      System.out.println("Redis中没有更多的文章ID。");
      break;
    }
  }
}

4，运行测试

六、通过 Elasticsearch 搜索数据

1，代码实现

public interface ArticleRepository extends ElasticsearchRepository<Article, String> {

  @Query(value =
        "{"
          + "\"bool\": {"
            + "\"should\": ["
              + "{ \"match\": { \"title\": \"?0\" } },"
              + "{ \"match\": { \"content\": \"?0\" } }"
            + "]"
          + "}"
        + "}"
  )
  List<Article> findByTitleOrContent(String keyword);
}

（2）接着是搜索数据的业务代码，调用 ArticleRepository 中的全文检索方法根据客户端输入的关键词在文章标题或内容中查询匹配的文章列表，然后通过 HBase 数据库获取每篇文章的详细内容，并返回包含完整内容的文章列表。

@GetMapping("/search/{keyword}")
public List<Article> search(@PathVariable("keyword") String keyword) {
  // 通过articleRepository根据标题或内容查询文章列表
  List<Article> articles = articleRepository.findByTitleOrContent(keyword);
  // 遍历查询到的文章列表
  for (Article article : articles) {
    // HBase表名为"article"，列族为"info"
    String tableName = "article";
    String cf = "info";
    // 从HBase中获取content正文数据
    String content = hbaseUtils.getData(tableName, article.getId(), cf, "content");
    // 将获取到的content设置到文章对象的content属性中
    article.setContent(content);
  }
  // 返回查询到的文章列表
  return articles;
}

2，运行测试

http://localhost:8080/search/黄岩岛菲律宾