elasticsearch spring 集成

elasticsearch spring 集成

项目清单

elasticsearch服务下载包括其中插件和分词

http://download.csdn.net/detail/u014201191/8809619

项目源码

资源文件

app.properties

[html] view plain copy

print ?

elasticsearch.esNodes=localhost:9300
elasticsearch.cluster.name=heroscluster

app.xml

[html] view plain copy

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:util="http://www.springframework.org/schema/util"
xmlns:context="http://www.springframework.org/schema/context"
xmlns:elasticsearch="http://www.pilato.fr/schema/elasticsearch"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util-3.0.xsd
http://www.pilato.fr/schema/elasticsearch http://www.pilato.fr/schema/elasticsearch/elasticsearch-0.3.xsd
http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.1.xsd">
<context:annotation-config />
<context:property-placeholder location="classpath:/app.properties" />
<import resource="elasticseach.xml" />
</beans>

elasticseach.xml

[html] view plain copy

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:util="http://www.springframework.org/schema/util"
xmlns:context="http://www.springframework.org/schema/context"
xmlns:elasticsearch="http://www.pilato.fr/schema/elasticsearch"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util-3.0.xsd
http://www.pilato.fr/schema/elasticsearch http://www.pilato.fr/schema/elasticsearch/elasticsearch-0.3.xsd
http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.1.xsd">
<util:map id="esproperties">
<entry key="cluster.name" value="${elasticsearch.cluster.name}" />
</util:map>
<elasticsearch:client id="client" properties="esproperties"
esNodes="${elasticsearch.esNodes}" />
<bean name="elasticsearchTemplate"
class="org.springframework.data.elasticsearch.core.ElasticsearchTemplate">
<constructor-arg name="client" ref="client" />
</bean>
<bean name="elasticsearchService" class="com.sf.heros.mq.consumer.service.ElasticsearchService"
init-method="init" />
<bean name="es" class="com.sf.daidongxi.web.service.ElasticsearchService"></bean>
</beans>

log4j.properties

[html] view plain copy

### \u8bbe\u7f6eLogger\u8f93\u51fa\u7ea7\u522b\u548c\u8f93\u51fa\u76ee\u7684\u5730 ###
log4j.rootLogger=info,logfile
log4j.appender.console=org.apache.log4j.ConsoleAppender
log4j.appender.console.Threshold=info
log4j.appender.console.layout=org.apache.log4j.PatternLayout
log4j.appender.console.layout.ConversionPattern=[%-5p] %d{yyyy-MM-dd HH:mm:ss,SSS} - %m%n
log4j.appender.logfile=org.apache.log4j.DailyRollingFileAppender
log4j.appender.logfile.File=/app/logs/mq_consumer.log
log4j.appender.logfile.datePattern='.'yyyy-MM-dd'.'
log4j.appender.logfile.append=true
log4j.appender.logfile.Threshold=debug
log4j.appender.logfile.layout=org.apache.log4j.PatternLayout
log4j.appender.logfile.layout.ConversionPattern=[%-5p] %d{yyyy-MM-dd HH:mm:ss,SSS} - %m%n

maven管理

[html] view plain copy

<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/maven-v4_0_0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId>com.elasticsearch</groupId>
<artifactId>elasticsearch</artifactId>
<packaging>war</packaging>
<version>0.0.1-SNAPSHOT</version>
<name>elasticsearch Maven Webapp</name>
<url>http://maven.apache.org</url>
<properties>
<spring.version>3.1.1.RELEASE</spring.version>
<findbugs.annotations>2.0.0</findbugs.annotations>
<checkstyle.maven.plugin>2.11</checkstyle.maven.plugin>
<pmd.maven.plugin>3.0</pmd.maven.plugin>
<findbugs.maven.plugin>2.5.3</findbugs.maven.plugin>
<java.version>1.7</java.version>
</properties>
<dependencies>
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>3.8.1</version>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-context</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-context-support</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-aop</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-core</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-jdbc</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>fr.pilato.spring</groupId>
<artifactId>spring-elasticsearch</artifactId>
<version>1.0.0</version>
</dependency>
<dependency>
<groupId>org.elasticsearch</groupId>
<artifactId>elasticsearch</artifactId>
<version>1.0.0</version>
</dependency>
<dependency>
<groupId>org.springframework.data</groupId>
<artifactId>spring-data-elasticsearch</artifactId>
<version>1.0.0.RELEASE</version>
</dependency>
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>druid</artifactId>
<version>1.0.5</version>
</dependency>
<dependency>
<groupId>net.sf.json-lib</groupId>
<artifactId>json-lib</artifactId>
<version>2.4</version>
<classifier>jdk15</classifier>
</dependency>
<dependency>
<groupId>org.quartz-scheduler</groupId>
<artifactId>quartz</artifactId>
<version>2.2.1</version>
</dependency>
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-log4j12</artifactId>
<version>1.7.5</version>
</dependency>
</dependencies>
<build>
<finalName>elasticsearch</finalName>
</build>
</project>

Java.class

Bean配置

[html] view plain copy

package com.sf.heros.mq.consumer.vo;
import org.springframework.data.annotation.Id;
import org.springframework.data.elasticsearch.annotations.Document;
import org.springframework.data.elasticsearch.annotations.Field;
import org.springframework.data.elasticsearch.annotations.FieldIndex;
import org.springframework.data.elasticsearch.annotations.FieldType;
import com.sf.heros.mq.consumer.utils.APP;
//@Document(indexName = APP.ESProp.INDEX_NAME, type = APP.ESProp.TYPE_TASK_INFO, indexStoreType = APP.ESProp.INDEX_STORE_TYPE, shards = APP.ESProp.SHARDS, replicas = APP.ESProp.REPLICAS, refreshInterval = APP.ESProp.REFRESH_INTERVAL)
@Document(indexName = APP.ESProp.INDEX_NAME, type = APP.ESProp.TYPE_TASK_INFO)
public class TaskInfo {
@Id
@Field(index = FieldIndex.not_analyzed, store = true)
private String taskId;
@Field(type = FieldType.Integer, index = FieldIndex.not_analyzed, store = true)
private Integer userId;
@Field(type = FieldType.String, indexAnalyzer="ik", searchAnalyzer="ik", store = true)
private String taskContent;
@Field(type = FieldType.String, indexAnalyzer="ik", searchAnalyzer="ik", store = true)
private String taskArea;
@Field(type = FieldType.String, indexAnalyzer="ik", searchAnalyzer="ik", store = true)
private String taskTags;
@Field(type = FieldType.Integer, index = FieldIndex.not_analyzed, store = true)
private Integer taskState;
@Field(type = FieldType.String, index = FieldIndex.not_analyzed, store = true)
private String updateTime;
@Field(type = FieldType.String, indexAnalyzer="ik", searchAnalyzer="ik", store = true)
private String userNickName;
public String getTaskId() {
return taskId;
}
public void setTaskId(String taskId) {
this.taskId = taskId;
}
public Integer getUserId() {
return userId;
}
public void setUserId(Integer userId) {
this.userId = userId;
}
public String getTaskContent() {
return taskContent;
}
public void setTaskContent(String taskContent) {
this.taskContent = taskContent;
}
public String getTaskArea() {
return taskArea;
}
public void setTaskArea(String taskArea) {
this.taskArea = taskArea;
}
public String getTaskTags() {
return taskTags;
}
public void setTaskTags(String taskTags) {
this.taskTags = taskTags;
}
public Integer getTaskState() {
return taskState;
}
public void setTaskState(Integer taskState) {
this.taskState = taskState;
}
public String getUpdateTime() {
return updateTime;
}
public void setUpdateTime(String updateTime) {
this.updateTime = updateTime;
}
public String getUserNickName() {
return userNickName;
}
public void setUserNickName(String userNickName) {
this.userNickName = userNickName;
}
@Override
public String toString() {
return "TaskInfo [taskId=" + taskId + ", userId=" + userId
+ ", taskContent=" + taskContent + ", taskArea=" + taskArea
+ ", taskState=" + taskState
+ ", updateTime=" + updateTime + ", userNickName="
+ userNickName + "]";
}
public TaskInfo(String taskId, Integer userId, String taskContent,
String taskArea, String taskTags, Integer taskState,
String updateTime, String userNickName) {
this.taskId = taskId;
this.userId = userId;
this.taskContent = taskContent;
this.taskArea = taskArea;
this.taskTags = taskTags;
this.taskState = taskState;
this.updateTime = updateTime;
this.userNickName = userNickName;
}
public TaskInfo() {
// TODO Auto-generated constructor stub
}
}

其余的类在源码中下载,此处不列出了...

常量管理

[html] view plain copy

package com.sf.heros.mq.consumer.utils;
import java.util.HashMap;
import java.util.Map;
public interface APP {
public static final Map<String, String> map = new HashMap<String, String>();
public static final String CLOSED_MSG = "#################closed####################";
public static final long DELIVERIED_TAG = -1;
class ESProp {
public static final String INDEX_NAME = "heros";
public static final String DAIDONGXI_INDEX_NAME = "daidongxi";
public static final String TYPE_NEWS_INFO = "news_info";
public static final String TYPE_PRODUCT_INFO = "product_info";
public static final String TYPE_STORY_INFO = "story_info";
public static final String TYPE_TASK_INFO = "task_info";
public static final String TYPE_USER_INFO = "user_info";
public static final String TYPE_BRANDCASE_INFO = "brandcase_info";
public static final String INDEX_STORE_TYPE = "memory";
public static final int SHARDS = 2;
public static final int REPLICAS = 1;
public static final String REFRESH_INTERVAL = "-1";
}
}

增删改类

[html] view plain copy

/**
*@Pr锛歨eros
*@Date: 2014-5-4 涓婂崍9:21:27
*@Author: seaphy
*@Copyright: 漏 2012 sf-express.com Inc. All rights reserved
*娉ㄦ剰锛氭湰鍐呭浠呴檺浜庨『涓伴�熻繍鍏徃鍐呴儴浼犻槄锛岀姝㈠娉勪互鍙婄敤浜庡叾浠栫殑鍟嗕笟鐩殑
*/
package com.sf.heros.mq.consumer.service;
import java.util.ArrayList;
import java.util.List;
import org.apache.log4j.Logger;
import org.elasticsearch.action.ActionFuture;
import org.elasticsearch.action.admin.cluster.health.ClusterHealthRequest;
import org.elasticsearch.action.admin.cluster.health.ClusterHealthResponse;
import org.elasticsearch.action.admin.cluster.health.ClusterHealthStatus;
import org.elasticsearch.client.Client;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.elasticsearch.core.ElasticsearchTemplate;
import org.springframework.data.elasticsearch.core.query.IndexQuery;
import org.springframework.data.elasticsearch.core.query.IndexQueryBuilder;
import com.sf.heros.mq.consumer.utils.APP;
import com.sf.heros.mq.consumer.vo.BrandCaseInfo;
import com.sf.heros.mq.consumer.vo.NewsInfo;
import com.sf.heros.mq.consumer.vo.TaskInfo;
import com.sf.heros.mq.consumer.vo.UserInfo;
/**
* @author seaphy
* @date 2014-5-4
*/
public class ElasticsearchService {
private static final Logger logger = Logger.getLogger(ElasticsearchService.class);
@Autowired
private ElasticsearchTemplate elasticsearchTemplate;
@Autowired
private Client esClient;
public void init() {
if (!elasticsearchTemplate.indexExists(APP.ESProp.INDEX_NAME)) {
elasticsearchTemplate.createIndex(APP.ESProp.INDEX_NAME);
}
elasticsearchTemplate.putMapping(TaskInfo.class);
elasticsearchTemplate.putMapping(NewsInfo.class);
}
public boolean update(List<TaskInfo> taskInfoList) {
List<IndexQuery> queries = new ArrayList<IndexQuery>();
for (TaskInfo taskInfo : taskInfoList) {
IndexQuery indexQuery = new IndexQueryBuilder().withId(taskInfo.getTaskId()).withObject(taskInfo).build();
queries.add(indexQuery);
}
elasticsearchTemplate.bulkIndex(queries);
return true;
}
public boolean insertOrUpdateTaskInfo(List<TaskInfo> taskInfoList) {
List<IndexQuery> queries = new ArrayList<IndexQuery>();
for (TaskInfo taskInfo : taskInfoList) {
IndexQuery indexQuery = new IndexQueryBuilder().withId(taskInfo.getTaskId()).withObject(taskInfo).build();
queries.add(indexQuery);
}
elasticsearchTemplate.bulkIndex(queries);
return true;
}
public boolean insertOrUpdateNewsInfo(List<NewsInfo> newsInfos) {
List<IndexQuery> queries = new ArrayList<IndexQuery>();
for (NewsInfo newsInfo : newsInfos) {
IndexQuery indexQuery = new IndexQueryBuilder().withId(newsInfo.getNewsId()).withObject(newsInfo).build();
queries.add(indexQuery);
}
elasticsearchTemplate.bulkIndex(queries);
return true;
}
public boolean insertOrUpdateNewsInfo(NewsInfo newsInfo) {
try {
IndexQuery indexQuery = new IndexQueryBuilder().withId(newsInfo.getNewsId()).withObject(newsInfo).build();
elasticsearchTemplate.index(indexQuery);
return true;
} catch (Exception e) {
logger.error("insert or update news info error.", e);
return false;
}
}
public boolean insertOrUpdateTaskInfo(TaskInfo taskInfo) {
try {
IndexQuery indexQuery = new IndexQueryBuilder().withId(taskInfo.getTaskId()).withObject(taskInfo).build();
elasticsearchTemplate.index(indexQuery);
return true;
} catch (Exception e) {
logger.error("insert or update task info error.", e);
return false;
}
}
public boolean insertOrUpdateUserInfo(UserInfo userInfo) {
try {
IndexQuery indexQuery = new IndexQueryBuilder().withId(userInfo.getUserId()).withObject(userInfo).build();
elasticsearchTemplate.index(indexQuery);
return true;
} catch (Exception e) {
logger.error("insert or update user info error.", e);
return false;
}
}
public <T> boolean deleteById(String id, Class<T> clzz) {
try {
elasticsearchTemplate.delete(clzz, id);
return true;
} catch (Exception e) {
logger.error("delete " + clzz + " by id " + id + " error.", e);
return false;
}
}
/**
* 检查健康状态
* @author 高国藩
* @date 2015年6月15日下午6:59:47
* @return
*/
public boolean ping() {
try {
ActionFuture<ClusterHealthResponse> health = esClient.admin().cluster().health(new ClusterHealthRequest());
ClusterHealthStatus status = health.actionGet().getStatus();
if (status.value() == ClusterHealthStatus.RED.value()) {
throw new RuntimeException("elasticsearch cluster health status is red.");
}
return true;
} catch (Exception e) {
logger.error("ping elasticsearch error.", e);
return false;
}
}
public boolean insertOrUpdateBrandCaseInfo(BrandCaseInfo brandCaseInfo) {
try {
IndexQuery indexQuery = new IndexQueryBuilder()
.withId(brandCaseInfo.getId()).withObject(brandCaseInfo).build();
elasticsearchTemplate.index(indexQuery);
return true;
} catch (Exception e) {
logger.error("insert or update brandcase info error.", e);
return false;
}
}
}

查询类

[html] view plain copy

package com.sf.daidongxi.web.service;
import java.util.ArrayList;
import java.util.Collection;
import java.util.List;
import java.util.Map;
import org.apache.commons.lang.StringUtils;
import org.apache.log4j.Logger;
import org.apache.lucene.queries.TermFilter;
import org.apache.lucene.queryparser.xml.builders.FilteredQueryBuilder;
import org.elasticsearch.action.search.SearchRequestBuilder;
import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.action.search.SearchType;
import org.elasticsearch.client.Client;
import org.elasticsearch.index.query.BoolFilterBuilder;
import org.elasticsearch.index.query.FilterBuilder;
import org.elasticsearch.index.query.FilterBuilders;
import org.elasticsearch.index.query.MatchQueryBuilder;
import org.elasticsearch.index.query.QueryBuilder;
import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.index.query.QueryStringQueryBuilder;
import org.elasticsearch.index.query.RangeFilterBuilder;
import org.elasticsearch.index.query.TermsQueryBuilder;
import org.elasticsearch.search.SearchHit;
import org.elasticsearch.search.sort.SortOrder;
import org.springframework.beans.factory.InitializingBean;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.elasticsearch.core.ElasticsearchTemplate;
import sun.misc.Contended;
public class ElasticsearchService implements InitializingBean {
private static final Logger logger = Logger
.getLogger(ElasticsearchService.class);
@Autowired
private Client client;
private String esIndexName = "heros";
@Autowired
private ElasticsearchTemplate elasticsearchTemplate;
@Autowired
private Client esClient;
/** 查询 id */
public List<String> queryId(String type, String[] fields, String content,
String sortField, SortOrder order, int from, int size) {
SearchRequestBuilder reqBuilder = client.prepareSearch(esIndexName)
.setTypes(type).setSearchType(SearchType.DEFAULT)
.setExplain(true);
QueryStringQueryBuilder queryString = QueryBuilders.queryString("\""
+ content + "\"");
for (String k : fields) {
queryString.field(k);
}
queryString.minimumShouldMatch("10");
reqBuilder.setQuery(QueryBuilders.boolQuery().should(queryString))
.setExplain(true);
if (StringUtils.isNotEmpty(sortField) && order != null) {
reqBuilder.addSort(sortField, order);
}
if (from >= 0 && size > 0) {
reqBuilder.setFrom(from).setSize(size);
}
SearchResponse resp = reqBuilder.execute().actionGet();
SearchHit[] hits = resp.getHits().getHits();
ArrayList<String> results = new ArrayList<String>();
for (SearchHit hit : hits) {
results.add(hit.getId());
}
return results;
}
/**
* 查询得到结果为Map集合
*
* @author 高国藩
* @date 2015年6月15日下午8:46:13
* @param type
* 表
* @param fields
* 字段索引
* @param content
* 查询的值
* @param sortField
* 排序的字段
* @param order
* 排序的規則
* @param from
* 分頁
* @param size
* @return
*/
public List<Map<String, Object>> queryForObject(String type,
String[] fields, String content, String sortField, SortOrder order,
int from, int size) {
SearchRequestBuilder reqBuilder = client.prepareSearch(esIndexName)
.setTypes(type).setSearchType(SearchType.DEFAULT)
.setExplain(true);
QueryStringQueryBuilder queryString = QueryBuilders.queryString("\""
+ content + "\"");
for (String k : fields) {
queryString.field(k);
}
queryString.minimumShouldMatch("10");
reqBuilder.setQuery(QueryBuilders.boolQuery().should(queryString))
.setExplain(true);
if (StringUtils.isNotEmpty(sortField) && order != null) {
reqBuilder.addSort(sortField, order);
}
if (from >= 0 && size > 0) {
reqBuilder.setFrom(from).setSize(size);
}
SearchResponse resp = reqBuilder.execute().actionGet();
SearchHit[] hits = resp.getHits().getHits();
List<Map<String, Object>> results = new ArrayList<Map<String, Object>>();
for (SearchHit hit : hits) {
results.add(hit.getSource());
}
return results;
}
/**
* QueryBuilders 所有查询入口
*/
public List<Map<String, Object>> queryForObjectEq(String type,
String[] fields, String content, String sortField, SortOrder order,
int from, int size) {
SearchRequestBuilder reqBuilder = client.prepareSearch(esIndexName)
.setTypes(type).setSearchType(SearchType.DEFAULT)
.setExplain(true);
QueryStringQueryBuilder queryString = QueryBuilders.queryString("\""
+ content + "\"");
for (String k : fields) {
queryString.field(k);
}
queryString.minimumShouldMatch("10");
reqBuilder.setQuery(QueryBuilders.boolQuery().must(queryString))
.setExplain(true);
if (StringUtils.isNotEmpty(sortField) && order != null) {
reqBuilder.addSort(sortField, order);
}
if (from >= 0 && size > 0) {
reqBuilder.setFrom(from).setSize(size);
}
SearchResponse resp = reqBuilder.execute().actionGet();
SearchHit[] hits = resp.getHits().getHits();
List<Map<String, Object>> results = new ArrayList<Map<String, Object>>();
for (SearchHit hit : hits) {
results.add(hit.getSource());
}
return results;
}
/**
* 多个文字记不清是那些字,然后放进去查询
*
* @author 高国藩
* @date 2015年6月16日上午9:56:08
* @param type
* @param field
* @param countents
* @param sortField
* @param order
* @param from
* @param size
* @return
*/
public List<Map<String, Object>> queryForObjectNotEq(String type,
String field, Collection<String> countents, String sortField,
SortOrder order, int from, int size) {
SearchRequestBuilder reqBuilder = client.prepareSearch(esIndexName)
.setTypes(type).setSearchType(SearchType.DEFAULT)
.setExplain(true);
List<String> contents = new ArrayList<String>();
for (String content : countents) {
contents.add("\"" + content + "\"");
}
TermsQueryBuilder inQuery = QueryBuilders.inQuery(field, contents);
inQuery.minimumShouldMatch("10");
reqBuilder.setQuery(QueryBuilders.boolQuery().mustNot(inQuery))
.setExplain(true);
if (StringUtils.isNotEmpty(sortField) && order != null) {
reqBuilder.addSort(sortField, order);
}
if (from >= 0 && size > 0) {
reqBuilder.setFrom(from).setSize(size);
}
SearchResponse resp = reqBuilder.execute().actionGet();
SearchHit[] hits = resp.getHits().getHits();
List<Map<String, Object>> results = new ArrayList<Map<String, Object>>();
for (SearchHit hit : hits) {
results.add(hit.getSource());
}
return results;
}
/**
* Filters 查询方式
*
* 1. 1)QueryBuilders.queryString 获得基本查询
* 2)FilteredQueryBuilder query = QueryBuilders.filteredQuery(queryString,FilterBuilder)
* 3)通过上面封装成为查询,将这个query插入到reqBuilder中;完成操作
*
* 2.在 reqBuilder.setQuery(query);
*
* 3.介绍在2)中的FilterBuilder各种构造方式-参数都可以传String类型即可
* FilterBuilders.rangeFilter("taskState").lt(20) 小于、 lte(20) 小于等于
* FilterBuilders.rangeFilter("taskState").gt(20)) 大于、 gte(20) 大于等于
* FilterBuilders.rangeFilter("taskState").from(start).to(end)) 范围,也可以指定日期,用字符串就ok了
* @author 高国藩
* @date 2015年6月15日下午10:06:05
* @param type
* @param field
* @param countents
* @param sortField
* @param order
* @param from
* @param size
* @return
*/
public List<Map<String, Object>> queryForObjectForElasticSerch(String type,
String field, String content,int start,int end) {
SearchRequestBuilder reqBuilder = client.prepareSearch(esIndexName)
.setTypes(type).setSearchType(SearchType.DEFAULT)
.setExplain(true);
QueryStringQueryBuilder queryString = QueryBuilders.queryString("\""
+ content + "\"");
queryString.field(field);
queryString.minimumShouldMatch("10");
reqBuilder.setQuery(QueryBuilders.filteredQuery(queryString, FilterBuilders.rangeFilter("taskState").from(start).to(end)))
.setExplain(true);
SearchResponse resp = reqBuilder.execute().actionGet();
SearchHit[] hits = resp.getHits().getHits();
List<Map<String, Object>> results = new ArrayList<Map<String, Object>>();
for (SearchHit hit : hits) {
results.add(hit.getSource());
}
return results;
}
public void afterPropertiesSet() throws Exception {
System.out.println("init...");
}
}

测试

[html] view plain copy

package com.sf.heros.mq.consumer;
import java.util.ArrayList;
import java.util.Collection;
import java.util.HashSet;
import java.util.List;
import java.util.Map;
import org.apache.log4j.Logger;
import org.elasticsearch.search.sort.SortOrder;
import org.junit.Test;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import com.sf.heros.mq.consumer.service.ElasticsearchService;
import com.sf.heros.mq.consumer.utils.APP;
import com.sf.heros.mq.consumer.vo.TaskInfo;
public class AppMain {
private static final Logger logger = Logger.getLogger(AppMain.class);
public void start() {
ClassPathXmlApplicationContext context = null;
try {
context = new ClassPathXmlApplicationContext("classpath:app.xml");
} catch (Exception e) {
logger.error("An error occurred, applicationContext will close.", e);
if (context != null) {
context.close();
}
context = null;
logger.error(APP.CLOSED_MSG);
}
}
/**
* 插入
* @author 高国藩
* @date 2015年6月16日上午10:14:21
*/
@Test
public void insertNo() {
ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(
"classpath:app.xml");
ElasticsearchService service = context
.getBean(ElasticsearchService.class);
List<TaskInfo> taskInfoList = new ArrayList<TaskInfo>();
for (int i = 0; i < 20; i++) {
taskInfoList.add(new TaskInfo(String.valueOf((i + 5)), i + 5, "高国藩"
+ i, "taskArea", "taskTags", i + 5, "1996-02-03", "霍华德"));
}
service.insertOrUpdateTaskInfo(taskInfoList);
}
/**
* 查询
* @author 高国藩
* @date 2015年6月16日上午10:14:21
*/
@Test
public void serchNo() {
ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(
"classpath:app.xml");
com.sf.daidongxi.web.service.ElasticsearchService service = (com.sf.daidongxi.web.service.ElasticsearchService) context
.getBean("es");
List<Map<String, Object>> al = service.queryForObject("task_info",
new String[] { "taskContent", "taskArea" }, "高国藩", "taskArea", SortOrder.DESC,
0, 2);
for (int i = 0; i < al.size(); i++) {
System.out.println(al.get(i));
}
}
/**
* filter查询
* @author 高国藩
* @date 2015年6月16日上午10:14:21
*/
@Test
public void serchFilter() {
ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(
"classpath:app.xml");
com.sf.daidongxi.web.service.ElasticsearchService service = (com.sf.daidongxi.web.service.ElasticsearchService) context
.getBean("es");
List<Map<String, Object>> al = service.queryForObjectForElasticSerch("task_info", "taskContent", "高",19,20);
for (int i = 0; i < al.size(); i++) {
System.out.println(al.get(i));
}
}
}

源码项目下载

http://download.csdn.net/detail/u014201191/8812073

http://blog.csdn.net/u014201191/article/details/46508311

项目清单

elasticsearch服务下载包括其中插件和分词

http://download.csdn.net/detail/u014201191/8809619

项目源码

资源文件

app.properties

[java] view plain copy

print ?

elasticsearch.esNodes=localhost:9300
elasticsearch.cluster.name=heroscluster

app.xml

[java] view plain copy

print ?

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:util="http://www.springframework.org/schema/util"
xmlns:context="http://www.springframework.org/schema/context"
xmlns:elasticsearch="http://www.pilato.fr/schema/elasticsearch"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util-3.0.xsd
http://www.pilato.fr/schema/elasticsearch http://www.pilato.fr/schema/elasticsearch/elasticsearch-0.3.xsd
http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.1.xsd">
<context:annotation-config />
<context:property-placeholder location="classpath:/app.properties" />
<import resource="elasticseach.xml" />
</beans>

elasticseach.xml

[java] view plain copy

print ?

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:util="http://www.springframework.org/schema/util"
xmlns:context="http://www.springframework.org/schema/context"
xmlns:elasticsearch="http://www.pilato.fr/schema/elasticsearch"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util-3.0.xsd
http://www.pilato.fr/schema/elasticsearch http://www.pilato.fr/schema/elasticsearch/elasticsearch-0.3.xsd
http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.1.xsd">
<util:map id="esproperties">
<entry key="cluster.name" value="${elasticsearch.cluster.name}" />
</util:map>
<elasticsearch:client id="client" properties="esproperties"
esNodes="${elasticsearch.esNodes}" />
<bean name="elasticsearchTemplate"
class="org.springframework.data.elasticsearch.core.ElasticsearchTemplate">
<constructor-arg name="client" ref="client" />
</bean>
<bean name="elasticsearchService" class="com.sf.heros.mq.consumer.service.ElasticsearchService"
init-method="init" />
<bean name="es" class="com.sf.daidongxi.web.service.ElasticsearchService"></bean>
</beans>

maven

[java] view plain copy

<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/maven-v4_0_0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId>com.elasticsearch</groupId>
<artifactId>elasticsearch</artifactId>
<packaging>war</packaging>
<version>0.0.1-SNAPSHOT</version>
<name>elasticsearch Maven Webapp</name>
<url>http://maven.apache.org</url>
<properties>
<spring.version>3.1.1.RELEASE</spring.version>
<findbugs.annotations>2.0.0</findbugs.annotations>
<checkstyle.maven.plugin>2.11</checkstyle.maven.plugin>
<pmd.maven.plugin>3.0</pmd.maven.plugin>
<findbugs.maven.plugin>2.5.3</findbugs.maven.plugin>
<java.version>1.7</java.version>
</properties>
<dependencies>
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>3.8.1</version>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-context</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-context-support</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-aop</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-core</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-jdbc</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>fr.pilato.spring</groupId>
<artifactId>spring-elasticsearch</artifactId>
<version>1.0.0</version>
</dependency>
<dependency>
<groupId>org.elasticsearch</groupId>
<artifactId>elasticsearch</artifactId>
<version>1.0.0</version>
</dependency>
<dependency>
<groupId>org.springframework.data</groupId>
<artifactId>spring-data-elasticsearch</artifactId>
<version>1.0.0.RELEASE</version>
</dependency>
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>druid</artifactId>
<version>1.0.5</version>
</dependency>
<dependency>
<groupId>net.sf.json-lib</groupId>
<artifactId>json-lib</artifactId>
<version>2.4</version>
<classifier>jdk15</classifier>
</dependency>
<dependency>
<groupId>org.quartz-scheduler</groupId>
<artifactId>quartz</artifactId>
<version>2.2.1</version>
</dependency>
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-log4j12</artifactId>
<version>1.7.5</version>
</dependency>
</dependencies>
<build>
<finalName>elasticsearch</finalName>
</build>
</project>

Java.class

Bean配置

[java] view plain copy

package com.sf.heros.mq.consumer.vo;
import org.springframework.data.annotation.Id;
import org.springframework.data.elasticsearch.annotations.Document;
import org.springframework.data.elasticsearch.annotations.Field;
import org.springframework.data.elasticsearch.annotations.FieldIndex;
import org.springframework.data.elasticsearch.annotations.FieldType;
import com.sf.heros.mq.consumer.utils.APP;
//@Document(indexName = APP.ESProp.INDEX_NAME, type = APP.ESProp.TYPE_TASK_INFO, indexStoreType = APP.ESProp.INDEX_STORE_TYPE, shards = APP.ESProp.SHARDS, replicas = APP.ESProp.REPLICAS, refreshInterval = APP.ESProp.REFRESH_INTERVAL)
@Document(indexName = APP.ESProp.INDEX_NAME, type = APP.ESProp.TYPE_TASK_INFO)
public class TaskInfo {
@Id
@Field(index = FieldIndex.not_analyzed, store = true)
private String taskId;
@Field(type = FieldType.Integer, index = FieldIndex.not_analyzed, store = true)
private Integer userId;
@Field(type = FieldType.String, indexAnalyzer="ik", searchAnalyzer="ik", store = true)
private String taskContent;
@Field(type = FieldType.String, indexAnalyzer="ik", searchAnalyzer="ik", store = true)
private String taskArea;
@Field(type = FieldType.String, indexAnalyzer="ik", searchAnalyzer="ik", store = true)
private String taskTags;
@Field(type = FieldType.Integer, index = FieldIndex.not_analyzed, store = true)
private Integer taskState;
@Field(type = FieldType.String, index = FieldIndex.not_analyzed, store = true)
private String updateTime;
@Field(type = FieldType.String, indexAnalyzer="ik", searchAnalyzer="ik", store = true)
private String userNickName;
public String getTaskId() {
return taskId;
}
public void setTaskId(String taskId) {
this.taskId = taskId;
}
public Integer getUserId() {
return userId;
}
public void setUserId(Integer userId) {
this.userId = userId;
}
public String getTaskContent() {
return taskContent;
}
public void setTaskContent(String taskContent) {
this.taskContent = taskContent;
}
public String getTaskArea() {
return taskArea;
}
public void setTaskArea(String taskArea) {
this.taskArea = taskArea;
}
public String getTaskTags() {
return taskTags;
}
public void setTaskTags(String taskTags) {
this.taskTags = taskTags;
}
public Integer getTaskState() {
return taskState;
}
public void setTaskState(Integer taskState) {
this.taskState = taskState;
}
public String getUpdateTime() {
return updateTime;
}
public void setUpdateTime(String updateTime) {
this.updateTime = updateTime;
}
public String getUserNickName() {
return userNickName;
}
public void setUserNickName(String userNickName) {
this.userNickName = userNickName;
}
@Override
public String toString() {
return "TaskInfo [taskId=" + taskId + ", userId=" + userId
+ ", taskContent=" + taskContent + ", taskArea=" + taskArea
+ ", taskState=" + taskState
+ ", updateTime=" + updateTime + ", userNickName="
+ userNickName + "]";
}
public TaskInfo(String taskId, Integer userId, String taskContent,
String taskArea, String taskTags, Integer taskState,
String updateTime, String userNickName) {
this.taskId = taskId;
this.userId = userId;
this.taskContent = taskContent;
this.taskArea = taskArea;
this.taskTags = taskTags;
this.taskState = taskState;
this.updateTime = updateTime;
this.userNickName = userNickName;
}
public TaskInfo() {
// TODO Auto-generated constructor stub
}
}

增删改类

[java] view plain copy

/**
*@Pr锛歨eros
*@Date: 2014-5-4 涓婂崍9:21:27
*@Author: seaphy
*@Copyright: 漏 2012 sf-express.com Inc. All rights reserved
*娉ㄦ剰锛氭湰鍐呭浠呴檺浜庨『涓伴�熻繍鍏徃鍐呴儴浼犻槄锛岀姝㈠娉勪互鍙婄敤浜庡叾浠栫殑鍟嗕笟鐩殑
*/
package com.sf.heros.mq.consumer.service;
import java.util.ArrayList;
import java.util.List;
import org.apache.log4j.Logger;
import org.elasticsearch.action.ActionFuture;
import org.elasticsearch.action.admin.cluster.health.ClusterHealthRequest;
import org.elasticsearch.action.admin.cluster.health.ClusterHealthResponse;
import org.elasticsearch.action.admin.cluster.health.ClusterHealthStatus;
import org.elasticsearch.client.Client;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.elasticsearch.core.ElasticsearchTemplate;
import org.springframework.data.elasticsearch.core.query.IndexQuery;
import org.springframework.data.elasticsearch.core.query.IndexQueryBuilder;
import com.sf.heros.mq.consumer.utils.APP;
import com.sf.heros.mq.consumer.vo.BrandCaseInfo;
import com.sf.heros.mq.consumer.vo.NewsInfo;
import com.sf.heros.mq.consumer.vo.TaskInfo;
import com.sf.heros.mq.consumer.vo.UserInfo;
/**
* @author seaphy
* @date 2014-5-4
*/
public class ElasticsearchService {
private static final Logger logger = Logger.getLogger(ElasticsearchService.class);
@Autowired
private ElasticsearchTemplate elasticsearchTemplate;
@Autowired
private Client esClient;
public void init() {
if (!elasticsearchTemplate.indexExists(APP.ESProp.INDEX_NAME)) {
elasticsearchTemplate.createIndex(APP.ESProp.INDEX_NAME);
}
elasticsearchTemplate.putMapping(TaskInfo.class);
elasticsearchTemplate.putMapping(NewsInfo.class);
}
public boolean update(List<TaskInfo> taskInfoList) {
List<IndexQuery> queries = new ArrayList<IndexQuery>();
for (TaskInfo taskInfo : taskInfoList) {
IndexQuery indexQuery = new IndexQueryBuilder().withId(taskInfo.getTaskId()).withObject(taskInfo).build();
queries.add(indexQuery);
}
elasticsearchTemplate.bulkIndex(queries);
return true;
}
public boolean insertOrUpdateTaskInfo(List<TaskInfo> taskInfoList) {
List<IndexQuery> queries = new ArrayList<IndexQuery>();
for (TaskInfo taskInfo : taskInfoList) {
IndexQuery indexQuery = new IndexQueryBuilder().withId(taskInfo.getTaskId()).withObject(taskInfo).build();
queries.add(indexQuery);
}
elasticsearchTemplate.bulkIndex(queries);
return true;
}
public boolean insertOrUpdateNewsInfo(List<NewsInfo> newsInfos) {
List<IndexQuery> queries = new ArrayList<IndexQuery>();
for (NewsInfo newsInfo : newsInfos) {
IndexQuery indexQuery = new IndexQueryBuilder().withId(newsInfo.getNewsId()).withObject(newsInfo).build();
queries.add(indexQuery);
}
elasticsearchTemplate.bulkIndex(queries);
return true;
}
public boolean insertOrUpdateNewsInfo(NewsInfo newsInfo) {
try {
IndexQuery indexQuery = new IndexQueryBuilder().withId(newsInfo.getNewsId()).withObject(newsInfo).build();
elasticsearchTemplate.index(indexQuery);
return true;
} catch (Exception e) {
logger.error("insert or update news info error.", e);
return false;
}
}
public boolean insertOrUpdateTaskInfo(TaskInfo taskInfo) {
try {
IndexQuery indexQuery = new IndexQueryBuilder().withId(taskInfo.getTaskId()).withObject(taskInfo).build();
elasticsearchTemplate.index(indexQuery);
return true;
} catch (Exception e) {
logger.error("insert or update task info error.", e);
return false;
}
}
public boolean insertOrUpdateUserInfo(UserInfo userInfo) {
try {
IndexQuery indexQuery = new IndexQueryBuilder().withId(userInfo.getUserId()).withObject(userInfo).build();
elasticsearchTemplate.index(indexQuery);
return true;
} catch (Exception e) {
logger.error("insert or update user info error.", e);
return false;
}
}
public <T> boolean deleteById(String id, Class<T> clzz) {
try {
elasticsearchTemplate.delete(clzz, id);
return true;
} catch (Exception e) {
logger.error("delete " + clzz + " by id " + id + " error.", e);
return false;
}
}
/**
* 检查健康状态
* @author 高国藩
* @date 2015年6月15日下午6:59:47
* @return
*/
public boolean ping() {
try {
ActionFuture<ClusterHealthResponse> health = esClient.admin().cluster().health(new ClusterHealthRequest());
ClusterHealthStatus status = health.actionGet().getStatus();
if (status.value() == ClusterHealthStatus.RED.value()) {
throw new RuntimeException("elasticsearch cluster health status is red.");
}
return true;
} catch (Exception e) {
logger.error("ping elasticsearch error.", e);
return false;
}
}
public boolean insertOrUpdateBrandCaseInfo(BrandCaseInfo brandCaseInfo) {
try {
IndexQuery indexQuery = new IndexQueryBuilder()
.withId(brandCaseInfo.getId()).withObject(brandCaseInfo).build();
elasticsearchTemplate.index(indexQuery);
return true;
} catch (Exception e) {
logger.error("insert or update brandcase info error.", e);
return false;
}
}
}

查询类

[java] view plain copy

package com.sf.daidongxi.web.service;
import java.util.ArrayList;
import java.util.Collection;
import java.util.List;
import java.util.Map;
import org.apache.commons.lang.StringUtils;
import org.apache.log4j.Logger;
import org.apache.lucene.queries.TermFilter;
import org.apache.lucene.queryparser.xml.builders.FilteredQueryBuilder;
import org.elasticsearch.action.search.SearchRequestBuilder;
import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.action.search.SearchType;
import org.elasticsearch.client.Client;
import org.elasticsearch.index.query.BoolFilterBuilder;
import org.elasticsearch.index.query.FilterBuilder;
import org.elasticsearch.index.query.FilterBuilders;
import org.elasticsearch.index.query.MatchQueryBuilder;
import org.elasticsearch.index.query.QueryBuilder;
import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.index.query.QueryStringQueryBuilder;
import org.elasticsearch.index.query.RangeFilterBuilder;
import org.elasticsearch.index.query.TermsQueryBuilder;
import org.elasticsearch.search.SearchHit;
import org.elasticsearch.search.sort.SortOrder;
import org.springframework.beans.factory.InitializingBean;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.elasticsearch.core.ElasticsearchTemplate;
import sun.misc.Contended;
public class ElasticsearchService implements InitializingBean {
private static final Logger logger = Logger
.getLogger(ElasticsearchService.class);
@Autowired
private Client client;
private String esIndexName = "heros";
@Autowired
private ElasticsearchTemplate elasticsearchTemplate;
@Autowired
private Client esClient;
/** 查询 id */
public List<String> queryId(String type, String[] fields, String content,
String sortField, SortOrder order, int from, int size) {
SearchRequestBuilder reqBuilder = client.prepareSearch(esIndexName)
.setTypes(type).setSearchType(SearchType.DEFAULT)
.setExplain(true);
QueryStringQueryBuilder queryString = QueryBuilders.queryString("\""
+ content + "\"");
for (String k : fields) {
queryString.field(k);
}
queryString.minimumShouldMatch("10");
reqBuilder.setQuery(QueryBuilders.boolQuery().should(queryString))
.setExplain(true);
if (StringUtils.isNotEmpty(sortField) && order != null) {
reqBuilder.addSort(sortField, order);
}
if (from >= 0 && size > 0) {
reqBuilder.setFrom(from).setSize(size);
}
SearchResponse resp = reqBuilder.execute().actionGet();
SearchHit[] hits = resp.getHits().getHits();
ArrayList<String> results = new ArrayList<String>();
for (SearchHit hit : hits) {
results.add(hit.getId());
}
return results;
}
/**
* 查询得到结果为Map集合
*
* @author 高国藩
* @date 2015年6月15日下午8:46:13
* @param type
* 表
* @param fields
* 字段索引
* @param content
* 查询的值
* @param sortField
* 排序的字段
* @param order
* 排序的規則
* @param from
* 分頁
* @param size
* @return
*/
public List<Map<String, Object>> queryForObject(String type,
String[] fields, String content, String sortField, SortOrder order,
int from, int size) {
SearchRequestBuilder reqBuilder = client.prepareSearch(esIndexName)
.setTypes(type).setSearchType(SearchType.DEFAULT)
.setExplain(true);
QueryStringQueryBuilder queryString = QueryBuilders.queryString("\""
+ content + "\"");
for (String k : fields) {
queryString.field(k);
}
queryString.minimumShouldMatch("10");
reqBuilder.setQuery(QueryBuilders.boolQuery().should(queryString))
.setExplain(true);
if (StringUtils.isNotEmpty(sortField) && order != null) {
reqBuilder.addSort(sortField, order);
}
if (from >= 0 && size > 0) {
reqBuilder.setFrom(from).setSize(size);
}
SearchResponse resp = reqBuilder.execute().actionGet();
SearchHit[] hits = resp.getHits().getHits();
List<Map<String, Object>> results = new ArrayList<Map<String, Object>>();
for (SearchHit hit : hits) {
results.add(hit.getSource());
}
return results;
}
/**
* QueryBuilders 所有查询入口
*/
public List<Map<String, Object>> queryForObjectEq(String type,
String[] fields, String content, String sortField, SortOrder order,
int from, int size) {
SearchRequestBuilder reqBuilder = client.prepareSearch(esIndexName)
.setTypes(type).setSearchType(SearchType.DEFAULT)
.setExplain(true);
QueryStringQueryBuilder queryString = QueryBuilders.queryString("\""
+ content + "\"");
for (String k : fields) {
queryString.field(k);
}
queryString.minimumShouldMatch("10");
reqBuilder.setQuery(QueryBuilders.boolQuery().must(queryString))
.setExplain(true);
if (StringUtils.isNotEmpty(sortField) && order != null) {
reqBuilder.addSort(sortField, order);
}
if (from >= 0 && size > 0) {
reqBuilder.setFrom(from).setSize(size);
}
SearchResponse resp = reqBuilder.execute().actionGet();
SearchHit[] hits = resp.getHits().getHits();
List<Map<String, Object>> results = new ArrayList<Map<String, Object>>();
for (SearchHit hit : hits) {
results.add(hit.getSource());
}
return results;
}
/**
* 多个文字记不清是那些字,然后放进去查询
*
* @author 高国藩
* @date 2015年6月16日上午9:56:08
* @param type
* @param field
* @param countents
* @param sortField
* @param order
* @param from
* @param size
* @return
*/
public List<Map<String, Object>> queryForObjectNotEq(String type,
String field, Collection<String> countents, String sortField,
SortOrder order, int from, int size) {
SearchRequestBuilder reqBuilder = client.prepareSearch(esIndexName)
.setTypes(type).setSearchType(SearchType.DEFAULT)
.setExplain(true);
List<String> contents = new ArrayList<String>();
for (String content : countents) {
contents.add("\"" + content + "\"");
}
TermsQueryBuilder inQuery = QueryBuilders.inQuery(field, contents);
inQuery.minimumShouldMatch("10");
reqBuilder.setQuery(QueryBuilders.boolQuery().mustNot(inQuery))
.setExplain(true);
if (StringUtils.isNotEmpty(sortField) && order != null) {
reqBuilder.addSort(sortField, order);
}
if (from >= 0 && size > 0) {
reqBuilder.setFrom(from).setSize(size);
}
SearchResponse resp = reqBuilder.execute().actionGet();
SearchHit[] hits = resp.getHits().getHits();
List<Map<String, Object>> results = new ArrayList<Map<String, Object>>();
for (SearchHit hit : hits) {
results.add(hit.getSource());
}
return results;
}
/**
* Filters 查询方式
*
* 1. 1)QueryBuilders.queryString 获得基本查询
* 2)FilteredQueryBuilder query = QueryBuilders.filteredQuery(queryString,FilterBuilder)
* 3)通过上面封装成为查询,将这个query插入到reqBuilder中;完成操作
*
* 2.在 reqBuilder.setQuery(query);
*
* 3.介绍在2)中的FilterBuilder各种构造方式-参数都可以传String类型即可
* FilterBuilders.rangeFilter("taskState").lt(20) 小于、 lte(20) 小于等于
* FilterBuilders.rangeFilter("taskState").gt(20)) 大于、 gte(20) 大于等于
* FilterBuilders.rangeFilter("taskState").from(start).to(end)) 范围,也可以指定日期,用字符串就ok了
* @author 高国藩
* @date 2015年6月15日下午10:06:05
* @param type
* @param field
* @param countents
* @param sortField
* @param order
* @param from
* @param size
* @return
*/
public List<Map<String, Object>> queryForObjectForElasticSerch(String type,
String field, String content,int start,int end) {
SearchRequestBuilder reqBuilder = client.prepareSearch(esIndexName)
.setTypes(type).setSearchType(SearchType.DEFAULT)
.setExplain(true);
QueryStringQueryBuilder queryString = QueryBuilders.queryString("\""
+ content + "\"");
queryString.field(field);
queryString.minimumShouldMatch("10");
reqBuilder.setQuery(QueryBuilders.filteredQuery(queryString, FilterBuilders.rangeFilter("taskState").from(start).to(end)))
.setExplain(true);
SearchResponse resp = reqBuilder.execute().actionGet();
SearchHit[] hits = resp.getHits().getHits();
List<Map<String, Object>> results = new ArrayList<Map<String, Object>>();
for (SearchHit hit : hits) {
results.add(hit.getSource());
}
return results;
}
public void afterPropertiesSet() throws Exception {
System.out.println("init...");
}
}

测试

[java] view plain copy

package com.sf.heros.mq.consumer;
import java.util.ArrayList;
import java.util.Collection;
import java.util.HashSet;
import java.util.List;
import java.util.Map;
import org.apache.log4j.Logger;
import org.elasticsearch.search.sort.SortOrder;
import org.junit.Test;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import com.sf.heros.mq.consumer.service.ElasticsearchService;
import com.sf.heros.mq.consumer.utils.APP;
import com.sf.heros.mq.consumer.vo.TaskInfo;
public class AppMain {
private static final Logger logger = Logger.getLogger(AppMain.class);
public void start() {
ClassPathXmlApplicationContext context = null;
try {
context = new ClassPathXmlApplicationContext("classpath:app.xml");
} catch (Exception e) {
logger.error("An error occurred, applicationContext will close.", e);
if (context != null) {
context.close();
}
context = null;
logger.error(APP.CLOSED_MSG);
}
}
/**
* 插入
* @author 高国藩
* @date 2015年6月16日上午10:14:21
*/
@Test
public void insertNo() {
ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(
"classpath:app.xml");
ElasticsearchService service = context
.getBean(ElasticsearchService.class);
List<TaskInfo> taskInfoList = new ArrayList<TaskInfo>();
for (int i = 0; i < 20; i++) {
taskInfoList.add(new TaskInfo(String.valueOf((i + 5)), i + 5, "高国藩"
+ i, "taskArea", "taskTags", i + 5, "1996-02-03", "霍华德"));
}
service.insertOrUpdateTaskInfo(taskInfoList);
}
/**
* 查询
* @author 高国藩
* @date 2015年6月16日上午10:14:21
*/
@Test
public void serchNo() {
ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(
"classpath:app.xml");
com.sf.daidongxi.web.service.ElasticsearchService service = (com.sf.daidongxi.web.service.ElasticsearchService) context
.getBean("es");
List<Map<String, Object>> al = service.queryForObject("task_info",
new String[] { "taskContent", "taskArea" }, "高国藩", "taskArea", SortOrder.DESC,
0, 2);
for (int i = 0; i < al.size(); i++) {
System.out.println(al.get(i));
}
}
/**
* filter查询
* @author 高国藩
* @date 2015年6月16日上午10:14:21
*/
@Test
public void serchFilter() {
ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(
"classpath:app.xml");
com.sf.daidongxi.web.service.ElasticsearchService service = (com.sf.daidongxi.web.service.ElasticsearchService) context
.getBean("es");
List<Map<String, Object>> al = service.queryForObjectForElasticSerch("task_info", "taskContent", "高",19,20);
for (int i = 0; i < al.size(); i++) {
System.out.println(al.get(i));
}
}
}

http://download.csdn.net/detail/liyantianmin/9565012

http://blog.csdn.net/liyantianmin/article/details/51801961

时间： 2024-04-15 11:56:25

elasticsearch spring 集成的相关文章

shiro和spring集成时session管理器超时时间问题

问题描述 shiro和spring集成时session管理器超时时间问题这是我的配置文件,我配置了并发人数控制和动态权限过滤,然后session超时时间这里也是配置了的,然后并没有什么鸟用,在登录以后获取超时时间也是正常的,但还是1分钟就过期了. <?xml version="1.0" encoding="UTF-8"?> xmlns:util="http://www.springframework.org/schema/util"

一个简单的hibernate与spring集成

下面介绍一下hibernate与spring的集成,这两个框架的集成关键在于 applicationContext.xml文件的配置,其实很简单的,但需要注意的是,导入包时一定选择导入到webroot/web-inf/lib目录中,而且hibernate一般要在spring 之前导入,因为集成时要用到sessionFactory类, 一.初始化工作:新建一个项目,如(ssh),在此项目中导入对hibernate的支持 ,新建一个表sstest表,有字段id,username,password,

Spring集成JSF的最简单方式

Spring集成JSF的最简单方式是使用DelegatingVariableResolver类.在faces-config.xml中配置,示例如下: <application> <variable-resolver>org.springframework.web.jsf. DelegatingVariableResolver</variable-resolver> <locale-config> <default-locale>zh_CN<

Spring集成RMI实现客户访问服务器，如何实现冗余服务器操作？

问题描述 Spring集成RMI实现客户访问服务器,如何实现冗余服务器操作?就是我的服务器设定为两个,一个是主,一个是备,当主服务器出现问题,客户机能通过RMI自动连接备服务器.请问谁知道如何配置啊?我的RMI是用Spring内带的RMI接口实现的.谢谢!另外,JMS服务如何实现上面的冗余操作呢? 解决方案解决方案二:没有人知道答案吗解决方案三:没有人知道答案吗

spring集成velocity，项目启动加载不到vm页面是为什么？

问题描述 spring集成velocity,项目启动加载不到vm页面是为什么? 这是在spring_mvc中的配置: <bean class="org.springframework.web.servlet.view.ResourceBundleViewResolver"> <property name="basename" value="views"></property> </bean> <

spring 集成quazt 后如何实现等spring容器加载完成之后自动执行一次任务？

问题描述我的项目中使用了spring集成quazt来实现任务调度任务的功能,现在有这样一个需求,我需要通过后台任务每隔半小时统计一次业务数据,然后放到缓存中,前台页面通过实时刷新页面来从缓存中获取统计的数据,可能,当我们系统刚上线的时候调度任务还没有执行,要等到指定的时间点才执行,我现要想让系统等到spring容器加载完成后就自动执行一次,请问有什么办法吗?<bean id="refreshOldAccountTrigger" class="org.springfra

struts2和spring集成问题

问题描述在公司项目开发中遇见spring 和struts2 集成问题spring context配置文件代码:<bean id="CustomerAction"class="com.kuquo.app.customer.action.CustomerAction"autowire="byName"></bean><bean id="

jax ws-jax-ws 与 spring 集成

问题描述 jax-ws 与 spring 集成我在上网上找了好多案例什么的,但是基本上就是不全,要么工程就运行不了.求各位大神的简单案例客服端与服务端,小弟再次谢谢了.95414928@qq.com

MyBatis5中Spring集成MyBatis事物管理_java

单独使用MyBatis对事物进行管理前面MyBatis的文章有写过相关内容,这里继续写一个最简单的Demo,算是复习一下之前MyBatis的内容吧,先是建表,建立一个简单的Student表: create table student ( student_id int auto_increment, student_name varchar(20) not null, primary key(student_id) ) 建立实体类Student.java: public class Studen

猜你喜欢

Android配置----小米手机通过wifi连接ADB调试Android应用

[正文] ADB远程调试的方法给Android开发人员带来了便利,下面介绍本人亲测有效的wifi连接ADB的方法.首先要保证电脑和手机在同一个局域网内,并且手机要通过wifi已正常连接. [测试版 ...

某公司出的题目，要做出来给面试

问题描述某公司出的题目,要做出来给面试直接贴代码,看注释部分,大家懂的,我研究了三天无果,觉得是恨变态的智力游戏... (把 input 数组改了,让程序main 函数正常退出) #includ ...

用Java转化汉字为拼音全拼

汉字|拼音 package com.easydozer.commons.util; import java.util.Iterator;import java.util.LinkedHashMap;i ...

带着梦想上路，从应届毕业生到运营总监

一直都想写写自己的故事,却一直没静下心来写.前几日加入了上海站长论坛,受一方兄再三邀稿,今日就将近几年来我的经历和大家分享下. 2000年我就读湖南的一所中专,学的是计算机专业,并开始接触到网站开发课 ...

C#新建站点,删除站点函数代码

函数|站点 using System;using System.Drawing;using System.Collections;using System.ComponentModel;using S ...

CSS设置背景图片

CSS设置背景图片需要用到background属性,其中的background-repeat设置图片平铺的方式,no-repeat为图片不重复平铺.CSS手册中对background-repeat的说 ...

蚁群算法小程序(C/C++语言实现)(二)

fclose(fp_block); } void HomeFoodInitial(void) { int randnum; int homeplace; /* 1 -- home at left-up ...

数据库组件 Hxj.Data （十五）（查询的排序、分组）

本节将讲述查询的排序(order by) 和分组(group by). 先说排序在分页中如果没有指定排序,组件会默认一个排序来实现分页. 例如 DbSession.Default.From< ...

spring依赖注入的3种实现方式

在讲解依赖注入的3种实现方式之前,这里先澄清一下依赖注入的意义:让组件依赖于抽象,当组件要与其他实际对象发生依赖关系时,通过抽象来注入依赖的实际对象. 依赖注入的3种实现方式分别是:接口注入 ...

Dreamweaver实现网页上漫天花雨效果

淡蓝色的天空下,一朵朵花瓣随风飘下,慢慢的在屏幕中飘荡.你一定要说这种效果用FLASH可以实现.其实用DREAMWEAVER也可以很轻松的实现! Dreamweaver之所以能够超过Frontpage ...

微软Win8系统语言设置技巧

在Win8系统中,可以在电脑设置常规选项页面,点击"语言首选项"进入语言设置页面,可以进行添加或更改输入法.键盘布局和语言. 图1 电脑设置常规页面在语言设置页面,更改语言首选项 ...

wps演示文稿设置背景的方法

wps演示文稿是可以设置背景的,但如果想要设置成自己想要背景该怎么操作呢?wps演示文稿如何设置背景?看了下面的教程你就知道了. 1.首先我们打开你要改背景的ppt,前提是你准备好了你改背景的图片 ...

Excel2010中不能输入斜杠怎么办

在Excel2010中,无法输入字符:/ ,而是在键盘上按下按键时出现悬浮的快捷键.如下图所示: 方法/步骤解决办法如下: 打开Excel2010,点击文件,然后单击"选项" ...

win7系统屏保怎么设置图文教程

话说win7下设置屏保不比xp,旗舰版,桌面右击,个性化,右下角的屏幕保护,选择一种,下面是时间设置了.家庭普通版,就到"控制面板"里面就找了. 小编用的是旗舰版,下面就一步步 ...

再谈pipeline-filter模式

本文结合最近我正在实现的一个基于RabbitMQ的消息总线上所走的弯路来谈谈设计层面上的责任链模式以及架构层面上的pipeline-filter模式.写这篇文章的另一个目的是为了纠正我之前针对pipe ...

java-socket设置setsotimeout后为什么没有作用？

问题描述 socket设置setsotimeout后为什么没有作用? try { ServerSocket serverSocket=null; serverSocket=new ServerSock ...

UIView转UIImage(截屏,UIGraphicsBeginImageContextWithOptions函数的使用)

UIView转UIImage(截屏,UIGraphicsBeginImageContextWithOptions函数的使用) 2012-11-06 13:56:59| 分类: iphone_de ...

SDN大趋势：控制器整合

在软件定义网络(SDN)中,控制器是网络架构中至关重要的一个点,它处在网络应用和网络设备之间.对网络专业人士来说,集中化的控制器担负着控制平面的作用,而控制平面就是传统上各种分布式路由协议如BGP和O ...

说说ToolBar以及仿QQ没网络提示的实现

转载请注明出处:王亟亟的大牛之路昨天停滞了一天的技术更新,写了个感悟,传送门"保持初心不变是多么的艰难--致那些一直在分享,在学习,在努力的开发者们" 今天来说说我们Google ...

source-java 编程中出现下面的错误

问题描述 java 编程中出现下面的错误 package Chat; import java.awt.*; import java.awt.event.*; import javax.swing.*; ...

mysql-MySQL语句查询问题，异常和查询条件

问题描述 MySQL语句查询问题,异常和查询条件源代码如下switch (querryType) { case 0: hql = ""from BookInfo b where ...

jsp function 的一些问题

问题描述 jsp function 的一些问题新手求助 ~~~ jsp中一个表单每行里面就有yes 和no 两个值只有最后yes个数等于三时才能提交成功这个应该怎么写那个function呢 ...

中国电信推最高网速家庭宽带：10M包年3588元

中国电信武汉分公司(下称"武汉电信")本月推出10M高速宽带,包年3588元,这是目前电信最高网速的家庭宽带. 10Mbps的速率是目前北京广为使用512Kbps的20倍,下载速度 ...

JAVA 图片批量改名

问题描述某个文件夹里边全部都是图片文件,如1.jpg,2.jpg.....若在前面加个编号变成Abc1.jpg,Abc2.jpg......,怎样实现,逐个改实在烦死人了.救命阿! 解决方案解决方 ...

将域名成功转移到美国实战经验详细分享

中介交易 http://www.aliyun.com/zixun/aggregation/6858.html">SEO诊断淘宝客云主机技术大厅一.域名出国步骤 kenengba ...

Riverbed大力扩展云存储生态系统

10月20日消息,旨在提升IT架构性能的Riverbed科技公司日前宣布扩展Riverbed® Whitewater®系列云存储网关产品的生态系统,提供快速.安全.经济高效的解决方案将异地数据无缝连接 ...

java-在oracle数据库建立分组的问题

问题描述在oracle数据库建立分组的问题怎么样建立一个大组,大组下面可以分很多小组,用户在每个小组里面发发布的信息只有小组成员能看见,小组于小组之间独立.而且建立小组的人对小组里面的人员有权限管 ...

think in java-java 多态中的一些问题

问题描述 java 多态中的一些问题 class Glyph{ void draw(){ System.out.println("Glyph.draw()"); } Glyph() ...

只需6000万美元，微软新总部将节约40%的能源

生活在大数据的未来,将是怎样的情景? 目前微软总部包括 125 栋建筑,容纳 41664 名微软人,就好像一座城镇.但 Darrell Smith 要将微软的总部变为"未来城市". ...

OpenID 关联认证提供 CoreOS dex

CoreOS dex 详细介绍 CoreOS dex 是 CoreOS 开源的,基于标准的认证提供器和身份验证解决方案. 之所以称之为"dex"是因为集中化用户索引,软件的其他部分 ...

热搜

© 2024 iVAN | info#iamivan.net | 11 q. 0.128 s.