查看: 85|回复: 0

Spring Boot系列(十)Spring Boot整合Elasticsearch全文搜索引擎

发表于 2018-5-15 16:11:01
这一篇介绍Spring Boot整合Elasticsearch全文搜索引擎,需要springboot实战完整视频教程的,点击这里!
Elastic Search是一个开源的,分布式,实时搜索和分析引擎。Spring Boot为Elasticsearch及Spring Data Elasticsearch提供的基于它的抽象提供了基本的配置。Spring Boot提供了一个用于聚集依赖的spring-boot-starter-data-elasticsearch 'StarterPOM'。
引入spring-boot-starter-data-elasticsearch依赖,在pom.xml配置文件中增加如下内容(基于之前章节“Spring Boot 构建框架”中的pom.xml文件):
org.springframework.boot
spring-boot-starter-data-elasticsearch
可以像其他Spring beans那样注入一个自动配置的ElasticsearchTemplate或Elasticsearch客户端实例。默认情况下,该实例将尝试连接到一个本地内存服务器(在Elasticsearch项目中的一个NodeClient),但可以通过设置spring.data.elasticsearch.clusterNodes为一个以逗号分割的host:port列表来将其切换到一个远程服务器(比如,TransportClient)。
@Component
publicclass MyBean {
privateElasticsearchTemplatetemplate;
@Autowired
public MyBean(ElasticsearchTemplate template) {
this.template=template;
}
// ...
}
如果添加一个自己的ElasticsearchTemplate类型的@Bean,它将替换默认的。
应用集成ElasticSearch案例
新建elasticsearch.properties配置文件,添加如下配置内容:
elasticsearch.host=localhost
elasticsearch.port=9300
ElasticSearch配置,读取elasticsearch.properties配置文件信息,具体代码如下:
@Configuration@PropertySource(value ="classpath:elasticsearch.properties")
@EnableElasticsearchRepositories(basePackages ="co.paan.repository")
publicclass ElasticsearchConfiguration {
@Resource
privateEnvironment environment;
@Bean
public Client client() {
TransportClient client =newTransportClient();
TransportAddress address =newInetSocketTransportAddress(environment.getProperty("elasticsearch.host"), Integer.parseInt(environment.getProperty("elasticsearch.port")));
client.addTransportAddress(address);
returnclient;
}
@BeanpublicElasticsearchOperations elasticsearchTemplate() {
returnnewElasticsearchTemplate(client());
}
}
两个实体类,具体代码如下:
@Document(indexName ="post",type="post", shards =1, replicas =0)
publicclassPost {
@Id
privateStringid;
privateStringtitle;
@Field(type= FieldType.Nested)
privateList tags;
publicStringgetId() {
returnid;
}
publicvoidsetId(Stringid) {
this.id = id;
}
publicStringgetTitle() {
returntitle;
}
publicvoidsetTitle(Stringtitle) {
this.title = title;
}
publicList getTags() {
returntags;
}
publicvoidsetTags(List tags) {
this.tags = tags;
}
}
publicclassTag {
privateStringid;
privateStringname;
publicStringgetId() {
returnid;
}
publicvoidsetId(Stringid) {
this.id = id;
}
publicStringgetName() {
returnname;
}
publicvoidsetName(Stringname) {
this.name = name;
}
}
数据源继承ElasticsearchRepository类,封装接口代码如下:
publicinterface PostRepository extends ElasticsearchRepository{
Page findByTagsName(String name, Pageable pageable);
}
数据服务接口及实现类,代码如下:
publicinterface PostService {
Post save(Post post);
Post findOne(String id);
Iterable findAll();
Page findByTagsName(String tagName, PageRequest pageRequest);
}
@Servicepublicclass PostServiceImpl implements PostService{
@Autowired
privatePostRepository postRepository;
@Override
public Post save(Post post) {
postRepository.save(post);
returnpost;
}
@OverridepublicPost findOne(String id) {
returnpostRepository.findOne(id);
}
@OverridepublicIterable findAll() {
returnpostRepository.findAll();
}
@OverridepublicPage findByTagsName(String tagName, PageRequest pageRequest) {
returnpostRepository.findByTagsName(tagName, pageRequest);
}
}

工作一到五年的程序员朋友面对目前的技术无从下手,感到很迷茫可以加群744677563,里面有阿里Java高级大牛直播讲解知识点,分享知识,课程内容都是各位老师多年工作经验的梳理和总结,带着大家全面、科学地建立自己的技术体系和技术认知!



回复

使用道具 举报