Nest 官方提供了一套 ElasticSearch 模块，来解决它与 ElasticSearch 服务器之间的交互。这篇文章你将学习到：
- 安装
- 导入模块
- 创建服务
- 使用
ElasticsearchService查询数据
- 使用
- 向外提供 RESTful 服务
安装
还是老规矩：
npm i --save @nestjs/elasticsearch elasticsearch @types/elasticsearch
OR
yarn add @nestjs/elasticsearch elasticsearch @types/elasticsearch
导入模块
安装完成后，我们需要将 ElasticsearchModule 导入到 AppModule：
// app.module.ts
import { Module } from '@nestjs/common';
import { ElasticsearchModule } from '@nestjs/elasticsearch';
@Module({
imports: [
ElasticsearchModule.register({
host: 'localhost:9200',
log: 'trace',
}),
],
})
export class AppModule { }
创建服务
我们创建一个搜索服务，并将 ElasticsearchService 注入到服务中使用相关查询功能：
// search.service.ts
import { ElasticsearchService } from '@nestjs/elasticsearch';
import { Injectable } from '@nestjs/common';
@Injectable()
export class SearchService {
constructor(private readonly elasticsearchService: ElasticsearchService) { }
async search<T>(params) {
return await this.elasticsearchService.getClient().search<T>(params);
}
}
Elasticsearch 相关的搜索功能，我们可以去相关网站上查询，它的 DSL 也可以从 Google 上搜索到。
向外提供 RESTful 服务
最后，我将这个服务通过 SearchController 暴露成 RESTful 接口：
// search.controller.ts
import { Controller, Get } from '@nestjs/common';
import { SearchService } from './search.service';
@Controller('search')
export class SearchController {
constructor(
private readonly searchService: SearchService,
) { }
@Get()
search() {
return this.searchService.search({
index: 'test_alias',
body: {
from: 0,
size: 10,
}
});
}
}
当然，这些 Service、Controller 需要注册到相关的 Module 中去：
// app.module.ts
import { Module } from '@nestjs/common';
import { SearchService } from './search.service';
import { SearchController } from './search.controller';
import { ElasticsearchModule } from '@nestjs/elasticsearch';
@Module({
imports: [
ElasticsearchModule.register({
host: '10.5.11.86:9200',
log: 'trace',
}),
],
controllers: [SearchController],
providers: [SearchService],
})
export class AppModule { }
这样，启动并访问 localhost:3000/search，就大功告成了！
〖坚持的一俢〗
