1. 搜索服务概述：搜索服务在微服务架构中的定位、Elasticsearch核心概念、NestJS与ES集成方案对比

1.1 搜索服务在微服务架构中的定位

在微服务架构中，搜索服务通常作为数据查询的专用枢纽，承担着跨服务、跨数据源的全文检索与聚合分析职责。与传统的单体应用不同，微服务架构下的数据被分散在多个独立的服务数据库中，直接跨库 JOIN 查询既不现实，也会破坏服务自治原则。搜索服务通过事件驱动或 CDC（Change Data Capture）机制，将各业务域的数据同步至 Elasticsearch 集群，对外提供统一的搜索入口。

下图展示了搜索服务在微服务架构中的典型位置：

1.2 Elasticsearch 核心概念

Elasticsearch 是一个基于 Lucene 的分布式搜索与分析引擎。理解以下核心概念是封装搜索服务的前提：

下图展示了 Elasticsearch 索引与分片的物理结构：

1.3 NestJS 与 Elasticsearch 集成方案对比

NestJS 生态中集成 Elasticsearch 主要有三种方案，各有适用场景：

三种方案的代码结构对比：

// 方案一：@nestjs/elasticsearch 直接注入
@Injectable()
export class ProductSearchService {
  constructor(
    @Inject(ELASTICSEARCH_CLIENT)
    private readonly esClient: ElasticsearchClient,
  ) {}

  async search(keyword: string) {
    return this.esClient.search({
      index: 'products',
      body: { query: { match: { name: keyword } } },
    });
  }
}

// 方案二：自定义 Repository 模式（本课程采用）
@Injectable()
export class ProductSearchRepository {
  constructor(
    @Inject(ELASTICSEARCH_CLIENT)
    private readonly esClient: ElasticsearchClient,
  ) {}

  async search(dto: SearchProductDto): Promise<SearchResult> {
    const queryBody = this.buildQueryDSL(dto);
    const response = await this.esClient.search({
      index: 'products',
      body: queryBody,
    });
    return this.mapResponse(response);
  }

  private buildQueryDSL(dto: SearchProductDto): Record<string, any> {
    // 封装复杂的 bool / multi_match / filter 逻辑
    return {
      query: {
        bool: {
          must: dto.keyword
            ? [{ multi_match: { query: dto.keyword, fields: ['name', 'description'] } }]
            : [{ match_all: {} }],
          filter: dto.categoryId
            ? [{ term: { categoryId: dto.categoryId } }]
            : [],
        },
      },
      sort: [{ price: { order: dto.sortOrder || 'asc' } }],
    };
  }

  private mapResponse(response: SearchResponse): SearchResult {
    return {
      total: response.hits.total.value,
      items: response.hits.hits.map((hit) => ({
        id: hit._id,
        score: hit._score,
        source: hit._source,
      })),
    };
  }
}