搜索引擎优化指南2.0(本文分布式多用户能力的全文搜索引擎源码:GitHub·点这里 )

优采云 发布时间: 2022-04-01 21:19

  搜索引擎优化指南2.0(本文分布式多用户能力的全文搜索引擎源码:GitHub·点这里

)

  本文源码:GitHub·点击这里|| GitEE·点击这里

  一、安装与介绍

  ElasticSearch 是一个基于 Lucene 的搜索服务器。它提供了一个基于 RESTful Web 界面的分布式多用户全文搜索引擎。 Elasticsearch 使用 Java 开发并根据 Apache 许可条款作为开源版本发布,是当前流行的企业搜索引擎。

  搭建运行环境

  Linux系统:centos7下搭建ElasticSearch中间件,常用界面演示

  二、与SpringBoot2集成1、核心依赖

  

org.springframework.boot

spring-boot-starter-data-elasticsearch

${spring-boot.version}

  2、配置文件

  spring:

application:

name: ware-elastic-search

data:

elasticsearch:

# 默认 elasticsearch

cluster-name: elasticsearch

# 9200作为Http协议,主要用于外部通讯

# 9300作为Tcp协议,jar之间就是通过tcp协议通讯

cluster-nodes: 192.168.72.130:9300

  3、实体类配置

  文档配置

  添加@Document注解后,该实体中的所有属性默认都会被索引和标记化。

  indexName 索引名理解为数据库名,仅限小写

  type理解为数据库的表名

  shards = 5 默认分区数

  replicas = 1 每个分区的默认备份数

  refreshInterval = "1s" 刷新间隔

  indexStoreType = "fs" 索引文件存储类型

  @Document(indexName = "requestlogindex",type = "requestlog")

public class RequestLog {

//Id注解Elasticsearch里相应于该列就是主键,查询时可以使用主键查询

@Id

private Long id;

private String orderNo;

private String userId;

private String userName;

private String createTime;

}

  4、数据交互层

  实现 ElasticsearchRepository 接口。

  public interface RequestLogRepository

extends ElasticsearchRepository {

}

  5、演示案例

  数据添加、修改、查询、排序、多条件查询。

  @Service

public class RequestLogServiceImpl implements RequestLogService {

@Resource

private RequestLogRepository requestLogRepository ;

@Override

public String esInsert(Integer num) {

for (int i = 0 ; i < num ; i++){

RequestLog requestLog = new RequestLog() ;

requestLog.setId(System.currentTimeMillis());

requestLog.setOrderNo(DateUtil.formatDate(new Date(),DateUtil.DATE_FORMAT_02)+System.currentTimeMillis());

requestLog.setUserId("userId"+i);

requestLog.setUserName("张三"+i);

requestLog.setCreateTime(DateUtil.formatDate(new Date(),DateUtil.DATE_FORMAT_01));

requestLogRepository.save(requestLog) ;

}

return "success" ;

}

@Override

public Iterable esFindAll (){

return requestLogRepository.findAll() ;

}

@Override

public String esUpdateById(RequestLog requestLog) {

requestLogRepository.save(requestLog);

return "success" ;

}

@Override

public Optional esSelectById(Long id) {

return requestLogRepository.findById(id) ;

}

@Override

public Iterable esFindOrder() {

// 用户名倒序

// Sort sort = new Sort(Sort.Direction.DESC,"userName.keyword") ;

// 创建时间正序

Sort sort = new Sort(Sort.Direction.ASC,"createTime.keyword") ;

return requestLogRepository.findAll(sort) ;

}

@Override

public Iterable esFindOrders() {

List sortList = new ArrayList() ;

Sort.Order sort1 = new Sort.Order(Sort.Direction.ASC,"createTime.keyword") ;

Sort.Order sort2 = new Sort.Order(Sort.Direction.DESC,"userName.keyword") ;

sortList.add(sort1) ;

sortList.add(sort2) ;

Sort orders = Sort.by(sortList) ;

return requestLogRepository.findAll(orders) ;

}

@Override

public Iterable search() {

// 全文搜索关键字

/*

String queryString="张三";

QueryStringQueryBuilder builder = new QueryStringQueryBuilder(queryString);

requestLogRepository.search(builder) ;

*/

/*

* 多条件查询

*/

QueryBuilder builder = QueryBuilders.boolQuery()

// .must(QueryBuilders.matchQuery("userName.keyword", "历张")) 搜索不到

.must(QueryBuilders.matchQuery("userName", "张三")) // 可以搜索

.must(QueryBuilders.matchQuery("orderNo", "20190613736278243"));

return requestLogRepository.search(builder) ;

}

}

  三、源码地址

  GitHub·地址

https://github.com/cicadasmile/middle-ware-parent

GitEE·地址

https://gitee.com/cicadasmile/middle-ware-parent

0 个评论

要回复文章请先登录注册


官方客服QQ群

微信人工客服

QQ人工客服


线