• SpringBoot应用之配置中心

• SpringBoot应用之分布式会话

• SpringBoot应用之分布式索引

序

本文主要讲怎么在SpringBoot中使用elasticsearch。elasticsearch呢，从其根源来讲，是索引服务，但是讲高端一点，就是分布式的实时文件存储、分布式的实时分析搜索引擎。

准备es

详见 docker环境搭建elasticsearch 这篇。

新建项目

application.properties

spring.data.elasticsearch.repositories.enabled=true  spring.data.elasticsearch.cluster-name=cn-out-of-box  spring.data.elasticsearch.cluster-nodes=192.168.99.100:9300

模型

@Document(indexName = "post", type = "post", shards = 1, replicas = 0)  public class Post {      @Id      private String id;        private String title;        private Double rating;        @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 Double getRating() {          return rating;      }        public void setRating(Double rating) {          this.rating = rating;      }  }

内嵌对象

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

repository

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

service层

@Service  public class PostService {        @Autowired      PostRepository postRepository;        public Post save(Post post){          postRepository.save(post);          return post;      }        public Post findOne(String id) {          return postRepository.findOne(id);      }        public Iterable<Post> findAll() {          return postRepository.findAll();      }        public Page<Post> findByTagsName(String tagName, PageRequest pageRequest) {          return postRepository.findByTagsName(tagName, pageRequest);      }        List<Post> findByRatingBetween(Double beginning, Double end){          return postRepository.findByRatingBetween(beginning,end);      }  }

Test

@RunWith(SpringJUnit4ClassRunner.class)  @SpringApplicationConfiguration(classes = EsdemoApplication.class)  public class EsdemoApplicationTests {        @Autowired      private PostService postService;        @Autowired      private ElasticsearchTemplate elasticsearchTemplate;        @Before      public void before() {          elasticsearchTemplate.deleteIndex(Post.class);          elasticsearchTemplate.createIndex(Post.class);          elasticsearchTemplate.putMapping(Post.class);          elasticsearchTemplate.refresh(Post.class, true);      }        @Test      public void testSave() 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.setRating(9.5);          post.setTags(Arrays.asList(tag, tag2));          postService.save(post);            assertThat(post.getId(), notNullValue());            Post post2 = new Post();          post2.setId("2");          post2.setTitle("Bigining with spring boot application");          post2.setTags(Arrays.asList(tag));          post2.setRating(7.5);          postService.save(post2);          assertThat(post2.getId(), notNullValue());      }        @Test //tag必须不是nested的      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.setRating(9.4);          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));          post2.setRating(9.6);          postService.save(post2);            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));      }    }

save的截图

坑

• NoNodeAvailableException

org.elasticsearch.client.transport.NoNodeAvailableException: None of the configured nodes are available: []

应用中指定的cluster-name与集群中的cluster.name不一致的缘故。

参考

• First Step with Spring Boot and Elasticsearch

• Head first elastic search on java with spring boot and data features

</div>