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集成的,以下是怎么查看客户端版本号:
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