更新 ES 实战代码。

Author: Jackson0714

passjava-gateway/src/main/resources/application.yml

@@ -13,6 +13,13 @@ spring:
           uri: lb://passjava-question # 负载均衡，将请求转发到注册中心注册的assjava-question服务
           predicates: # 断言
             - Path=/api/question/** # 如果前端请求路径包含 api/question，则应用这条路由规则
+          filters: #过滤器
+            - RewritePath=/api/(?<segment>.*),/$\{segment} # 将跳转路径中包含的 api 替换成空
+
+        - id: route_search # 题目微服务路由规则
+          uri: lb://passjava-search # 负载均衡，将请求转发到注册中心注册的 passjava-search 服务
+          predicates: # 断言
+            - Path=/api/search/** # 如果前端请求路径包含 api/question，则应用这条路由规则
           filters: #过滤器
             - RewritePath=/api/(?<segment>.*),/$\{segment} # 将跳转路径中包含的api替换成空
 

passjava-search/src/main/java/com/jackson0714/passjava/search/config/EsConstant.java

@@ -9,4 +9,5 @@
 public class EsConstant {
 
     public static final String QUESTION_INDEX = "question"; // 题目数据在 ES 中的索引
+    public static final Integer PAGE_SIZE = 5; // 分页大小
 }

passjava-search/src/main/java/com/jackson0714/passjava/search/controller/SearchController.java

@@ -2,6 +2,7 @@
 
 import com.jackson0714.passjava.search.service.IQuestionSearchService;
 import com.jackson0714.passjava.search.vo.SearchParam;
+import com.jackson0714.passjava.search.vo.SearchQuestionResponse;
 import org.elasticsearch.action.search.SearchResponse;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Controller;
@@ -23,7 +24,7 @@ public class SearchController {
     IQuestionSearchService questionSearchService;
 
     @PostMapping("/question/list")
-    public SearchResponse list(SearchParam param) {
+    public SearchQuestionResponse list(SearchParam param) {
 
         return questionSearchService.search(param);
 

passjava-search/src/main/java/com/jackson0714/passjava/search/service/IQuestionSearchService.java

@@ -1,7 +1,7 @@
 package com.jackson0714.passjava.search.service;
 
 import com.jackson0714.passjava.search.vo.SearchParam;
-import org.elasticsearch.action.search.SearchResponse;
+import com.jackson0714.passjava.search.vo.SearchQuestionResponse;
 
 /**
  * @Author: 公众号 | 悟空聊架构
@@ -11,5 +11,5 @@
  */
 public interface IQuestionSearchService {
 
-    SearchResponse search(SearchParam param);
+    SearchQuestionResponse search(SearchParam param);
 }

passjava-search/src/main/java/com/jackson0714/passjava/search/service/impl/QuestionSearchServiceImpl.java

@@ -5,6 +5,7 @@
 import com.jackson0714.passjava.search.config.EsConstant;
 import com.jackson0714.passjava.search.service.IQuestionSearchService;
 import com.jackson0714.passjava.search.vo.SearchParam;
+import com.jackson0714.passjava.search.vo.SearchQuestionResponse;
 import org.apache.commons.lang.StringUtils;
 import org.elasticsearch.action.search.SearchRequest;
 import org.elasticsearch.action.search.SearchResponse;
@@ -21,6 +22,8 @@
 import org.springframework.stereotype.Service;
 
 import java.io.IOException;
+import java.util.ArrayList;
+import java.util.List;
 
 /**
  * @Author: 公众号 | 悟空聊架构
@@ -38,48 +41,67 @@ public class QuestionSearchServiceImpl implements IQuestionSearchService {
     private RestHighLevelClient client;
 
     @Override
-    public SearchResponse search(SearchParam param) {
+    public SearchQuestionResponse search(SearchParam param) {
 
-        SearchResponse response = null;
+        SearchQuestionResponse questionResponse = new SearchQuestionResponse();
+        SearchResponse searchResponse = null;
         /*
-         * 动态构建出查询需要的 DSL 语句
+         * 1.动态构建出查询需要的 DSL 语句
          */
-        // 1. 创建检索请求
-
+        // 1.1） 创建检索请求
         SearchSourceBuilder sourceBuilder = new SearchSourceBuilder(); // 构建 DSL 语句
         BoolQueryBuilder boolQuery = QueryBuilders.boolQuery();
         if (!StringUtils.isEmpty(param.getKeyword())) {
-            boolQuery.must(QueryBuilders.matchQuery("title", param.getKeyword()));
+            // 1.2） title，answer，typeName 字段用来关键词检索
+            boolQuery.must(QueryBuilders.multiMatchQuery(param.getKeyword(),"title", "answer", "typeName"));
         }
-
         if (param.getId() != null) {
+            // 1.3）题目 id 用来精确匹配
             boolQuery.filter(QueryBuilders.termQuery("id", param.getId()));
         }
         sourceBuilder.query(boolQuery);
+
+        // 1.4）分页
+        sourceBuilder.from((param.getPageNum() - 1) * EsConstant.PAGE_SIZE);
+        sourceBuilder.size(EsConstant.PAGE_SIZE);
+
         SearchRequest request = new SearchRequest(new String[] {EsConstant.QUESTION_INDEX}, sourceBuilder);
 
         try {
             // 2、执行检索
-            response = client.search(request, RequestOptions.DEFAULT);
+            searchResponse = client.search(request, RequestOptions.DEFAULT);
 
             // 3、分析结果
-            System.out.println(response.toString());
+            System.out.println(searchResponse.toString());
             // 3.1）获取查到的数据。
-            SearchHits hits = response.getHits();
+            SearchHits hits = searchResponse.getHits();
             // 3.2）获取真正命中的结果
             SearchHit[] searchHits = hits.getHits();
             // 3.3）遍历命中结果
-            for (SearchHit hit: searchHits) {
-                String hitStr = hit.getSourceAsString();
-                QuestionEsModel questionEsModel = JSON.parseObject(hitStr, QuestionEsModel.class);
-                System.out.println(questionEsModel);
+            List<QuestionEsModel> questionEsModelList = new ArrayList<>();
+            if (hits.getHits() != null && hits.getHits().length > 0) {
+                for (SearchHit hit : searchHits) {
+                    String hitStr = hit.getSourceAsString();
+                    QuestionEsModel questionEsModel = JSON.parseObject(hitStr, QuestionEsModel.class);
+                    System.out.println(questionEsModel);
+                    questionEsModelList.add(questionEsModel);
+                }
+                questionResponse.setQuestionList(questionEsModelList);
+
+                // 分页
+                long total = hits.getTotalHits().value;
+                questionResponse.setTotal(total);
+                questionResponse.setPageNum(param.getPageNum());
+                int totalPages = (int) total % EsConstant.PAGE_SIZE == 0 ? (int) total / EsConstant.PAGE_SIZE : (int) (total / EsConstant.PAGE_SIZE + 1);
+                questionResponse.setTotalPages(totalPages);
             }
+
         } catch (IOException e) {
             e.printStackTrace();
         }
 
 
-        return response;
+        return questionResponse;
     }
 
 

passjava-search/src/main/java/com/jackson0714/passjava/search/vo/SearchParam.java

@@ -12,5 +12,5 @@
 public class SearchParam {
     private String keyword; // 全文匹配的关键字
     private String id; // 题目 id
-
+    private Integer pageNum; // 题目 id
 }

passjava-search/src/main/java/com/jackson0714/passjava/search/vo/SearchQuestionResponse.java

@@ -0,0 +1,20 @@
+package com.jackson0714.passjava.search.vo;
+
+import com.jackson0714.common.to.es.QuestionEsModel;
+import lombok.Data;
+
+import java.util.List;
+
+/**
+ * @Author: 公众号 | 悟空聊架构
+ * @Date: 2021/4/7 16:50
+ * @Site: www.passjava.cn
+ * @Github: https://github.com/Jackson0714/PassJava-Platform
+ */
+@Data
+public class SearchQuestionResponse {
+    private List<QuestionEsModel> questionList;
+    private Integer pageNum;
+    private Long total;
+    private Integer totalPages;
+}