美文网首页
elasticsearch

elasticsearch

作者: 半日孤独 | 来源:发表于2020-12-09 15:07 被阅读0次

\color{red}{用于大数据的搜索和分析,在此用于分布式中的多字段搜索}

1.引入依赖

      //在此我们使用的是es7.6.2,对应的springboot版本为2.3.2
        <dependency>
            <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-data-elasticsearch</artifactId>
        </dependency>

2.配置文件

// yml中的配置
elasticsearch:
  rest:
    uris: 127.0.0.1:9200 //分布式的可配置多个:127.0.0.1:9200,127.0.0.1:9201,127.0.0.1:9202
    username: elastic
    password: zzp@2020
  repositories:
    enabled: true
//连接客户端配置,es7.x推荐使用,之前版本都是在yml配置就行,且端口号使用9300,但已被废弃。
@Configuration
public class RestClientConfig extends AbstractElasticsearchConfiguration {
    @Value("${elasticsearch.rest.uris}")
    private String hostAndPort;

    @Value("${elasticsearch.rest.username}")
    private String username;

    @Value("${elasticsearch.rest.password}")
    private String password;

    @Override
    public RestHighLevelClient elasticsearchClient() {
        ClientConfiguration clientConfiguration = ClientConfiguration.builder()
                .connectedTo(hostAndPort)
                .withConnectTimeout(Duration.ofSeconds(5))
                .withSocketTimeout(Duration.ofSeconds(3))
                .withBasicAuth(username, password)//如使用默认用户名和密码,请注释掉
                .build();
        return RestClients.create(clientConfiguration).rest();
    }
}

3.实体类

@Data
@JsonInclude(JsonInclude.Include.NON_NULL)
@Document(indexName = "person") //在es中进行声明一个索引,会通过此索引查找数据
public class PersonEntity implements Serializable {

    @Id//必须指定id
    private String personId;//人员id
    @Field(type= FieldType.Text,analyzer="ik_max_word")//表示es中字段的类型和分词方式
    private String name;//姓名
    @Field(type= FieldType.Keyword)
    private String idCard;//身份证
    @Field(type= FieldType.Keyword)
    private Integer sex;//性别:1 男,2 女
}

3.service

在此要重写一下ElasticsearchRepository类,并且采用es默认的分词器
@Repository
//将实体类注册进来,String表示实体类中的id类型
public interface PersonRepository extends ElasticsearchRepository<PersonEntity, String> {
}
          @Autowired
           private PersonRepository personRepository;
          
           Page<RckPersonEntity> page;
           //查询所有
            Pageable pageable = PageRequest.of(pageNo - 1, pageSize);
            page = personRepository.findAll(pageable);

            //带条件查询
            String text ="张中国";//查询条件
           //字段名
           private static String[] items = {"name", "title"};
            NativeSearchQuery searchQuery = new NativeSearchQueryBuilder()
                    .withQuery(QueryBuilders.multiMatchQuery(text, items))//查询条件
                    .withPageable(PageRequest.of(pageNo - 1, pageSize))//分页条件
                    .withHighlightFields(new HighlightBuilder.Field(items[0]))//高亮字段
                    .build();
            page = personRepository.search(searchQuery);
            
              //单条保存
             personRepository.save(new PersonEntity());
             //  保存所有
             personRepository.saveAll(list);
             //注:如果search方法已过期,请使用以下查询
             @Autowired
            private ElasticsearchRestTemplate elasticsearchRestTemplate;
            NativeSearchQuery nativeSearchQuery = new NativeSearchQueryBuilder()
                //查询条件,没有defaultField则为所有字段
                .withQuery(QueryBuilders.multiMatchQuery(text ,items))
                //分页
                .withPageable(PageRequest.of(0, 5))
                //排序
                .withSort(SortBuilders.fieldSort("id").order(SortOrder.DESC))
                //高亮字段显示
                .withHighlightFields(new HighlightBuilder.Field(items[0]))
                .build();
              List<PersonEntity> articleEntities = 
              elasticsearchRestTemplate.queryForList(nativeSearchQuery, PersonEntity.class); 

4.安装客户端

客户端的选择得根据springboot的版本进行匹配,因为我使用的是springboot集成的,以下是怎么查看客户端版本号:

elasticSearch.png
\color{red}{官网下载太慢,下载地址请查看这个老哥写的}
https://blog.csdn.net/weixin_37281289/article/details/101483434
下载之后直接启动就好了

5.修改密码

主要修改 elasticsearch.yml 文件,在es安装目录的config中
1.添加
http.cors.enabled: true
http.cors.allow-origin: "*"
http.cors.allow-headers: Authorization
xpack.security.enabled: true
xpack.security.transport.ssl.enabled: true
2.运行cmd
先启动,然后在安装目录的bin下进入cmd,运行:elasticsearch-setup-passwords.bat interactive
随后输入密码即可
3.验证密码是否修改成功,访问:localhost:9200
默认用户名:elastic,密码为你修改后的

6.扩展

若想安装ik分词器请访问这个老哥的:https://blog.csdn.net/csdn_20150804/article/details/105474229

8.注意

如果查询出来的结果与现实结果不匹配,大部分是写入的数据分词与查询的分词类型不一致导致。
解决办法:重新写入,如还不能解决,请还原配置文件,在写入。如还不能解决,请自行百度。

9.更多QueryBuilders使用

https://blog.csdn.net/csdn_20150804/article/details/105618933

相关文章

网友评论

      本文标题:elasticsearch

      本文链接:https://www.haomeiwen.com/subject/dcqhgktx.html