Spring Boot整合Elasticsearch实现全文搜索引擎案例解析

 更新时间:2017年11月02日 10:07:10   投稿:mrr  
ElasticSearch作为基于Lucene的搜索服务器,既可以作为一个独立的服务部署,也可以签入Web应用中。SpringBoot作为Spring家族的全新框架,使得使用SpringBoot开发Spring应用变得非常简单,在本案例中我们给大家介绍Spring Boot整合Elasticsearch实现全文搜索引擎

简单说,ElasticSearch(简称 ES)是搜索引擎,是结构化数据的分布式搜索引擎。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文件):

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

可以像其他Spring beans那样注入一个自动配置的ElasticsearchTemplate或Elasticsearch客户端实例。默认情况下,该实例将尝试连接到一个本地内存服务器(在Elasticsearch项目中的一个NodeClient),但可以通过设置spring.data.elasticsearch.clusterNodes为一个以逗号分割的host:port列表来将其切换到一个远程服务器(比如,TransportClient)。

@Component
public class MyBean {
 private ElasticsearchTemplate template;
 
 @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")
public class ElasticsearchConfiguration {
 @Resource
private Environment environment;
@Bean
public Client client() {
TransportClient client = new TransportClient();
TransportAddress address = new InetSocketTransportAddress(environment.getProperty("elasticsearch.host"), Integer.parseInt(environment.getProperty("elasticsearch.port")));
client.addTransportAddress(address); 
return client;
}
 @Beanpublic ElasticsearchOperations elasticsearchTemplate() {
 return new ElasticsearchTemplate(client());
 }
}

两个实体类,具体代码如下:

@Document(indexName = "post", type = "post", shards = 1, replicas = 0)
public class Post {
@Id
private String id;
 private String title;
@Field(type= FieldType.Nested)
private List<Tag> tags; 
 public String getId() {
return id;
}
 public void setId(String id) {
 this.id = id;
}
 public String getTitle() {
 return title;
}
 public void setTitle(String title) {
 this.title = title;
}
 public List<Tag> getTags() {
 return tags;
}
 public void setTags(List<Tag> tags) {
 this.tags = tags;
}
}
public class Tag {
private String id; 
private String name; 
public String getId() {
 return id;
 }
 public void setId(String id) {
 this.id = id;
 }
 public String getName() {
 return name;
 }
 public void setName(String name) {
 this.name = name;
 }
}

数据源继承ElasticsearchRepository类,封装接口代码如下:

public interface PostRepository extends ElasticsearchRepository<Post, String>{
 Page<Post> findByTagsName(String name, Pageable pageable);
}

数据服务接口及实现类,代码如下:

public interface PostService {
 Post save(Post post);
 Post findOne(String id);
 Iterable<Post> findAll();
 Page<Post> findByTagsName(String tagName, PageRequest pageRequest);
}
@Servicepublic class PostServiceImpl implements PostService{
 @Autowired
private PostRepository postRepository;
@Override
public Post save(Post post) {
 postRepository.save(post); 
 return post;
 }
 @Overridepublic Post findOne(String id) {
 return postRepository.findOne(id);
 }
 @Overridepublic Iterable<Post> findAll() {
 return postRepository.findAll();
 }
 @Overridepublic Page<Post> findByTagsName(String tagName, PageRequest pageRequest) {
 return postRepository.findByTagsName(tagName, pageRequest);
 }
}

测试代码如下:

@Test
public void testFindByTagsName() throws Exception {
 Tag tag = new Tag();
 tag.setId("1");
 tag.setName("tech");
 Tag tag2 = new Tag();
 tag2.setId("2");
 tag2.setName("elasticsearch");
 Post post = new Post();
 post.setId("1");
 post.setTitle("Bigining with spring boot application and elasticsearch");
 post.setTags(Arrays.asList(tag, tag2));
 postService.save(post);
 Post post2 = new Post();
 post2.setId("1");
 post2.setTitle("Bigining with spring boot application");
 post2.setTags(Arrays.asList(tag));
 postService.save(post);
 Page<Post> posts = postService.findByTagsName("tech", new PageRequest(0,10));
 Page<Post> posts2 = postService.findByTagsName("tech", new PageRequest(0,10));
 Page<Post> posts3 = postService.findByTagsName("maz", new PageRequest(0,10));
 assertThat(posts.getTotalElements(), is(1L));
 assertThat(posts2.getTotalElements(), is(1L));
 assertThat(posts3.getTotalElements(), is(0L));
}

总结

以上所述是小编给大家介绍的Spring Boot整合Elasticsearch实现全文搜索引擎案例解析,希望对大家有所帮助,如果大家有任何疑问请给我留言,小编会及时回复大家的。在此也非常感谢大家对脚本之家网站的支持!

相关文章

  • 使用自定义注解和@Aspect实现责任链模式的组件增强的详细代码

    使用自定义注解和@Aspect实现责任链模式的组件增强的详细代码

    责任链模式是一种行为设计模式,其作用是将请求的发送者和接收者解耦,从而可以灵活地组织和处理请求,本文讲给大家介绍如何使用自定义注解和@Aspect实现责任链模式的组件增强,文中有详细的代码示例供大家参考,感兴趣的同学可以借鉴一下
    2023-05-05
  • Java中实现代码优化的技巧分享

    Java中实现代码优化的技巧分享

    这篇文章主要跟大家谈谈优化这个话题,那么我们一起聊聊Java中如何实现代码优化这个问题,小编这里有几个实用的小技巧分享给大家,需要的可以参考一下
    2022-08-08
  • Java中BigDecimal的equals方法和compareTo方法的区别详析

    Java中BigDecimal的equals方法和compareTo方法的区别详析

    这篇文章主要给大家介绍了关于Java中BigDecimal的equals方法和compareTo方法区别的相关资料,对于BigDecimal的大小比较,用equals方法的话会不仅会比较值的大小,还会比较两个对象的精确度,而compareTo方法则不会比较精确度,只比较数值的大小,需要的朋友可以参考下
    2023-11-11
  • Java使用TCP套接字实现多人聊天功能详解

    Java使用TCP套接字实现多人聊天功能详解

    这篇文章主要介绍了Java使用TCP套接字实现多人聊天功能,结合实例形式详细分析了java使用socket通信实现tcp协议下的聊天功能客户端与服务器端相关实现技巧,需要的朋友可以参考下
    2019-10-10
  • Scala之Object的具体使用(小结)

    Scala之Object的具体使用(小结)

    这篇文章主要介绍了Scala之Object的具体使用(小结),文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2019-06-06
  • Mybatis查询时的延迟加载解析

    Mybatis查询时的延迟加载解析

    这篇文章主要介绍了Mybatis查询时的延迟加载解析,先从单表查询,需要时再从关联表去关联查询,能大大提高数据库性能,因为查询单表要比关联查询多张表速度要快,延迟加载分为两种:深度延时加载,侵入式延迟加载,需要的朋友可以参考下
    2023-10-10
  • JavaWeb pageContext对象原理解析

    JavaWeb pageContext对象原理解析

    这篇文章主要介绍了JavaWeb pageContext对象原理解析,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2020-02-02
  • java基于反射得到对象属性值的方法

    java基于反射得到对象属性值的方法

    这篇文章主要介绍了java基于反射得到对象属性值的方法,结合实例形式分析了java基于反射获取对象属性值的相关实现方法与操作技巧,需要的朋友可以参考下
    2017-03-03
  • JDK的一个Bug监听文件变更的初步实现思路

    JDK的一个Bug监听文件变更的初步实现思路

    这篇文章主要介绍了JDK的一个Bug监听文件变更要小心了,本篇文章就带大家简单实现一个对应的功能,并分析一下对应的Bug和优缺点,需要的朋友可以参考下
    2022-05-05
  • mybatis项目CRUD步骤实例详解

    mybatis项目CRUD步骤实例详解

    这篇文章主要介绍了mybatis项目CRUD步骤,包括pom.xml引入相应的依赖,在resources目录下写配置文件,本文结合实例代码给大家介绍的非常详细,需要的朋友可以参考下
    2022-09-09

最新评论