Spring Boot整合Elasticsearch如何實(shí)現(xiàn)全文搜索引擎

這篇文章給大家分享的是有關(guān)Spring Boot整合Elasticsearch如何實(shí)現(xiàn)全文搜索引擎的內(nèi)容。小編覺(jué)得挺實(shí)用的，因此分享給大家做個(gè)參考，一起跟隨小編過(guò)來(lái)看看吧。

簡(jiǎn)單說(shuō)，ElasticSearch（簡(jiǎn)稱 ES）是搜索引擎，是結(jié)構(gòu)化數(shù)據(jù)的分布式搜索引擎。Elastic Search是一個(gè)開源的，分布式，實(shí)時(shí)搜索和分析引擎。Spring Boot為Elasticsearch及Spring Data Elasticsearch提供的基于它的抽象提供了基本的配置。Spring Boot提供了一個(gè)用于聚集依賴的spring-boot-starter-data-elasticsearch 'StarterPOM'。

引入spring-boot-starter-data-elasticsearch依賴，在pom.xml配置文件中增加如下內(nèi)容（基于之前章節(jié)“Spring Boot 構(gòu)建框架”中的pom.xml文件）：

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

可以像其他Spring beans那樣注入一個(gè)自動(dòng)配置的ElasticsearchTemplate或Elasticsearch客戶端實(shí)例。默認(rèn)情況下，該實(shí)例將嘗試連接到一個(gè)本地內(nèi)存服務(wù)器（在Elasticsearch項(xiàng)目中的一個(gè)NodeClient），但可以通過(guò)設(shè)置spring.data.elasticsearch.clusterNodes為一個(gè)以逗號(hào)分割的host:port列表來(lái)將其切換到一個(gè)遠(yuǎn)程服務(wù)器（比如，TransportClient）。

@Component
public class MyBean {
 private ElasticsearchTemplate template;
 
 @Autowired
 public MyBean(ElasticsearchTemplate template) {
 this.template = template;
 }
 // ...
}

如果添加一個(gè)自己的ElasticsearchTemplate類型的@Bean，它將替換默認(rèn)的。

應(yīng)用集成ElasticSearch案例

新建elasticsearch.properties配置文件，添加如下配置內(nèi)容：

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());
 }
}

兩個(gè)實(shí)體類，具體代碼如下：

@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;
 }
}

數(shù)據(jù)源繼承ElasticsearchRepository類，封裝接口代碼如下：

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

數(shù)據(jù)服務(wù)接口及實(shí)現(xiàn)類，代碼如下：

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);
 }
}

測(cè)試代碼如下：

@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));
}

感謝各位的閱讀！關(guān)于“Spring Boot整合Elasticsearch如何實(shí)現(xiàn)全文搜索引擎”這篇文章就分享到這里了，希望以上內(nèi)容可以對(duì)大家有一定的幫助，讓大家可以學(xué)到更多知識(shí)，如果覺(jué)得文章不錯(cuò)，可以把它分享出去讓更多的人看到吧！