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；

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>2.0.1.RELEASE</version><relativePath /></parent><groupId>com.huize.pluto.els</groupId><artifactId>demo</artifactId><version>1.0.0-SNAPSHOT</version><packaging>jar</packaging><name>demo</name><url>http://maven.apache.org</url><properties><project.build.sourceEncoding>UTF-8</project.build.sourceEncoding><elasticsearch.version>5.6.4</elasticsearch.version><java.version>1.8</java.version></properties><repositories><repository><id>spring-libs-milestone</id><url>https://repo.spring.io/libs-milestone</url></repository></repositories><pluginRepositories><pluginRepository><id>spring-plugins-release</id><url>https://repo.spring.io/plugins-release</url></pluginRepository></pluginRepositories><dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope></dependency><dependency><groupId>org.springframework.data</groupId><artifactId>spring-data-elasticsearch</artifactId><version>3.0.6.RELEASE</version></dependency><!-- 强制声明ES版本 --><dependency><groupId>org.elasticsearch</groupId><artifactId>elasticsearch</artifactId><version>${elasticsearch.version}</version></dependency><!-- 因为要采用java编码直接操作ES所以需要引入 --><dependency><groupId>org.elasticsearch.client</groupId><artifactId>transport</artifactId><version>${elasticsearch.version}</version><exclusions><exclusion><groupId>commons-logging</groupId><artifactId>commons-logging</artifactId></exclusion></exclusions></dependency></dependencies><build><plugins><plugin><groupId>org.apache.maven.plugins</groupId><artifactId>maven-compiler-plugin</artifactId><version>3.5.1</version><configuration><source>1.8</source><target>1.8</target><compilerVersion>1.8</compilerVersion><encoding>UTF-8</encoding></configuration></plugin></plugins></build></project>

 

四、spring-data-elasticsearch详解

4.1：配置ES

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

/***** 配置ES,支持集群*/
@Configuration
public class ElasticConfigration {@Value("${elasticsearch.host}")private String esHost;@Value("${elasticsearch.port}")private int esPort;@Value("${elasticsearch.clusterName}")private String esClusterName;private TransportClient client;@PostConstructpublic 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));}}@Beanpublic Client client() {return client;}@Beanpublic ElasticsearchTemplate elasticsearchTemplate() throws Exception {return new ElasticsearchTemplate(client);}@PreDestroypublic 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 {@Idprivate 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<Role> 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<Role> getRoles() {return roles;}public void setRoles(List<Role> roles) {this.roles = roles;}}@Document(indexName = "test-role", type = "role",replicas=0,shards=3)
public class Role {@Idprivate 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<User,String>{//按userName like查询List<User> findByUserNameLike(String userName);//按role的name属性查询List<User> findByRolesName(String name);//按role的name属性查询 两种方式都可以List<User> findByRoles_Name(String name);}

4.4：编写service

@Service
public class UserStandardService implements StandardService{@Autowiredprivate UserRepository userRepository;@Autowiredprivate ElasticsearchTemplate elasticsearchTemplate;/*** 批量新增**/@Overridepublic void batchAddUser(List<User> users) {if(CollectionUtils.isEmpty(users)) {return ;}List<IndexQuery> queries = Lists.newArrayListWithExpectedSize(users.size());IndexQuery indexItem  = null;for(User user :users) {indexItem = new IndexQuery();indexItem.setObject(user);queries.add(indexItem);}elasticsearchTemplate.bulkIndex(queries);}@Overridepublic void addUser(User user) {userRepository.save(user);}@Overridepublic void deletedUserById(String id) {userRepository.deleteById(id);}/*** 根据userId更新信息*/@Overridepublic 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);}@Overridepublic List<User> queryByUserName(String userName) {return userRepository.findByUserNameLike(userName);}@Overridepublic List<User> queryByRoleName(Role role) {return userRepository.findByRoles_Name(role.getName());}}

 

4.5：启动

主要要加上 @EnableElasticsearchRepositories 注解；

@EnableElasticsearchRepositories(basePackages = "com.test.els.demo.core.user.repository")
@SpringBootApplication
public 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详解的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！

---