厂里资讯之app端文章搜索

app端文章搜索

1) 内容介绍

  • 文章搜索

    • ElasticSearch环境搭建

    • 索引库创建

    • 文章搜索多条件复合查询

    • 索引数据同步

  • 搜索历史记录

    • Mongodb环境搭建

    • 异步保存搜索历史

    • 查看搜索历史列表

    • 删除搜索历史

  • 联想词查询

    • 联想词的来源

    • 联想词功能实现

2) 搭建ElasticSearch环境

2.1) 拉取镜像

docker pull elasticsearch:7.4.0

2.2) 创建容器

docker run -id --name elasticsearch -d --restart=always -p 9200:9200 -p 9300:9300 -v /usr/share/elasticsearch/plugins:/usr/share/elasticsearch/plugins -e "discovery.type=single-node" elasticsearch:7.4.0

2.3) 配置中文分词器 ik

因为在创建elasticsearch容器的时候，映射了目录，所以可以在宿主机上进行配置ik中文分词器

在去选择ik分词器的时候，需要与elasticsearch的版本好对应上

#切换目录
cd /usr/share/elasticsearch/plugins
#新建目录
mkdir analysis-ik
cd analysis-ik
#root根目录中拷贝文件
mv elasticsearch-analysis-ik-7.4.0.zip /usr/share/elasticsearch/plugins/analysis-ik
#解压文件
cd /usr/share/elasticsearch/plugins/analysis-ik
unzip elasticsearch-analysis-ik-7.4.0.zip

3) app端文章搜索

3.1) 需求分析

  • 用户输入关键可搜索文章列表

  • 关键词高亮显示

  • 文章列表展示与home展示一样，当用户点击某一篇文章，可查看文章详情

3.2) 思路分析

为了加快检索的效率，在查询的时候不会直接从数据库中查询文章，需要在elasticsearch中进行高速检索。

3.3) 创建索引和映射

使用postman添加映射

put请求 ： http://192.168.200.130:9200/app_info_article

{"mappings":{"properties":{"id":{"type":"long"},"publishTime":{"type":"date"},"layout":{"type":"integer"},"images":{"type":"keyword","index": false},"staticUrl":{"type":"keyword","index": false},"authorId": {"type": "long"},"authorName": {"type": "text"},"title":{"type":"text","analyzer":"ik_smart"},"content":{"type":"text","analyzer":"ik_smart"}}}
}

GET请求查询映射：http://192.168.200.130:9200/app_info_article

DELETE请求，删除索引及映射：http://192.168.200.130:9200/app_info_article

GET请求，查询所有文档：http://192.168.200.130:9200/app_info_article/_search

3.4) 数据初始化到索引库

3.4.1)导入es-init到changli-Information-test工程下

3.4.1)查询所有的文章信息，批量导入到es索引库中
package com.kjz.es;
​
import com.alibaba.fastjson.JSON;
import com.kjz.es.mapper.ApArticleMapper;
import com.kjz.es.pojo.SearchArticleVo;
import org.elasticsearch.action.bulk.BulkRequest;
import org.elasticsearch.action.index.IndexRequest;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.common.xcontent.XContentType;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;
​
import java.util.List;
​
​
@SpringBootTest
@RunWith(SpringRunner.class)
public class ApArticleTest {
​@Autowiredprivate ApArticleMapper apArticleMapper;
​@Autowiredprivate RestHighLevelClient restHighLevelClient;
​
​/*** 注意：数据量的导入，如果数据量过大，需要分页导入* @throws Exception*/@Testpublic void init() throws Exception {
​//1.查询所有符合条件的文章数据List<SearchArticleVo> searchArticleVos = apArticleMapper.loadArticleList();
​//2.批量导入到es索引库
​BulkRequest bulkRequest = new BulkRequest("app_info_article");
​for (SearchArticleVo searchArticleVo : searchArticleVos) {
​IndexRequest indexRequest = new IndexRequest().id(searchArticleVo.getId().toString()).source(JSON.toJSONString(searchArticleVo), XContentType.JSON);
​//批量添加数据bulkRequest.add(indexRequest);
​}restHighLevelClient.bulk(bulkRequest, RequestOptions.DEFAULT);
​}
​
}
3.4.3)测试

postman查询所有的es中数据 GET请求： http://192.168.200.130:9200/app_info_article/_search

3.5) 文章搜索功能实现

3.5.1)搭建搜索微服务

（1）创建changli-Information-search

（2）在changli-Information-service的pom中添加依赖

<!--elasticsearch-->
<dependency><groupId>org.elasticsearch.client</groupId><artifactId>elasticsearch-rest-high-level-client</artifactId><version>7.4.0</version>
</dependency>
<dependency><groupId>org.elasticsearch.client</groupId><artifactId>elasticsearch-rest-client</artifactId><version>7.4.0</version>
</dependency>
<dependency><groupId>org.elasticsearch</groupId><artifactId>elasticsearch</artifactId><version>7.4.0</version>
</dependency>

（3）nacos配置中心Information-search

spring:autoconfigure:exclude: org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration
elasticsearch:host: 192.168.200.130port: 9200
3.5.2) 搜索接口定义
package com.kjz.search.controller.v1;
​
import com.heima.model.common.dtos.ResponseResult;
import com.heima.model.search.dtos.UserSearchDto;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
​
import java.io.IOException;
​
@RestController
@RequestMapping("/api/v1/article/search")
public class ArticleSearchController {
​
​@PostMapping("/search")public ResponseResult search(@RequestBody UserSearchDto dto) throws IOException {return null;}
}
 

UserSearchDto
 

package com.kjz.model.search.dtos;
​
import lombok.Data;
​
import java.util.Date;
​
​
@Data
public class UserSearchDto {
​/*** 搜索关键字*/String searchWords;/*** 当前页*/int pageNum;/*** 分页条数*/int pageSize;/*** 最小时间*/Date minBehotTime;
​public int getFromIndex(){if(this.pageNum<1)return 0;if(this.pageSize<1) this.pageSize = 10;return this.pageSize * (pageNum-1);}
}
 

3.5.3) 业务层实现
 

创建业务层接口：ApArticleSearchService
 

package com.kjz.search.service;
​
import com.heima.model.search.dtos.UserSearchDto;
import com.heima.model.common.dtos.ResponseResult;
​
import java.io.IOException;
​
public interface ArticleSearchService {
​/**ES文章分页搜索@return*/ResponseResult search(UserSearchDto userSearchDto) throws IOException;
}
 

实现类：
 

package com.kjz.search.service.impl;
​
import com.alibaba.fastjson.JSON;
import com.kjz.model.common.dtos.ResponseResult;
import com.kjz.model.common.enums.AppHttpCodeEnum;
import com.kjz.model.search.dtos.UserSearchDto;
import com.kjz.model.user.pojos.ApUser;
import com.kjz.search.service.ArticleSearchService;
import com.kjz.utils.thread.AppThreadLocalUtil;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.elasticsearch.action.search.SearchRequest;
import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.common.text.Text;
import org.elasticsearch.index.query.*;
import org.elasticsearch.search.SearchHit;
import org.elasticsearch.search.builder.SearchSourceBuilder;
import org.elasticsearch.search.fetch.subphase.highlight.HighlightBuilder;
import org.elasticsearch.search.sort.SortOrder;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
​
import java.io.IOException;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
​
@Service
@Slf4j
public class ArticleSearchServiceImpl implements ArticleSearchService {
​@Autowiredprivate RestHighLevelClient restHighLevelClient;
​/*** es文章分页检索** @param dto* @return*/@Overridepublic ResponseResult search(UserSearchDto dto) throws IOException {
​//1.检查参数if(dto == null || StringUtils.isBlank(dto.getSearchWords())){return ResponseResult.errorResult(AppHttpCodeEnum.PARAM_INVALID);}
​//2.设置查询条件SearchRequest searchRequest = new SearchRequest("app_info_article");SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
​//布尔查询BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery();
​//关键字的分词之后查询QueryStringQueryBuilder queryStringQueryBuilder = QueryBuilders.queryStringQuery(dto.getSearchWords()).field("title").field("content").defaultOperator(Operator.OR);boolQueryBuilder.must(queryStringQueryBuilder);
​//查询小于mindate的数据RangeQueryBuilder rangeQueryBuilder = QueryBuilders.rangeQuery("publishTime").lt(dto.getMinBehotTime().getTime());boolQueryBuilder.filter(rangeQueryBuilder);
​//分页查询searchSourceBuilder.from(0);searchSourceBuilder.size(dto.getPageSize());
​//按照发布时间倒序查询searchSourceBuilder.sort("publishTime", SortOrder.DESC);
​//设置高亮  titleHighlightBuilder highlightBuilder = new HighlightBuilder();highlightBuilder.field("title");highlightBuilder.preTags("<font style='color: red; font-size: inherit;'>");highlightBuilder.postTags("</font>");searchSourceBuilder.highlighter(highlightBuilder);
​
​searchSourceBuilder.query(boolQueryBuilder);searchRequest.source(searchSourceBuilder);SearchResponse searchResponse = restHighLevelClient.search(searchRequest, RequestOptions.DEFAULT);
​
​//3.结果封装返回
​List<Map> list = new ArrayList<>();
​SearchHit[] hits = searchResponse.getHits().getHits();for (SearchHit hit : hits) {String json = hit.getSourceAsString();Map map = JSON.parseObject(json, Map.class);//处理高亮if(hit.getHighlightFields() != null && hit.getHighlightFields().size() > 0){Text[] titles = hit.getHighlightFields().get("title").getFragments();String title = StringUtils.join(titles);//高亮标题map.put("h_title",title);}else {//原始标题map.put("h_title",map.get("title"));}list.add(map);}
​return ResponseResult.okResult(list);
​}
}
 

3.5.4) 控制层实现
 

新建控制器ArticleSearchController
 

package com.kjz.search.controller.v1;
​
import com.heima.model.common.dtos.ResponseResult;
import com.heima.model.search.dtos.UserSearchDto;
import com.heima.search.service.ArticleSearchService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
​
import java.io.IOException;
​
@RestController
@RequestMapping("/api/v1/article/search")
public class ArticleSearchController {
​@Autowiredprivate ArticleSearchService articleSearchService;
​@PostMapping("/search")public ResponseResult search(@RequestBody UserSearchDto dto) throws IOException {return articleSearchService.search(dto);}
}
 

3.5.5) 测试
 

需要在app的网关中添加搜索微服务的路由配置
 

#搜索微服务
- id: Information-searchuri: lb://Information-searchpredicates:- Path=/search/**filters:- StripPrefix= 1
 

启动项目进行测试，至少要启动文章微服务，用户微服务，搜索微服务，app网关微服务，app前端工程
 

3.6) 文章自动审核构建索引
 

3.6.1)思路分析
 

 

3.6.2)文章微服务发送消息
 

1.把SearchArticleVo放到model工程下
 

package com.kjz.model.search.vos;
​
import lombok.Data;
​
import java.util.Date;
​
@Data
public class SearchArticleVo {
​// 文章idprivate Long id;// 文章标题private String title;// 文章发布时间private Date publishTime;// 文章布局private Integer layout;// 封面private String images;// 作者idprivate Long authorId;// 作者名词private String authorName;//静态urlprivate String staticUrl;//文章内容private String content;
​
}
 

2.文章微服务的ArticleFreemarkerService中的buildArticleToMinIO方法中收集数据并发送消息
 

完整代码如下：
 

package com.kjz.article.service.impl;
​
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.kjz.article.mapper.ApArticleContentMapper;
import com.kjz.article.service.ApArticleService;
import com.heima.article.service.ArticleFreemarkerService;
import com.heima.common.constants.ArticleConstants;
import com.heima.file.service.FileStorageService;
import com.heima.model.article.pojos.ApArticle;
import com.heima.model.search.vos.SearchArticleVo;
import freemarker.template.Configuration;
import freemarker.template.Template;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.kafka.core.KafkaTemplate;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
​
import java.io.ByteArrayInputStream;
import java.io.InputStream;
import java.io.StringWriter;
import java.util.HashMap;
import java.util.Map;
​
@Service
@Slf4j
@Transactional
public class ArticleFreemarkerServiceImpl implements ArticleFreemarkerService {
​@Autowiredprivate ApArticleContentMapper apArticleContentMapper;
​@Autowiredprivate Configuration configuration;
​@Autowiredprivate FileStorageService fileStorageService;
​@Autowiredprivate ApArticleService apArticleService;
​/*** 生成静态文件上传到minIO中* @param apArticle* @param content*/@Async@Overridepublic void buildArticleToMinIO(ApArticle apArticle, String content) {//已知文章的id//4.1 获取文章内容if(StringUtils.isNotBlank(content)){//4.2 文章内容通过freemarker生成html文件Template template = null;StringWriter out = new StringWriter();try {template = configuration.getTemplate("article.ftl");//数据模型Map<String,Object> contentDataModel = new HashMap<>();contentDataModel.put("content", JSONArray.parseArray(content));//合成template.process(contentDataModel,out);} catch (Exception e) {e.printStackTrace();}
​
​//4.3 把html文件上传到minio中InputStream in = new ByteArrayInputStream(out.toString().getBytes());String path = fileStorageService.uploadHtmlFile("", apArticle.getId() + ".html", in);
​
​//4.4 修改ap_article表，保存static_url字段apArticleService.update(Wrappers.<ApArticle>lambdaUpdate().eq(ApArticle::getId,apArticle.getId()).set(ApArticle::getStaticUrl,path));
​//发送消息，创建索引createArticleESIndex(apArticle,content,path);
​}}
​@Autowiredprivate KafkaTemplate<String,String> kafkaTemplate;
​/*** 送消息，创建索引* @param apArticle* @param content* @param path*/private void createArticleESIndex(ApArticle apArticle, String content, String path) {SearchArticleVo vo = new SearchArticleVo();BeanUtils.copyProperties(apArticle,vo);vo.setContent(content);vo.setStaticUrl(path);
​kafkaTemplate.send(ArticleConstants.ARTICLE_ES_SYNC_TOPIC, JSON.toJSONString(vo));}
​
}
 

在ArticleConstants类中添加新的常量，完整代码如下
 

package com.heima.common.constants;
​
public class ArticleConstants {public static final Short LOADTYPE_LOAD_MORE = 1;public static final Short LOADTYPE_LOAD_NEW = 2;public static final String DEFAULT_TAG = "__all__";
​public static final String ARTICLE_ES_SYNC_TOPIC = "article.es.sync.topic";
​public static final Integer HOT_ARTICLE_LIKE_WEIGHT = 3;public static final Integer HOT_ARTICLE_COMMENT_WEIGHT = 5;public static final Integer HOT_ARTICLE_COLLECTION_WEIGHT = 8;
​public static final String HOT_ARTICLE_FIRST_PAGE = "hot_article_first_page_";
}
 

3.文章微服务集成kafka发送消息
 

在文章微服务的nacos的配置中心添加如下配置
 

kafka:bootstrap-servers: 192.168.200.130:9092producer:retries: 10key-serializer: org.apache.kafka.common.serialization.StringSerializervalue-serializer: org.apache.kafka.common.serialization.StringSerializer
 

3.6.3)搜索微服务接收消息并创建索引
 

1.搜索微服务中添加kafka的配置,nacos配置如下
 

spring:kafka:bootstrap-servers: 192.168.200.130:9092consumer:group-id: ${spring.application.name}key-deserializer: org.apache.kafka.common.serialization.StringDeserializervalue-deserializer: org.apache.kafka.common.serialization.StringDeserializer
 

2.定义监听接收消息,保存索引数据
 

package com.kjz.search.listener;
​
import com.alibaba.fastjson.JSON;
import com.heima.common.constants.ArticleConstants;
import com.heima.model.search.vos.SearchArticleVo;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.elasticsearch.action.index.IndexRequest;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.common.xcontent.XContentType;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.stereotype.Component;
​
import java.io.IOException;
​
@Component
@Slf4j
public class SyncArticleListener {
​@Autowiredprivate RestHighLevelClient restHighLevelClient;
​@KafkaListener(topics = ArticleConstants.ARTICLE_ES_SYNC_TOPIC)public void onMessage(String message){if(StringUtils.isNotBlank(message)){
​log.info("SyncArticleListener,message={}",message);
​SearchArticleVo searchArticleVo = JSON.parseObject(message, SearchArticleVo.class);IndexRequest indexRequest = new IndexRequest("app_info_article");indexRequest.id(searchArticleVo.getId().toString());indexRequest.source(message, XContentType.JSON);try {restHighLevelClient.index(indexRequest, RequestOptions.DEFAULT);} catch (IOException e) {e.printStackTrace();log.error("sync es error={}",e);}}
​}
}
 

4) app端搜索-搜索记录
 

4.1) 需求分析
 

  •  
    展示用户的搜索记录10条，按照搜索关键词的时间倒序
     
  •  
    可以删除搜索记录
     
  •  
    保存历史记录，保存10条，多余的则删除最久的历史记录
     
 

4.2)数据存储说明
 

用户的搜索记录，需要给每一个用户都保存一份，数据量较大，要求加载速度快，通常这样的数据存储到mongodb更合适，不建议直接存储到关系型数据库中
 

 

4.3)MongoDB安装及集成
 

4.3.1)安装MongoDB
 

拉取镜像
 

docker pull mongo
 

创建容器
 

docker run -di --name mongo-service --restart=always -p 27017:27017 -v ~/data/mongodata:/data mongo
 

4.3.2)创建mongo-demo项目到changli-Information-test中
 

其中有三项配置比较关键：
 

第一：mongo依赖
 

<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-mongodb</artifactId>
</dependency>
 

第二：mongo配置
 

server:port: 9998
spring:data:mongodb:host: 192.168.200.130port: 27017database: Information-history
 

第三：映射
 

package com.kjz.mongo.pojo;
​
import lombok.Data;
import org.springframework.data.mongodb.core.mapping.Document;
​
import java.io.Serializable;
import java.util.Date;
​
/*** <p>* 联想词表* </p>** @author kjz*/
@Data
@Document("ap_associate_words")
public class ApAssociateWords implements Serializable {
​private static final long serialVersionUID = 1L;
​private String id;
​/*** 联想词*/private String associateWords;
​/*** 创建时间*/private Date createdTime;
​
}
 

4.3.3)核心方法
 

package com.kjz.mongo.test;
​
​
import com.kjz.mongo.MongoApplication;
import com.kjz.mongo.pojo.ApAssociateWords;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.data.domain.Sort;
import org.springframework.data.mongodb.core.MongoTemplate;
import org.springframework.data.mongodb.core.query.Criteria;
import org.springframework.data.mongodb.core.query.Query;
import org.springframework.test.context.junit4.SpringRunner;
​
import java.util.Date;
import java.util.List;
​
@SpringBootTest(classes = MongoApplication.class)
@RunWith(SpringRunner.class)
public class MongoTest {
​
​@Autowiredprivate MongoTemplate mongoTemplate;
​//保存@Testpublic void saveTest(){/*for (int i = 0; i < 10; i++) {ApAssociateWords apAssociateWords = new ApAssociateWords();apAssociateWords.setAssociateWords("黑马头条");apAssociateWords.setCreatedTime(new Date());mongoTemplate.save(apAssociateWords);}*/ApAssociateWords apAssociateWords = new ApAssociateWords();apAssociateWords.setAssociateWords("厂里资讯");apAssociateWords.setCreatedTime(new Date());mongoTemplate.save(apAssociateWords);
​}
​//查询一个@Testpublic void saveFindOne(){ApAssociateWords apAssociateWords = mongoTemplate.findById("60bd973eb0c1d430a71a7928", ApAssociateWords.class);System.out.println(apAssociateWords);}
​//条件查询@Testpublic void testQuery(){Query query = Query.query(Criteria.where("associateWords").is("黑马头条")).with(Sort.by(Sort.Direction.DESC,"createdTime"));List<ApAssociateWords> apAssociateWordsList = mongoTemplate.find(query, ApAssociateWords.class);System.out.println(apAssociateWordsList);}
​@Testpublic void testDel(){mongoTemplate.remove(Query.query(Criteria.where("associateWords").is("黑马头条")),ApAssociateWords.class);}
}
 

4.4)保存搜索记录
 

4.4.1)实现思路
 

 

用户输入关键字进行搜索的异步记录关键字
 

 

用户搜索记录对应的集合，对应实体类：
 

package com.kjz.search.pojos;
​
import lombok.Data;
import org.springframework.data.mongodb.core.mapping.Document;
​
import java.io.Serializable;
import java.util.Date;
​
/*** <p>* APP用户搜索信息表* </p>* @author itheima*/
@Data
@Document("ap_user_search")
public class ApUserSearch implements Serializable {
​private static final long serialVersionUID = 1L;
​/*** 主键*/private String id;
​/*** 用户ID*/private Integer userId;
​/*** 搜索词*/private String keyword;
​/*** 创建时间*/private Date createdTime;
​
}
 

 

4.4.2)实现步骤
 

1.搜索微服务集成mongodb
 

①：pom依赖
 

<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-mongodb</artifactId>
</dependency>
 

②：nacos配置
 

spring:data:mongodb:host: 192.168.200.130port: 27017database: Information-history
 

③：创建对应实体类到到搜索微服务下
 

2.创建ApUserSearchService新增insert方法
 

public interface ApUserSearchService {
​/*** 保存用户搜索历史记录* @param keyword* @param userId*/public void insert(String keyword,Integer userId);
}
 

实现类：
 

@Service
@Slf4j
public class ApUserSearchServiceImpl implements ApUserSearchService {
​@Autowiredprivate MongoTemplate mongoTemplate;/*** 保存用户搜索历史记录* @param keyword* @param userId*/@Override@Asyncpublic void insert(String keyword, Integer userId) {//1.查询当前用户的搜索关键词Query query = Query.query(Criteria.where("userId").is(userId).and("keyword").is(keyword));ApUserSearch apUserSearch = mongoTemplate.findOne(query, ApUserSearch.class);
​//2.存在 更新创建时间if(apUserSearch != null){apUserSearch.setCreatedTime(new Date());mongoTemplate.save(apUserSearch);return;}
​//3.不存在，判断当前历史记录总数量是否超过10apUserSearch = new ApUserSearch();apUserSearch.setUserId(userId);apUserSearch.setKeyword(keyword);apUserSearch.setCreatedTime(new Date());
​Query query1 = Query.query(Criteria.where("userId").is(userId));query1.with(Sort.by(Sort.Direction.DESC,"createdTime"));List<ApUserSearch> apUserSearchList = mongoTemplate.find(query1, ApUserSearch.class);
​if(apUserSearchList == null || apUserSearchList.size() < 10){mongoTemplate.save(apUserSearch);}else {ApUserSearch lastUserSearch = apUserSearchList.get(apUserSearchList.size() - 1);mongoTemplate.findAndReplace(Query.query(Criteria.where("id").is(lastUserSearch.getId())),apUserSearch);}}
}
 

3.参考自媒体相关微服务，在搜索微服务中获取当前登录的用户
 

4.在ArticleSearchService的search方法中调用保存历史记录
 

完整代码如下：
 

package com.heima.search.service.impl;
​
import com.alibaba.fastjson.JSON;
import com.heima.model.common.dtos.ResponseResult;
import com.heima.model.common.enums.AppHttpCodeEnum;
import com.heima.model.search.dtos.UserSearchDto;
import com.heima.model.user.pojos.ApUser;
import com.heima.search.service.ApUserSearchService;
import com.heima.search.service.ArticleSearchService;
import com.heima.utils.thread.AppThreadLocalUtil;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.elasticsearch.action.search.SearchRequest;
import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.common.text.Text;
import org.elasticsearch.index.query.*;
import org.elasticsearch.search.SearchHit;
import org.elasticsearch.search.builder.SearchSourceBuilder;
import org.elasticsearch.search.fetch.subphase.highlight.HighlightBuilder;
import org.elasticsearch.search.sort.SortOrder;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
​
import java.io.IOException;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
​
@Service
@Slf4j
public class ArticleSearchServiceImpl implements ArticleSearchService {
​@Autowiredprivate RestHighLevelClient restHighLevelClient;
​@Autowiredprivate ApUserSearchService apUserSearchService;
​/*** es文章分页检索** @param dto* @return*/@Overridepublic ResponseResult search(UserSearchDto dto) throws IOException {
​//1.检查参数if(dto == null || StringUtils.isBlank(dto.getSearchWords())){return ResponseResult.errorResult(AppHttpCodeEnum.PARAM_INVALID);}
​ApUser user = AppThreadLocalUtil.getUser();
​//异步调用 保存搜索记录if(user != null && dto.getFromIndex() == 0){apUserSearchService.insert(dto.getSearchWords(), user.getId());}
​
​//2.设置查询条件SearchRequest searchRequest = new SearchRequest("app_info_article");SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
​//布尔查询BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery();
​//关键字的分词之后查询QueryStringQueryBuilder queryStringQueryBuilder = QueryBuilders.queryStringQuery(dto.getSearchWords()).field("title").field("content").defaultOperator(Operator.OR);boolQueryBuilder.must(queryStringQueryBuilder);
​//查询小于mindate的数据RangeQueryBuilder rangeQueryBuilder = QueryBuilders.rangeQuery("publishTime").lt(dto.getMinBehotTime().getTime());boolQueryBuilder.filter(rangeQueryBuilder);
​//分页查询searchSourceBuilder.from(0);searchSourceBuilder.size(dto.getPageSize());
​//按照发布时间倒序查询searchSourceBuilder.sort("publishTime", SortOrder.DESC);
​//设置高亮  titleHighlightBuilder highlightBuilder = new HighlightBuilder();highlightBuilder.field("title");highlightBuilder.preTags("<font style='color: red; font-size: inherit;'>");highlightBuilder.postTags("</font>");searchSourceBuilder.highlighter(highlightBuilder);
​
​searchSourceBuilder.query(boolQueryBuilder);searchRequest.source(searchSourceBuilder);SearchResponse searchResponse = restHighLevelClient.search(searchRequest, RequestOptions.DEFAULT);
​
​//3.结果封装返回
​List<Map> list = new ArrayList<>();
​SearchHit[] hits = searchResponse.getHits().getHits();for (SearchHit hit : hits) {String json = hit.getSourceAsString();Map map = JSON.parseObject(json, Map.class);//处理高亮if(hit.getHighlightFields() != null && hit.getHighlightFields().size() > 0){Text[] titles = hit.getHighlightFields().get("title").getFragments();String title = StringUtils.join(titles);//高亮标题map.put("h_title",title);}else {//原始标题map.put("h_title",map.get("title"));}list.add(map);}
​return ResponseResult.okResult(list);
​}
}
 

5.保存历史记录中开启异步调用，添加注解@Async
 

6.在搜索微服务引导类上开启异步调用
 

 

7.测试，搜索后查看结果
 

 

4.5) 加载搜索记录列表
 

4.5.1) 思路分析
 

按照当前用户，按照时间倒序查询
 

说明
接口路径/api/v1/history/load
请求方式POST
参数无
响应结果ResponseResult
 

4.5.2) 接口定义
 

/*** <p>* APP用户搜索信息表 前端控制器* </p>** @author kjz*/
@Slf4j
@RestController
@RequestMapping("/api/v1/history")
public class ApUserSearchController{
​
​@PostMapping("/load")@Overridepublic ResponseResult findUserSearch() {return null;}
​
}
 

4.5.3) mapper
 

已定义
 

4.5.4) 业务层
 

在ApUserSearchService中新增方法
 

/**查询搜索历史@return*/
ResponseResult findUserSearch();
 

实现方法
 

 /*** 查询搜索历史** @return*/
@Override
public ResponseResult findUserSearch() {//获取当前用户ApUser user = AppThreadLocalUtil.getUser();if(user == null){return ResponseResult.errorResult(AppHttpCodeEnum.NEED_LOGIN);}
​//根据用户查询数据，按照时间倒序List<ApUserSearch> apUserSearches = mongoTemplate.find(Query.query(Criteria.where("userId").is(user.getId())).with(Sort.by(Sort.Direction.DESC, "createdTime")), ApUserSearch.class);return ResponseResult.okResult(apUserSearches);
}
 

4.5.5) 控制器
 

/*** <p>* APP用户搜索信息表 前端控制器* </p>* @author itheima*/
@Slf4j
@RestController
@RequestMapping("/api/v1/history")
public class ApUserSearchController{
​@Autowiredprivate ApUserSearchService apUserSearchService;
​@PostMapping("/load")public ResponseResult findUserSearch() {return apUserSearchService.findUserSearch();}
​
}
 

4.5.6) 测试
 

打开app的搜索页面，可以查看搜索记录列表
 

4.6) 删除搜索记录
 

4.6.1) 思路分析
 

按照搜索历史id删除
 

说明
接口路径/api/v1/history/del
请求方式POST
参数HistorySearchDto
响应结果ResponseResult
 

4.6.2) 接口定义
 

在ApUserSearchController接口新增方法
 

@PostMapping("/del")
public ResponseResult delUserSearch(@RequestBody HistorySearchDto historySearchDto) {return null;
}
 

HistorySearchDto
 

@Data
public class HistorySearchDto {/*** 接收搜索历史记录id*/String id;
}
 

4.6.3) 业务层
 

在ApUserSearchService中新增方法
 

 /**删除搜索历史@param historySearchDto@return*/
ResponseResult delUserSearch(HistorySearchDto historySearchDto);
 

实现方法
 

/*** 删除历史记录** @param dto* @return*/
@Override
public ResponseResult delUserSearch(HistorySearchDto dto) {//1.检查参数if(dto.getId() == null){return ResponseResult.errorResult(AppHttpCodeEnum.PARAM_INVALID);}
​//2.判断是否登录ApUser user = AppThreadLocalUtil.getUser();if(user == null){return ResponseResult.errorResult(AppHttpCodeEnum.NEED_LOGIN);}
​//3.删除mongoTemplate.remove(Query.query(Criteria.where("userId").is(user.getId()).and("id").is(dto.getId())),ApUserSearch.class);return ResponseResult.okResult(AppHttpCodeEnum.SUCCESS);
}
 

4.6.4) 控制器
 

修改ApUserSearchController，补全方法
 

@PostMapping("/del")
public ResponseResult delUserSearch(@RequestBody HistorySearchDto historySearchDto) {return apUserSearchService.delUserSearch(historySearchDto);
}
 

4.6.5) 测试
 

打开app可以删除搜索记录
 

5) app端搜索-关键字联想词
 

5.1 需求分析
 

  •  
    根据用户输入的关键字展示联想词
     
 

对应实体类
 

package com.kjz.search.pojos;
​
import lombok.Data;
import org.springframework.data.mongodb.core.mapping.Document;
​
import java.io.Serializable;
import java.util.Date;
​
/*** <p>* 联想词表* </p>** @author kjz*/
@Data
@Document("ap_associate_words")
public class ApAssociateWords implements Serializable {
​private static final long serialVersionUID = 1L;
​private String id;
​/*** 联想词*/private String associateWords;
​/*** 创建时间*/private Date createdTime;
​
}
 

5.2)搜索词-数据来源
 

通常是网上搜索频率比较高的一些词，通常在企业中有两部分来源：
 

第一：自己维护搜索词
 

通过分析用户搜索频率较高的词，按照排名作为搜索词
 

第二：第三方获取
 

关键词规划师（百度）、5118、爱站网
 

 

导入资料中的ap_associate_words.js脚本到mongo中
 

5.3 功能实现
 

5.3.1 接口定义
 

说明
接口路径/api/v1/associate/search
请求方式POST
参数UserSearchDto
响应结果ResponseResult
 

新建接口
 

package com.kjz.search.controller.v1;
​
import com.heima.model.common.dtos.ResponseResult;
import com.heima.model.search.dtos.UserSearchDto;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
​
@RestController
@RequestMapping("/api/v1/associate")
public class ApAssociateWordsController {
​
​@PostMapping("/search")public ResponseResult search(@RequestBody UserSearchDto userSearchDto) {return null;}
}
 

​
 

5.3.3 业务层
 

新建联想词业务层接口
 

package com.kjz.search.service;
​
import com.kjz.model.common.dtos.ResponseResult;
import com.kjz.model.search.dtos.UserSearchDto;
​
/*** <p>* 联想词表 服务类* </p>** @author kjz*/
public interface ApAssociateWordsService {
​/**联想词@param userSearchDto@return*/ResponseResult findAssociate(UserSearchDto userSearchDto);
​
}
 

实现类
 

package com.kjz.search.service.impl;
​
import com.kjz.model.common.dtos.ResponseResult;
import com.kjz.model.common.enums.AppHttpCodeEnum;
import com.kjz.model.search.dtos.UserSearchDto;
import com.kjz.search.pojos.ApAssociateWords;
import com.kjz.search.service.ApAssociateWordsService;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.mongodb.core.MongoTemplate;
import org.springframework.data.mongodb.core.query.Criteria;
import org.springframework.data.mongodb.core.query.Query;
import org.springframework.stereotype.Service;
​
import java.util.List;
​
/*** @Description:* @Version: V1.0*/
@Service
public class ApAssociateWordsServiceImpl implements ApAssociateWordsService {
​@AutowiredMongoTemplate mongoTemplate;
​/*** 联想词* @param userSearchDto* @return*/@Overridepublic ResponseResult findAssociate(UserSearchDto userSearchDto) {//1 参数检查if(userSearchDto == null || StringUtils.isBlank(userSearchDto.getSearchWords())){return ResponseResult.errorResult(AppHttpCodeEnum.PARAM_INVALID);}//分页检查if (userSearchDto.getPageSize() > 20) {userSearchDto.setPageSize(20);}
​//3 执行查询 模糊查询Query query = Query.query(Criteria.where("associateWords").regex(".*?\\" + userSearchDto.getSearchWords() + ".*"));query.limit(userSearchDto.getPageSize());List<ApAssociateWords> wordsList = mongoTemplate.find(query, ApAssociateWords.class);
​return ResponseResult.okResult(wordsList);}
}
 

5.3.4 控制器
 

新建联想词控制器
 

package com.heima.search.controller.v1;
​
import com.kjz.model.common.dtos.ResponseResult;
import com.kjz.model.search.dtos.UserSearchDto;
import com.kjz.search.service.ApAssociateWordsService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
​
/*** <p>* 联想词表 前端控制器* </p>* @author itheima*/
@Slf4j
@RestController
@RequestMapping("/api/v1/associate")
public class ApAssociateWordsController{
​@Autowiredprivate ApAssociateWordsService apAssociateWordsService;
​@PostMapping("/search")public ResponseResult findAssociate(@RequestBody UserSearchDto userSearchDto) {return apAssociateWordsService.findAssociate(userSearchDto);}
}
 

5.3.5 测试
 

同样，打开前端联调测试效果
 

 












本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/web/30252.shtml


如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！











相关文章










MyBatis系列七: 一级缓存，二级缓存，EnCache缓存








MyBatis系列七: 一级缓存，二级缓存，EnCache缓存




缓存-提高检索效率的利器 官方文档 一级缓存基本介绍快速入门Debug一级缓存执行流程一级缓存失效分析 二级缓存基本介绍快速入门Debug二级缓存执行流程注意事项和使用细节 mybatis的一级缓存和二级缓存执行顺序小实验细节说明 EnCache缓存基本介绍配置和使用EhCache细节说明 My…




阅读更多...

















SpringBoot整合Minio(支持公有及私有bucket)








SpringBoot整合Minio(支持公有及私有bucket)




&#x1f60a;  作者&#xff1a; 一恍过去 &#x1f496;  主页&#xff1a; https://blog.csdn.net/zhuocailing3390 &#x1f38a;  社区&#xff1a; Java技术栈交流 &#x1f389;  主题&#xff1a; SpringBoot整合Minio(支持公有及私有bucket) ⏱️  创作时间&#xff1…




阅读更多...

















张大哥笔记：如何选择一个人就值得做的副业








张大哥笔记：如何选择一个人就值得做的副业




很多人喜欢把上班称为主业&#xff0c;把上班之外的工作称为副业&#xff0c;不管以哪种方式称呼都可以&#xff0c;只要能赚钱就行&#xff0c;上班的本质就是出卖时间&#xff0c;不管你是月入5000还是月入2万&#xff0c;都是给老板打工&#xff01; 但搞笑的就是月入2万的人…




阅读更多...

















关于app爬虫的环境准备








关于app爬虫的环境准备




摘要 
有些数据需要在手机应用中才能查看&#xff0c;没有网页版&#xff0c;所以学习移动端的爬虫是有必要的。 
手机系统分为安卓和苹果两大系统&#xff0c;本次讲解主要以安卓手机为例 
有安卓手机的可以使用手机&#xff0c;没有的可以使用模拟器&#xff0c;本次以夜神模…




阅读更多...

















基于C++、MFC和Windows套接字实现的简单聊天室程序开发








基于C++、MFC和Windows套接字实现的简单聊天室程序开发




一、一个简单的聊天室程序 
该程序由服务器端和客户端两个项目组成&#xff0c;这两个项目均基于对话框的程序。服务器端项目负责管理客户端的上线、离线状态&#xff0c;以及转发客户端发送的信息。客户端项目则负责向服务器发送信息&#xff0c;并接收来自服务器的信息&#…




阅读更多...

















[机器学习算法]决策树








[机器学习算法]决策树




1. 理解决策树的基本概念 
决策树是一种监督学习算法&#xff0c;可以用于分类和回归任务。决策树通过一系列规则将数据划分为不同的类别或值。树的每个节点表示一个特征&#xff0c;节点之间的分支表示特征的可能取值&#xff0c;叶节点表示分类或回归结果。  
2. 决策树的构建…




阅读更多...

















《STM32 HAL库》小米微电机控制例程——通信协议分析及驱动库








《STM32 HAL库》小米微电机控制例程——通信协议分析及驱动库




之前有段时间因为机器狗项目的缘故&#xff0c;一直在使用小米微电机&#xff0c;但是苦于没有一个详尽的奶妈级教程&#xff0c;在控制电机的学习中踩了不少的坑。今天咱们就从头至尾一步一步的实现使用按键控制小米微电机。本文将会分析小米电机驱动库&#xff0c;并简要介绍…




阅读更多...

















练手代码之使用Python实现合并PDF文件








练手代码之使用Python实现合并PDF文件




如果你有合并PDF的需要&#xff0c;你会怎么办 
我们无所不能的程序员会选择写一个Python代码来实现&#xff08;谁会这么无聊&#xff1f;是我&#xff09;&#xff0c;如果真的有PDF操作需要&#xff0c;我推荐你使用PDF Expert这个软件哈~ 
话不多说直接上代码&#xff1a; …




阅读更多...

















Linux操作系统学习：day05








Linux操作系统学习：day05




内容来自&#xff1a;Linux介绍 
视频推荐&#xff1a;[Linux基础入门教程-linux命令-vim-gcc/g -动态库/静态库 -makefile-gdb调试](  目录 day0530、删除用户31、添加和删除用户组创建用户组删除用户组 32、修改密码33、使用tar工具进行压缩和解压缩压缩解压缩 34、使用zip u…




阅读更多...

















增强大型语言模型（LLM）可访问性：深入探究在单块AMD GPU上通过QLoRA微调Llama 2的过程








增强大型语言模型（LLM）可访问性：深入探究在单块AMD GPU上通过QLoRA微调Llama 2的过程




Enhancing LLM Accessibility: A Deep Dive into QLoRA Through Fine-tuning Llama 2 on a single AMD GPU — ROCm Blogs 基于之前的博客《使用LoRA微调Llama 2》的内容&#xff0c;我们深入研究了一种称为量化低秩调整&#xff08;QLoRA&#xff09;的参数高效微调&#xff0…




阅读更多...

















单片机第五季-第八课：STM32CubeMx和FreeRTOS








单片机第五季-第八课：STM32CubeMx和FreeRTOS




1&#xff0c;FreeRTOS背景介绍 
RTOS简介&#xff1a; 
实时操作系统&#xff0c;本用于追求实时性的嵌入式系统&#xff0c;典型&#xff1a;ucos/uclinux/vxworks&#xff1b; 
特点&#xff1a;中断响应快、一般可嵌套中断、使用实地址、多任务&#xff1b; 
&#xff08;实…




阅读更多...

















Qt6视频播放器项目框架代码








Qt6视频播放器项目框架代码




视频播放的关键代码如下： 
使用Qt6的QMediaPlayer，QVideoWidget实现 
void FunnyWidget::initVideo()
{player = new QMediaPlayer(this);videoWidget = new QVideoWidget(this);playButton = new QPushButton("Play", this);pauseButton = new QPushButton("…




阅读更多...

















项目的打包








项目的打包




一:打包到微信小程序 
1)vscode打包 2)在微信小程序开发工具中打开路径,上传. 疑问:为什么pnpm bulid:mp-weixin用于打包,pnpm dev:mp-weixin也可生成对应路径下的文件?? 
打包的是没有热重载,且打包体积更小. 
二:条件编译 
vscode可以打包成能在不同平台上运行的代码.但是有…




阅读更多...

















404、左叶子之和








404、左叶子之和




题解&#xff1a;可以采用后序递归遍历的方式&#xff0c;先将左右子树的左叶子节点值计算出来&#xff0c;最后相加。 
当遍历到左叶子节点的父节点时就开始处理&#xff0c;将左叶子节点的值记录下来。 
代码如下&#xff1a; 
class Solution {
public:int sumOfLeftLeaves(…




阅读更多...

















算法金 | 再见！！！梯度下降（多图）








算法金 | 再见！！！梯度下降（多图）




大侠幸会&#xff0c;在下全网同名「算法金」 0 基础转 AI 上岸&#xff0c;多个算法赛 Top 「日更万日&#xff0c;让更多人享受智能乐趣」 接前天 李沐&#xff1a;用随机梯度下降来优化人生&#xff01; 
今天把达叔 6 脉神剑给佩奇了&#xff0c;上 吴恩达&#xff1a;机器…




阅读更多...

















利用 Qwen-VL 进行私有化部署第一个 AI 多模态大模型








利用 Qwen-VL 进行私有化部署第一个 AI 多模态大模型




Hi~&#xff01;这里是奋斗的小羊&#xff0c;很荣幸您能阅读我的文章&#xff0c;诚请评论指点&#xff0c;欢迎欢迎 ~~ &#x1f4a5;&#x1f4a5;个人主页&#xff1a;奋斗的小羊 &#x1f4a5;&#x1f4a5;所属专栏&#xff1a;C语言  &#x1f680;本系列文章为个人学习…




阅读更多...

















【profinet】从站开发要点








【profinet】从站开发要点




目录 
0、常见缩写及关键字注释 
1、profinet简介 
2、profinet协议栈 
3、profinet数据帧 
4、profinet网络解决方案示例 
5、Application areas 注&#xff1a;本文主要简述profinet从站开发涉及到的知识点。【不足之处后续慢慢补充】。 0、常见缩写及关键字注释 
MRP: Media…




阅读更多...

















Spring中IOC容器








Spring中IOC容器




IoC IOC容器 
IoC是一种设计思想&#xff0c;面向对象编程 
Spring通过IoC管理所有Java对象的实例化和初始化&#xff0c;控制对象之间依赖关系 
将IoC容器管理的Java对象称为Spring Bean&#xff0c;与new创建的对象没有区别 控制反转&#xff08;IoC Inversion of Controle&a…




阅读更多...

















宏观必读：数智化、气候能源、多极化趋势并存，如何获得转型性增长？








宏观必读：数智化、气候能源、多极化趋势并存，如何获得转型性增长？




关键词速读&#xff1a; 双转型——创新主导的 “新质生产力”正加速推动中国产业的数字化和绿色低碳“双转型”。 双引擎——企业借助“技术创新”和“生态创新”两大引擎&#xff0c;乘势而上&#xff0c;赢得未来机遇。 生成式 AI 与大模型爆发式发展正在引发计算、开发、交…




阅读更多...

















vue引入vant框架








vue引入vant框架








阅读更多...


















推荐文章












最新文章


















Copyright @ 2022~2023