spring boot2集成ES的过程讲解

本篇内容介绍了"spring boot2集成ES的过程讲解"的有关知识，在实际案例的操作过程中，不少人都会遇到这样的困境，接下来就让小编带领大家学习一下如何处理这些情况吧！希望大家仔细阅读，能够学有所成！

一：运行环境

JDK：1.8

ES：5.6.4

二：学习内容

如何构建spring-data-elasticsearch环境？

如何实现常用的增删改查？

如何实现对象嵌套也就是1对多这种关系？

三：JAVA依赖环境

根据spring-data-elasticsearch官网说明，我这采用的是3.0.6.RELEASE版本，spring boot采用的是2.0.1.RELEASE；

   4.0.0            org.springframework.boot         spring-boot-starter-parent         2.0.1.RELEASE                  com.huize.pluto.els      demo       1.0.0-SNAPSHOT   jar  demo   http://maven.apache.org                UTF-8          5.6.4                1.8                                           spring-libs-milestone                      https://repo.spring.io/libs-milestone                                                          spring-plugins-release                     https://repo.spring.io/plugins-release                                                         org.springframework.boot                 spring-boot-starter-web                                                               org.springframework.boot                 spring-boot-starter-test                   test                                                            org.springframework.data                 spring-data-elasticsearch                  3.0.6.RELEASE                                                                 org.elasticsearch                        elasticsearch                      ${elasticsearch.version}                                                                    org.elasticsearch.client                 transport                  ${elasticsearch.version}                                                                                      commons-logging                                  commons-logging                                                                                                                                                                          org.apache.maven.plugins                                maven-compiler-plugin                                3.5.1                                                                        1.8                                        1.8                                        1.8                                        UTF-8                                                                                

四、spring-data-elasticsearch详解

4.1：配置ES

声明 ElasticsearchTemplate bean ;（当然也可以采用spring boot自动配置方法来实现，因为后面还得直接用JAVA API操作ES，所以这用代码配置了）

/*** ** 配置ES,支持集群 */@Configurationpublic class ElasticConfigration {    @Value("${elasticsearch.host}")    private String esHost;    @Value("${elasticsearch.port}")    private int esPort;    @Value("${elasticsearch.clusterName}")    private String esClusterName;        private TransportClient client;        @PostConstruct    public void initialize() throws Exception {           Settings esSettings = Settings.builder()                  .put("cluster.name", esClusterName)                  .put("client.transport.sniff", true).build();           client = new PreBuiltTransportClient(esSettings);           String[] esHosts = esHost.trim().split(",");    for (String host : esHosts) {               client.addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName(host),            esPort));           }    }        @Bean    public Client client() {       return client;    }            @Bean    public ElasticsearchTemplate elasticsearchTemplate() throws Exception {      return new ElasticsearchTemplate(client);    }            @PreDestroy    public void destroy() {         if (client != null) {               client.close();           }    }}

4.2：编写实体类

声明各个字段类型及相应属性：

/** * 声明 USER实体，注意有一个1对多关系的roles **/@Document(indexName = "test-user", type = "user",replicas=0,shards=3)public class User {        @Id    private String id;        @Field(type=FieldType.keyword)    private String userName;        @Field(type=FieldType.Integer)    private Integer age;        @Field(type=FieldType.Date)    private Date birthday;        /**     * 声明分词器为ik_smart (注意 es要安装ik分词器插件)     */    @Field(searchAnalyzer="ik_smart",analyzer="ik_smart",type=FieldType.text)    private String description;        /**     * 1对多在spring-data-elasticsearch 统一为nested类型     **/    @Field(type=FieldType.Nested,includeInParent=true)    private List roles;            public User() {}        public User(String userName,Integer age,Date birthday,String description) {          this.userName = userName;      this.age = age;        this.birthday = birthday;      this.description = description;    }        public String getId() {        return id;    }        public void setId(String id) {        this.id = id;    }        public String getUserName() {        return userName;    }        public void setUserName(String userName) {        this.userName = userName;    }            public Date getBirthday() {        return birthday;    }        public void setBirthday(Date birthday) {        this.birthday = birthday;    }    public Integer getAge() {        return age;    }        public void setAge(Integer age) {        this.age = age;    }        public String getDescription() {        return description;    }        public void setDescription(String description) {        this.description = description;    }        public List getRoles() {        return roles;    }        public void setRoles(List roles) {        this.roles = roles;    }        }@Document(indexName = "test-role", type = "role",replicas=0,shards=3)public class Role {        @Id    private String id;        @Field(type=FieldType.keyword)    private String name;        @Field(type=FieldType.Date)    private Date createTime;        @Field(searchAnalyzer="ik_smart",analyzer="ik_smart",type=FieldType.text)    private String description;        public Role() {}        public Role(String name,String description,Date createTime) {  this.name = name;     this.description = description;       this.createTime = createTime;    }        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;    }        public Date getCreateTime() {        return createTime;    }        public void setCreateTime(Date createTime) {        this.createTime = createTime;    }        public String getDescription() {        return description;    }        public void setDescription(String description) {        this.description = description;    }    }

4.3：编写dao

只要继承ElasticsearchRepository就具有常用的增删减查功能了，可以新增一些其他需要用到的查询

public interface UserRepository extends ElasticsearchRepository{        //按userName like查询    List findByUserNameLike(String userName);        //按role的name属性查询    List findByRolesName(String name);        //按role的name属性查询 两种方式都可以    List findByRoles_Name(String name);    }

4.4：编写service

@Servicepublic class UserStandardService implements StandardService{        @Autowired    private UserRepository userRepository;        @Autowired    private ElasticsearchTemplate elasticsearchTemplate;        /**     * 批量新增     **/    @Override    public void batchAddUser(List users) {           if(CollectionUtils.isEmpty(users)) {           return ;           }           List queries = Lists.newArrayListWithExpectedSize(users.size());           IndexQuery indexItem  = null;        for(User user :users) {               indexItem = new IndexQuery();               indexItem.setObject(user);               queries.add(indexItem);           }           elasticsearchTemplate.bulkIndex(queries);    }        @Override    public void addUser(User user) {           userRepository.save(user);    }    @Override    public void deletedUserById(String id) {           userRepository.deleteById(id);    }    /**     * 根据userId更新信息     */    @Override    public void updateUser(User user) {           UpdateQuery updateQuery = new UpdateQuery();           updateQuery.setId(user.getId());           updateQuery.setClazz(User.class);           user.setId(null);           UpdateRequest request = new UpdateRequest();           request.doc(JsonUtils.beanToJson(user));           updateQuery.setUpdateRequest(request);           elasticsearchTemplate.update(updateQuery);    }    @Override    public List queryByUserName(String userName) {           return userRepository.findByUserNameLike(userName);    }    @Override    public List queryByRoleName(Role role) {         return userRepository.findByRoles_Name(role.getName());    }}

4.5：启动

主要要加上 @EnableElasticsearchRepositories 注解；

@EnableElasticsearchRepositories(basePackages = "com.test.els.demo.core.user.repository")@SpringBootApplicationpublic class DemoApplication {        private static final Logger logger = LoggerFactory.getLogger(DemoApplication.class);        public static void main(String[] args) {                   SpringApplication.run(DemoApplication.class, args);           logger.info("start completed ！");    }        }

OK，到这spring-data-elasticsearch 实践完了。

"spring boot2集成ES的过程讲解"的内容就介绍到这里了，感谢大家的阅读。如果想了解更多行业相关的知识可以关注网站，小编将为大家输出更多高质量的实用文章！