本篇内容介绍了“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，所以这用代码配置了）
@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：编写实体类
声明各个字段类型及相应属性：
@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; @Field(searchAnalyzer="ik_smart",analyzer="ik_smart",type=FieldType.text) private String description; @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 { @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<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
@Servicepublic class UserStandardService implements StandardService{ @Autowired private UserRepository userRepository; @Autowired private ElasticsearchTemplate elasticsearchTemplate; @Override public 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); } @Override public void addUser(User user) { userRepository.save(user); } @Override public void deletedUserById(String id) { userRepository.deleteById(id); } @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<User> queryByUserName(String userName) { return userRepository.findByUserNameLike(userName); } @Override public List<User> 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的过程讲解”的内容就介绍到这里了，感谢大家的阅读。如果想了解更多行业相关的知识可以关注编程网网站，小编将为大家输出更多高质量的实用文章！
