具體的代碼網址githup：https://github.com/growup818/springboot-es-searchphp
實戰：java
ES數據配置類git
package org.githup.es.config;import java.net.InetAddress;import org.elasticsearch.client.transport.TransportClient;import org.elasticsearch.common.settings.Settings;import org.elasticsearch.common.transport.InetSocketTransportAddress;import org.elasticsearch.transport.client.PreBuiltTransportClient;import org.slf4j.Logger;import org.slf4j.LoggerFactory;import org.springframework.beans.factory.DisposableBean;import org.springframework.beans.factory.FactoryBean;import org.springframework.beans.factory.InitializingBean;import org.springframework.beans.factory.annotation.Value;import org.springframework.context.annotation.Configuration;/** * 數據配置，進行初始化操做 * * @author sdc * */@Configurationpublic class ESConfiguration implements FactoryBean<TransportClient>, InitializingBean, DisposableBean { private static final Logger logger = LoggerFactory.getLogger(ESConfiguration.class); /** * es集羣地址 */
@Value("${elasticsearch.ip}") private String hostName; /** * 端口 */
@Value("${elasticsearch.port}") private String port; /** * 集羣名稱 */
@Value("${elasticsearch.cluster.name}") private String clusterName; /** * 鏈接池 */
@Value("${elasticsearch.pool}") private String poolSize; private TransportClient client; @Override
public void destroy() throws Exception { try {
logger.info("Closing elasticSearch client"); if (client != null) {
client.close();
}
} catch (final Exception e) {
logger.error("Error closing ElasticSearch client: ", e);
}
} @Override
public TransportClient getObject() throws Exception { return client;
} @Override
public Class<TransportClient> getObjectType() { return TransportClient.class;
} @Override
public boolean isSingleton() { return false;
} @Override
public void afterPropertiesSet() throws Exception { try { // 配置信息
Settings esSetting = Settings.builder().put("cluster.name", clusterName).put("client.transport.sniff", true)// 增長嗅探機制，找到ES集羣
.put("thread_pool.search.size", Integer.parseInt(poolSize))// 增長線程池個數，暫時設爲5
.build();
client = new PreBuiltTransportClient(esSetting);
InetSocketTransportAddress inetSocketTransportAddress = new InetSocketTransportAddress(InetAddress.getByName(hostName), Integer.valueOf(port));
client.addTransportAddresses(inetSocketTransportAddress);
} catch (Exception e) {
logger.error("elasticsearch TransportClient create error!!!", e);
}
}
}
dao層，數據層，增刪改查進行簡單數據封裝github
package org.githup.es.dao;import java.util.Map;import java.util.UUID;import org.elasticsearch.action.admin.indices.create.CreateIndexResponse;import org.elasticsearch.action.admin.indices.delete.DeleteIndexResponse;import org.elasticsearch.action.admin.indices.exists.indices.IndicesExistsRequest;import org.elasticsearch.action.admin.indices.exists.indices.IndicesExistsResponse;import org.elasticsearch.action.delete.DeleteResponse;import org.elasticsearch.action.get.GetRequestBuilder;import org.elasticsearch.action.get.GetResponse;import org.elasticsearch.action.index.IndexResponse;import org.elasticsearch.action.update.UpdateRequest;import org.elasticsearch.action.update.UpdateResponse;import org.elasticsearch.client.transport.TransportClient;import org.slf4j.Logger;import org.slf4j.LoggerFactory;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.stereotype.Component;import com.alibaba.fastjson.JSONObject;/** * ES的操做數據類 * * 備註：對es的一些操做作了一些封裝，抽出來一些操做，就是傳統的dao層，數據服務 * * @author sdc * */@Componentpublic class ESRepository { private static final Logger log = LoggerFactory.getLogger(ESRepository.class); @Autowired
private TransportClient client; /** * 建立索引 * * @param index * @return */
public boolean buildIndex(String index) { if (!isIndexExist(index)) {
log.info("Index is not exits!");
}
CreateIndexResponse buildIndexresponse = client.admin().indices().prepareCreate(index).execute().actionGet();
log.info(" 建立索引的標誌: " + buildIndexresponse.isAcknowledged()); return buildIndexresponse.isAcknowledged();
} /** * 刪除索引 * * @param index * @return */
public boolean deleteIndex(String index) { if (!isIndexExist(index)) {
log.info(" 索引不存在 ！！！！！!");
}
DeleteIndexResponse diResponse = client.admin().indices().prepareDelete(index).execute().actionGet(); if (diResponse.isAcknowledged()) {
log.info("刪除索引**成功** index->>>>>>>" + index);
} else {
log.info("刪除索引**失敗** index->>>>> " + index);
} return diResponse.isAcknowledged();
} /** * 查詢數據 * @param index 索引<----->關係型數據庫 * @param type 類型<----->關係型數據表 * @param id 數據ID<----->id * @return */
public Map<String, Object> searchDataByParam(String index, String type, String id) { if(index == null || type == null || id == null) {
log.info(" 沒法查詢數據，缺惟一值!!!!!!! "); return null;
} //來獲取查詢數據信息
GetRequestBuilder getRequestBuilder = client.prepareGet(index, type, id);
GetResponse getResponse = getRequestBuilder.execute().actionGet();
//這裏也有指定的時間獲取返回值的信息，若有特殊需求能夠
return getResponse.getSource();
} /** * 更新數據 * * @param data 添加的數據類型 json格式的 * @param index 索引<----->關係型數據庫 * @param type 類型<----->關係型數據表 * @param id 數據ID<----->id * @return */
public void updateDataById(JSONObject data, String index, String type, String id) { if(index == null || type == null || id == null) {
log.info(" 沒法更新數據，缺惟一值!!!!!!! "); return;
} //更新步驟
UpdateRequest up = new UpdateRequest();
up.index(index).type(type).id(id).doc(data); //獲取響應信息
//.actionGet(timeoutMillis)，也能夠用這個方法，當過了必定的時間還沒獲得返回值的時候，就自動返回。
UpdateResponse response = client.update(up).actionGet();
log.info("更新數據狀態信息，status{}", response.status().getStatus());
} /** * 添加數據 * * @param data 添加的數據類型 json格式的 * @param index 索引<----->關係型數據庫 * @param type 類型<----->關係型數據表 * @param id 數據ID<----->id * @return */
public String addTargetDataALL(JSONObject data, String index, String type, String id) { //判斷一下次id是否爲空，爲空的話就設置一個id
if(id == null) {
id = UUID.randomUUID().toString();
} //正式添加數據進去
IndexResponse response = client.prepareIndex(index, type, id).setSource(data).get();
log.info("addTargetDataALL 添加數據的狀態:{}", response.status().getStatus()); return response.getId();
} /** * 經過ID刪除數據 * * @param index 索引，相似數據庫 * @param type 類型，相似表 * @param id 數據ID */
public void delDataById(String index, String type, String id) { if(index == null || type == null || id == null) {
log.info(" 沒法刪除數據，缺惟一值!!!!!!! "); return;
} //開始刪除數據
DeleteResponse response = client.prepareDelete(index, type, id).execute().actionGet();
log.info("刪除數據狀態，status-->>>>{},", response.status().getStatus());
} /** * 判斷索引是否存在 * * @param index * @return */
public boolean isIndexExist(String index) {
IndicesExistsResponse iep = client.admin().indices().exists(new IndicesExistsRequest(index)).actionGet(); if (iep.isExists()) {
log.info("此索引 [" + index + "] 已經在ES集羣裏存在");
} else {
log.info(" 沒有此索引 [" + index + "] ");
} return iep.isExists();
}
}
service層，進行接口數據封裝：web
package org.githup.es.service;import java.util.Map;import com.alibaba.fastjson.JSONObject;/** * ES服務端 * * @author sdc * */public interface ESSearchService { /** * 構建索引 * @param index * @return */
public boolean buildIndex(String index); /** * 刪除索引 * @param index * @return */
public boolean delIndex(String index); /** * 查詢數據 * @param index 索引<----->關係型數據庫 * @param type 類型<----->關係型數據表 * @param id 數據ID<----->id * @return */
public Map<String, Object> searchDataByParam(String index, String type, String id); /** * 更新數據 * * @param data 添加的數據類型 json格式的 * @param index 索引<----->關係型數據庫 * @param type 類型<----->關係型數據表 * @param id 數據ID<----->id * @return */
public void updateDataById(JSONObject data, String index, String type, String id); /** * 添加數據 * * @param data 添加的數據類型 json格式的 * @param index 索引<----->關係型數據庫 * @param type 類型<----->關係型數據表 * @param id 數據ID<----->id * @return */
public String addTargetDataALL(JSONObject data, String index, String type, String id); /** * 經過ID刪除數據 * * @param index 索引，相似數據庫 * @param type 類型，相似表 * @param id 數據ID */
public void delDataById(String index, String type, String id); /** * 判斷索引是否存在 * * @param index * @return */
public boolean isIndexExist(String index);
}package org.githup.es.service.impl;import java.util.Map;import org.githup.es.dao.ESRepository;import org.githup.es.service.ESSearchService;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.stereotype.Service;import com.alibaba.fastjson.JSONObject;/** * ES具體實現類 * * 備註：抽出ES的分類信息 * * @author sdc * */@Servicepublic class ESSearchServiceImpl implements ESSearchService{ @Autowired
private ESRepository eSRepository; @Override
public boolean buildIndex(String index) { return eSRepository.buildIndex(index);
} @Override
public boolean delIndex(String index) { return eSRepository.deleteIndex(index);
} @Override
public Map<String, Object> searchDataByParam(String index, String type, String id) { // TODO Auto-generated method stub
return eSRepository.searchDataByParam(index, type, id);
} @Override
public void updateDataById(JSONObject data, String index, String type, String id) { // TODO Auto-generated method stub
eSRepository.updateDataById(data, index, type, id);
} @Override
public String addTargetDataALL(JSONObject data, String index, String type, String id) { // TODO Auto-generated method stub
return eSRepository.addTargetDataALL(data, index, type, id);
} @Override
public void delDataById(String index, String type, String id) { // TODO Auto-generated method stub
eSRepository.delDataById(index, type, id);
} @Override
public boolean isIndexExist(String index) { // TODO Auto-generated method stub
return eSRepository.isIndexExist(index);
}
}
maven環境：spring
<?xml version="1.0" encoding="UTF-8"?><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>
<groupId>org.githup.es</groupId>
<artifactId>springboot-es-sample-search</artifactId>
<version>1.0-SNAPSHOT</version>
<packaging>jar</packaging>
<name>spring-boot-es</name>
<description>搜索服務的實現類</description>
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.0.0.RELEASE</version>
<relativePath /> <!-- lookup parent from repository -->
</parent>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
<java.version>1.8</java.version>
<elasticsearch.version>5.5.3</elasticsearch.version>
<log4j2.version>2.6.2</log4j2.version>
<fastjson.version>1.2.31</fastjson.version>
<commons.lang3.version>3.4</commons.lang3.version>
</properties>
<repositories>
<repository>
<id>spring-releases</id>
<url>https://repo.spring.io/libs-release</url>
</repository>
</repositories>
<!-- elasticsearch 5.x 依賴 -->
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
<!-- https://mvnrepository.com/artifact/org.springframework.boot/spring-boot-starter-web -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.elasticsearch</groupId>
<artifactId>elasticsearch</artifactId>
<version>${elasticsearch.version}</version>
</dependency>
<dependency>
<groupId>org.elasticsearch.client</groupId>
<artifactId>transport</artifactId>
<version>${elasticsearch.version}</version>
</dependency>
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>fastjson</artifactId>
<version>${fastjson.version}</version>
</dependency>
<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-lang3</artifactId>
<version>${commons.lang3.version}</version>
</dependency>
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>fastjson</artifactId>
<version>${fastjson.version}</version>
</dependency>
</dependencies>
<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-surefire-plugin</artifactId>
<configuration>
<skip>true</skip>
</configuration>
</plugin>
</plugins>
</build></project>
具體的代碼網址githup：https://github.com/growup818/springboot-es-search數據庫
能夠下載下來，熟悉springboot的小夥伴能夠很快進行demo檢測。apache
本文分享自微信公衆號 - soft張三丰（aguzhangsanfeng）。
若有侵權，請聯繫 support@oschina.cn 刪除。
本文參與「OSC源創計劃」，歡迎正在閱讀的你也加入，一塊兒分享。json