标签：

elasticsearch spring 集成

项目清单

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

项目源码

资源文件

app.properties

app.xml

elasticseach.xml

log4j.properties

maven管理

Java.class

Bean配置

常量管理

增删改类

查询类

测试

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

项目清单

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

项目源码

资源文件

app.properties

[java] view plain copy

 

 print?

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

app.xml

[java] view plain copy

 

 print?

1. <?xml version="1.0" encoding="UTF-8"?>    
2. <beans xmlns="http://www.springframework.org/schema/beans"    
3.     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:util="http://www.springframework.org/schema/util"    
4.     xmlns:context="http://www.springframework.org/schema/context"    
5.     xmlns:elasticsearch="http://www.pilato.fr/schema/elasticsearch"    
6.     xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd    
7.         http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util-3.0.xsd    
8.         http://www.pilato.fr/schema/elasticsearch http://www.pilato.fr/schema/elasticsearch/elasticsearch-0.3.xsd    
9.         http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.1.xsd">    
10.     <context:annotation-config />    
11.     <!-- 自动扫描所有注解该路径 -->    
12.     <!-- <context:component-scan base-package="com.sf.heros.mq.*" /> -->    
13.     <context:property-placeholder location="classpath:/app.properties" />    
14.     
15.     <import resource="elasticseach.xml" />    
16. </beans>    

elasticseach.xml

[java] view plain copy

 

 print?

1. <?xml version="1.0" encoding="UTF-8"?>    
2. <beans xmlns="http://www.springframework.org/schema/beans"    
3.     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:util="http://www.springframework.org/schema/util"    
4.     xmlns:context="http://www.springframework.org/schema/context"    
5.     xmlns:elasticsearch="http://www.pilato.fr/schema/elasticsearch"    
6.     xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd    
7.         http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util-3.0.xsd    
8.         http://www.pilato.fr/schema/elasticsearch http://www.pilato.fr/schema/elasticsearch/elasticsearch-0.3.xsd    
9.         http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.1.xsd">    
10.     
11.     <util:map id="esproperties">    
12.         <entry key="cluster.name" value="${elasticsearch.cluster.name}" />    
13.     </util:map>    
14.     
15.     <elasticsearch:client id="client" properties="esproperties"    
16.         esNodes="${elasticsearch.esNodes}" />    
17.     
18.     <bean name="elasticsearchTemplate"    
19.         class="org.springframework.data.elasticsearch.core.ElasticsearchTemplate">    
20.         <constructor-arg name="client" ref="client" />    
21.     </bean>    
22.     
23.     <bean name="elasticsearchService" class="com.sf.heros.mq.consumer.service.ElasticsearchService"    
24.         init-method="init" />    
25.     
26.     <bean name="es" class="com.sf.daidongxi.web.service.ElasticsearchService"></bean>    
27. </beans>  

maven

[java] view plain copy

 

 print?

1. <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"    
2.     xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">    
3.     <modelVersion>4.0.0</modelVersion>    
4.     <groupId>com.elasticsearch</groupId>    
5.     <artifactId>elasticsearch</artifactId>    
6.     <packaging>war</packaging>    
7.     <version>0.0.1-SNAPSHOT</version>    
8.     <name>elasticsearch Maven Webapp</name>    
9.     <url>http://maven.apache.org</url>    
10.     <properties>    
11.         <spring.version>3.1.1.RELEASE</spring.version>    
12.         <findbugs.annotations>2.0.0</findbugs.annotations>    
13.         <checkstyle.maven.plugin>2.11</checkstyle.maven.plugin>    
14.         <pmd.maven.plugin>3.0</pmd.maven.plugin>    
15.         <findbugs.maven.plugin>2.5.3</findbugs.maven.plugin>    
16.         <java.version>1.7</java.version>    
17.     </properties>    
18.     <dependencies>    
19.         <dependency>    
20.             <groupId>junit</groupId>    
21.             <artifactId>junit</artifactId>    
22.             <version>3.8.1</version>    
23.             <scope>test</scope>    
24.         </dependency>    
25.         <!-- spring begin -->    
26.         <dependency>    
27.             <groupId>org.springframework</groupId>    
28.             <artifactId>spring-context</artifactId>    
29.             <version>${spring.version}</version>    
30.         </dependency>    
31.         <dependency>    
32.             <groupId>org.springframework</groupId>    
33.             <artifactId>spring-context-support</artifactId>    
34.             <version>${spring.version}</version>    
35.         </dependency>    
36.     
37.         <dependency>    
38.             <groupId>org.springframework</groupId>    
39.             <artifactId>spring-aop</artifactId>    
40.             <version>${spring.version}</version>    
41.         </dependency>    
42.     
43.         <dependency>    
44.             <groupId>org.springframework</groupId>    
45.             <artifactId>spring-core</artifactId>    
46.             <version>${spring.version}</version>    
47.         </dependency>    
48.     
49.         <dependency>    
50.             <groupId>org.springframework</groupId>    
51.             <artifactId>spring-jdbc</artifactId>    
52.             <version>${spring.version}</version>    
53.         </dependency>    
54.     
55.         <!-- spring end -->    
56.     
57.         <!-- elasticsearch package -->    
58.         <dependency>    
59.             <groupId>fr.pilato.spring</groupId>    
60.             <artifactId>spring-elasticsearch</artifactId>    
61.             <version>1.0.0</version>    
62.         </dependency>    
63.     
64.         <dependency>    
65.             <groupId>org.elasticsearch</groupId>    
66.             <artifactId>elasticsearch</artifactId>    
67.             <version>1.0.0</version>    
68.         </dependency>    
69.     
70.         <dependency>    
71.             <groupId>org.springframework.data</groupId>    
72.             <artifactId>spring-data-elasticsearch</artifactId>    
73.             <version>1.0.0.RELEASE</version>    
74.         </dependency>    
75.     
76.         <dependency>    
77.             <groupId>com.alibaba</groupId>    
78.             <artifactId>druid</artifactId>    
79.             <version>1.0.5</version>    
80.         </dependency>    
81.     
82.         <!--json-lib -->    
83.         <dependency>    
84.             <groupId>net.sf.json-lib</groupId>    
85.             <artifactId>json-lib</artifactId>    
86.             <version>2.4</version>    
87.             <classifier>jdk15</classifier>    
88.         </dependency>    
89.     
90.         <!-- quartz job -->    
91.         <dependency>    
92.             <groupId>org.quartz-scheduler</groupId>    
93.             <artifactId>quartz</artifactId>    
94.             <version>2.2.1</version>    
95.         </dependency>    
96.     
97.         <!-- log4j -->    
98.         <dependency>    
99.             <groupId>org.slf4j</groupId>    
100.             <artifactId>slf4j-log4j12</artifactId>    
101.             <version>1.7.5</version>    
102.         </dependency>    
103.     </dependencies>    
104.     <build>    
105.         <finalName>elasticsearch</finalName>    
106.     </build>    
107. </project>    

Java.class

Bean配置

[java] view plain copy

 

 print?

1. package com.sf.heros.mq.consumer.vo;    
2.     
3. import org.springframework.data.annotation.Id;    
4. import org.springframework.data.elasticsearch.annotations.Document;    
5. import org.springframework.data.elasticsearch.annotations.Field;    
6. import org.springframework.data.elasticsearch.annotations.FieldIndex;    
7. import org.springframework.data.elasticsearch.annotations.FieldType;    
8.     
9. import com.sf.heros.mq.consumer.utils.APP;    
10.     
11. //@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)    
12. @Document(indexName = APP.ESProp.INDEX_NAME, type = APP.ESProp.TYPE_TASK_INFO)    
13. public class TaskInfo {    
14.     @Id    
15.     @Field(index = FieldIndex.not_analyzed, store = true)    
16.     private String taskId;    
17.         
18.     @Field(type = FieldType.Integer, index = FieldIndex.not_analyzed, store = true)    
19.     private Integer userId;    
20.     
21.     @Field(type = FieldType.String, indexAnalyzer="ik", searchAnalyzer="ik", store = true)    
22.     private String taskContent;    
23.     
24.     @Field(type = FieldType.String, indexAnalyzer="ik", searchAnalyzer="ik", store = true)    
25.     private String taskArea;    
26.         
27.     @Field(type = FieldType.String, indexAnalyzer="ik", searchAnalyzer="ik", store = true)    
28.     private String taskTags;    
29.         
30.     @Field(type = FieldType.Integer, index = FieldIndex.not_analyzed, store = true)    
31.     private Integer taskState;    
32.     
33.     @Field(type = FieldType.String, index = FieldIndex.not_analyzed, store = true)    
34.     private String updateTime;    
35.     
36.     @Field(type = FieldType.String, indexAnalyzer="ik", searchAnalyzer="ik", store = true)    
37.     private String userNickName;    
38.         
39.     public String getTaskId() {    
40.         return taskId;    
41.     }    
42.     
43.     public void setTaskId(String taskId) {    
44.         this.taskId = taskId;    
45.     }    
46.     
47.     public Integer getUserId() {    
48.         return userId;    
49.     }    
50.     
51.     public void setUserId(Integer userId) {    
52.         this.userId = userId;    
53.     }    
54.     
55.     public String getTaskContent() {    
56.         return taskContent;    
57.     }    
58.     
59.     public void setTaskContent(String taskContent) {    
60.         this.taskContent = taskContent;    
61.     }    
62.     
63.     public String getTaskArea() {    
64.         return taskArea;    
65.     }    
66.     
67.     public void setTaskArea(String taskArea) {    
68.         this.taskArea = taskArea;    
69.     }    
70.     
71.     public String getTaskTags() {    
72.         return taskTags;    
73.     }    
74.     
75.     public void setTaskTags(String taskTags) {    
76.         this.taskTags = taskTags;    
77.     }    
78.     
79.     public Integer getTaskState() {    
80.         return taskState;    
81.     }    
82.     
83.     public void setTaskState(Integer taskState) {    
84.         this.taskState = taskState;    
85.     }    
86.     
87.     public String getUpdateTime() {    
88.         return updateTime;    
89.     }    
90.     
91.     public void setUpdateTime(String updateTime) {    
92.         this.updateTime = updateTime;    
93.     }    
94.     
95.     public String getUserNickName() {    
96.         return userNickName;    
97.     }    
98.     
99.     public void setUserNickName(String userNickName) {    
100.         this.userNickName = userNickName;    
101.     }    
102.     
103.     @Override    
104.     public String toString() {    
105.         return "TaskInfo [taskId=" + taskId + ", userId=" + userId    
106.                 + ", taskContent=" + taskContent + ", taskArea=" + taskArea    
107.                 + ", taskState=" + taskState    
108.                 + ", updateTime=" + updateTime + ", userNickName="    
109.                 + userNickName + "]";    
110.     }    
111.     
112.     public TaskInfo(String taskId, Integer userId, String taskContent,    
113.             String taskArea, String taskTags, Integer taskState,    
114.             String updateTime, String userNickName) {    
115.         this.taskId = taskId;    
116.         this.userId = userId;    
117.         this.taskContent = taskContent;    
118.         this.taskArea = taskArea;    
119.         this.taskTags = taskTags;    
120.         this.taskState = taskState;    
121.         this.updateTime = updateTime;    
122.         this.userNickName = userNickName;    
123.     }    
124.     public TaskInfo() {    
125.         // TODO Auto-generated constructor stub    
126.     }    
127. }  

增删改类

[java] view plain copy

 

 print?

1. /**   
2.  *@Pr锛歨eros   
3.  *@Date: 2014-5-4 涓婂崍9:21:27   
4.  *@Author: seaphy   
5.  *@Copyright: 漏 2012 sf-express.com Inc. All rights reserved   
6.  *娉ㄦ剰锛氭湰鍐呭浠呴檺浜庨『涓伴?熻繍鍏徃鍐呴儴浼犻槄锛岀姝㈠娉勪互鍙婄敤浜庡叾浠栫殑鍟嗕笟鐩殑   
7.  */    
8. package com.sf.heros.mq.consumer.service;    
9.     
10. import java.util.ArrayList;    
11. import java.util.List;    
12.     
13. import org.apache.log4j.Logger;    
14. import org.elasticsearch.action.ActionFuture;    
15. import org.elasticsearch.action.admin.cluster.health.ClusterHealthRequest;    
16. import org.elasticsearch.action.admin.cluster.health.ClusterHealthResponse;    
17. import org.elasticsearch.action.admin.cluster.health.ClusterHealthStatus;    
18. import org.elasticsearch.client.Client;    
19. import org.springframework.beans.factory.annotation.Autowired;    
20. import org.springframework.data.elasticsearch.core.ElasticsearchTemplate;    
21. import org.springframework.data.elasticsearch.core.query.IndexQuery;    
22. import org.springframework.data.elasticsearch.core.query.IndexQueryBuilder;    
23.     
24. import com.sf.heros.mq.consumer.utils.APP;    
25. import com.sf.heros.mq.consumer.vo.BrandCaseInfo;    
26. import com.sf.heros.mq.consumer.vo.NewsInfo;    
27. import com.sf.heros.mq.consumer.vo.TaskInfo;    
28. import com.sf.heros.mq.consumer.vo.UserInfo;    
29.     
30. /**   
31.  * @author seaphy   
32.  * @date 2014-5-4   
33.  */    
34. public class ElasticsearchService {    
35.     
36.     private static final Logger logger = Logger.getLogger(ElasticsearchService.class);    
37.     
38.     @Autowired    
39.     private ElasticsearchTemplate elasticsearchTemplate;    
40.     
41.     @Autowired    
42.     private Client esClient;    
43.     
44.     public void init() {    
45.         if (!elasticsearchTemplate.indexExists(APP.ESProp.INDEX_NAME)) {    
46.             elasticsearchTemplate.createIndex(APP.ESProp.INDEX_NAME);    
47.         }    
48.         elasticsearchTemplate.putMapping(TaskInfo.class);    
49.         elasticsearchTemplate.putMapping(NewsInfo.class);    
50.     }    
51.     
52.     public boolean update(List<TaskInfo> taskInfoList) {    
53.         List<IndexQuery> queries = new ArrayList<IndexQuery>();    
54.         for (TaskInfo taskInfo : taskInfoList) {    
55.             IndexQuery indexQuery = new IndexQueryBuilder().withId(taskInfo.getTaskId()).withObject(taskInfo).build();    
56.             queries.add(indexQuery);    
57.         }    
58.         elasticsearchTemplate.bulkIndex(queries);    
59.         return true;    
60.     }    
61.     
62.     public boolean insertOrUpdateTaskInfo(List<TaskInfo> taskInfoList) {    
63.         List<IndexQuery> queries = new ArrayList<IndexQuery>();    
64.         for (TaskInfo taskInfo : taskInfoList) {    
65.             IndexQuery indexQuery = new IndexQueryBuilder().withId(taskInfo.getTaskId()).withObject(taskInfo).build();    
66.             queries.add(indexQuery);    
67.         }    
68.         elasticsearchTemplate.bulkIndex(queries);    
69.         return true;    
70.     }    
71.     
72.     public boolean insertOrUpdateNewsInfo(List<NewsInfo> newsInfos) {    
73.         List<IndexQuery> queries = new ArrayList<IndexQuery>();    
74.         for (NewsInfo newsInfo : newsInfos) {    
75.             IndexQuery indexQuery = new IndexQueryBuilder().withId(newsInfo.getNewsId()).withObject(newsInfo).build();    
76.             queries.add(indexQuery);    
77.         }    
78.         elasticsearchTemplate.bulkIndex(queries);    
79.         return true;    
80.     }    
81.     
82.     public boolean insertOrUpdateNewsInfo(NewsInfo newsInfo) {    
83.         try {    
84.             IndexQuery indexQuery = new IndexQueryBuilder().withId(newsInfo.getNewsId()).withObject(newsInfo).build();    
85.             elasticsearchTemplate.index(indexQuery);    
86.             return true;    
87.         } catch (Exception e) {    
88.             logger.error("insert or update news info error.", e);    
89.             return false;    
90.         }    
91.     }    
92.     
93.     public boolean insertOrUpdateTaskInfo(TaskInfo taskInfo) {    
94.         try {    
95.             IndexQuery indexQuery = new IndexQueryBuilder().withId(taskInfo.getTaskId()).withObject(taskInfo).build();    
96.             elasticsearchTemplate.index(indexQuery);    
97.             return true;    
98.         } catch (Exception e) {    
99.             logger.error("insert or update task info error.", e);    
100.             return false;    
101.         }    
102.     }    
103.     
104.     public boolean insertOrUpdateUserInfo(UserInfo userInfo) {    
105.         try {    
106.             IndexQuery indexQuery = new IndexQueryBuilder().withId(userInfo.getUserId()).withObject(userInfo).build();    
107.             elasticsearchTemplate.index(indexQuery);    
108.             return true;    
109.         } catch (Exception e) {    
110.             logger.error("insert or update user info error.", e);    
111.             return false;    
112.         }    
113.     }    
114.     
115.     public <T> boolean deleteById(String id, Class<T> clzz) {    
116.         try {    
117.             elasticsearchTemplate.delete(clzz, id);    
118.             return true;    
119.         } catch (Exception e) {    
120.             logger.error("delete " + clzz + " by id " + id + " error.", e);    
121.             return false;    
122.         }    
123.     }    
124.     
125.     /**   
126.      * 检查健康状态   
127.     * @author 高国藩   
128.     * @date 2015年6月15日 下午6:59:47   
129.     * @return   
130.      */    
131.     public boolean ping() {    
132.         try {    
133.             ActionFuture<ClusterHealthResponse> health = esClient.admin().cluster().health(new ClusterHealthRequest());    
134.             ClusterHealthStatus status = health.actionGet().getStatus();    
135.             if (status.value() == ClusterHealthStatus.RED.value()) {    
136.                 throw new RuntimeException("elasticsearch cluster health status is red.");    
137.             }    
138.             return true;    
139.         } catch (Exception e) {    
140.             logger.error("ping elasticsearch error.", e);    
141.             return false;    
142.         }    
143.     }    
144.     
145.     public boolean insertOrUpdateBrandCaseInfo(BrandCaseInfo brandCaseInfo) {    
146.         try {    
147.             IndexQuery indexQuery = new IndexQueryBuilder()    
148.                     .withId(brandCaseInfo.getId()).withObject(brandCaseInfo).build();    
149.             elasticsearchTemplate.index(indexQuery);    
150.             return true;    
151.         } catch (Exception e) {    
152.             logger.error("insert or update brandcase info error.", e);    
153.             return false;    
154.         }    
155.     }    
156. }    

查询类

[java] view plain copy

 

 print?

1. package com.sf.daidongxi.web.service;    
2.     
3. import java.util.ArrayList;    
4. import java.util.Collection;    
5. import java.util.List;    
6. import java.util.Map;    
7.     
8. import org.apache.commons.lang.StringUtils;    
9. import org.apache.log4j.Logger;    
10. import org.apache.lucene.queries.TermFilter;    
11. import org.apache.lucene.queryparser.xml.builders.FilteredQueryBuilder;    
12. import org.elasticsearch.action.search.SearchRequestBuilder;    
13. import org.elasticsearch.action.search.SearchResponse;    
14. import org.elasticsearch.action.search.SearchType;    
15. import org.elasticsearch.client.Client;    
16. import org.elasticsearch.index.query.BoolFilterBuilder;    
17. import org.elasticsearch.index.query.FilterBuilder;    
18. import org.elasticsearch.index.query.FilterBuilders;    
19. import org.elasticsearch.index.query.MatchQueryBuilder;    
20. import org.elasticsearch.index.query.QueryBuilder;    
21. import org.elasticsearch.index.query.QueryBuilders;    
22. import org.elasticsearch.index.query.QueryStringQueryBuilder;    
23. import org.elasticsearch.index.query.RangeFilterBuilder;    
24. import org.elasticsearch.index.query.TermsQueryBuilder;    
25. import org.elasticsearch.search.SearchHit;    
26. import org.elasticsearch.search.sort.SortOrder;    
27. import org.springframework.beans.factory.InitializingBean;    
28. import org.springframework.beans.factory.annotation.Autowired;    
29. import org.springframework.data.elasticsearch.core.ElasticsearchTemplate;    
30.     
31. import sun.misc.Contended;    
32.     
33. public class ElasticsearchService implements InitializingBean {    
34.     
35.     private static final Logger logger = Logger    
36.             .getLogger(ElasticsearchService.class);    
37.     
38.     @Autowired    
39.     private Client client;    
40.     
41.     private String esIndexName = "heros";    
42.     
43.     @Autowired    
44.     private ElasticsearchTemplate elasticsearchTemplate;    
45.     
46.     @Autowired    
47.     private Client esClient;    
48.     
49.     /** 查询 id */    
50.     public List<String> queryId(String type, String[] fields, String content,    
51.             String sortField, SortOrder order, int from, int size) {    
52.         SearchRequestBuilder reqBuilder = client.prepareSearch(esIndexName)    
53.                 .setTypes(type).setSearchType(SearchType.DEFAULT)    
54.                 .setExplain(true);    
55.         QueryStringQueryBuilder queryString = QueryBuilders.queryString("\""    
56.                 + content + "\"");    
57.         for (String k : fields) {    
58.             queryString.field(k);    
59.         }    
60.         queryString.minimumShouldMatch("10");    
61.         reqBuilder.setQuery(QueryBuilders.boolQuery().should(queryString))    
62.                 .setExplain(true);    
63.         if (StringUtils.isNotEmpty(sortField) && order != null) {    
64.             reqBuilder.addSort(sortField, order);    
65.         }    
66.         if (from >= 0 && size > 0) {    
67.             reqBuilder.setFrom(from).setSize(size);    
68.         }    
69.         SearchResponse resp = reqBuilder.execute().actionGet();    
70.         SearchHit[] hits = resp.getHits().getHits();    
71.         ArrayList<String> results = new ArrayList<String>();    
72.         for (SearchHit hit : hits) {    
73.             results.add(hit.getId());    
74.         }    
75.         return results;    
76.     }    
77.     
78.     /**   
79.      * 查询得到结果为Map集合   
80.      *    
81.      * @author 高国藩   
82.      * @date 2015年6月15日 下午8:46:13   
83.      * @param type   
84.      *            表   
85.      * @param fields   
86.      *            字段索引   
87.      * @param content   
88.      *            查询的值   
89.      * @param sortField   
90.      *            排序的字段   
91.      * @param order   
92.      *            排序的規則   
93.      * @param from   
94.      *            分頁   
95.      * @param size   
96.      * @return   
97.      */    
98.     public List<Map<String, Object>> queryForObject(String type,    
99.             String[] fields, String content, String sortField, SortOrder order,    
100.             int from, int size) {    
101.         SearchRequestBuilder reqBuilder = client.prepareSearch(esIndexName)    
102.                 .setTypes(type).setSearchType(SearchType.DEFAULT)    
103.                 .setExplain(true);    
104.         QueryStringQueryBuilder queryString = QueryBuilders.queryString("\""    
105.                 + content + "\"");    
106.         for (String k : fields) {    
107.             queryString.field(k);    
108.         }    
109.         queryString.minimumShouldMatch("10");    
110.         reqBuilder.setQuery(QueryBuilders.boolQuery().should(queryString))    
111.                 .setExplain(true);    
112.         if (StringUtils.isNotEmpty(sortField) && order != null) {    
113.             reqBuilder.addSort(sortField, order);    
114.         }    
115.         if (from >= 0 && size > 0) {    
116.             reqBuilder.setFrom(from).setSize(size);    
117.         }    
118.     
119.         SearchResponse resp = reqBuilder.execute().actionGet();    
120.         SearchHit[] hits = resp.getHits().getHits();    
121.     
122.         List<Map<String, Object>> results = new ArrayList<Map<String, Object>>();    
123.         for (SearchHit hit : hits) {    
124.             results.add(hit.getSource());    
125.         }    
126.         return results;    
127.     }    
128.     
129.     /**   
130.      * QueryBuilders 所有查询入口   
131.      */    
132.     public List<Map<String, Object>> queryForObjectEq(String type,    
133.             String[] fields, String content, String sortField, SortOrder order,    
134.             int from, int size) {    
135.         SearchRequestBuilder reqBuilder = client.prepareSearch(esIndexName)    
136.                 .setTypes(type).setSearchType(SearchType.DEFAULT)    
137.                 .setExplain(true);    
138.         QueryStringQueryBuilder queryString = QueryBuilders.queryString("\""    
139.                 + content + "\"");    
140.         for (String k : fields) {    
141.             queryString.field(k);    
142.         }    
143.         queryString.minimumShouldMatch("10");    
144.         reqBuilder.setQuery(QueryBuilders.boolQuery().must(queryString))    
145.                 .setExplain(true);    
146.         if (StringUtils.isNotEmpty(sortField) && order != null) {    
147.             reqBuilder.addSort(sortField, order);    
148.         }    
149.         if (from >= 0 && size > 0) {    
150.             reqBuilder.setFrom(from).setSize(size);    
151.         }    
152.     
153.         SearchResponse resp = reqBuilder.execute().actionGet();    
154.         SearchHit[] hits = resp.getHits().getHits();    
155.     
156.         List<Map<String, Object>> results = new ArrayList<Map<String, Object>>();    
157.         for (SearchHit hit : hits) {    
158.             results.add(hit.getSource());    
159.         }    
160.         return results;    
161.     }    
162.     
163.     /**   
164.      * 多个文字记不清是那些字,然后放进去查询   
165.      *    
166.      * @author 高国藩   
167.      * @date 2015年6月16日 上午9:56:08   
168.      * @param type   
169.      * @param field   
170.      * @param countents   
171.      * @param sortField   
172.      * @param order   
173.      * @param from   
174.      * @param size   
175.      * @return   
176.      */    
177.     public List<Map<String, Object>> queryForObjectNotEq(String type,    
178.             String field, Collection<String> countents, String sortField,    
179.             SortOrder order, int from, int size) {    
180.     
181.         SearchRequestBuilder reqBuilder = client.prepareSearch(esIndexName)    
182.                 .setTypes(type).setSearchType(SearchType.DEFAULT)    
183.                 .setExplain(true);    
184.         List<String> contents = new ArrayList<String>();    
185.         for (String content : countents) {    
186.             contents.add("\"" + content + "\"");    
187.         }    
188.         TermsQueryBuilder inQuery = QueryBuilders.inQuery(field, contents);    
189.         inQuery.minimumShouldMatch("10");    
190.         reqBuilder.setQuery(QueryBuilders.boolQuery().mustNot(inQuery))    
191.                 .setExplain(true);    
192.         if (StringUtils.isNotEmpty(sortField) && order != null) {    
193.             reqBuilder.addSort(sortField, order);    
194.         }    
195.         if (from >= 0 && size > 0) {    
196.             reqBuilder.setFrom(from).setSize(size);    
197.         }    
198.     
199.         SearchResponse resp = reqBuilder.execute().actionGet();    
200.         SearchHit[] hits = resp.getHits().getHits();    
201.     
202.         List<Map<String, Object>> results = new ArrayList<Map<String, Object>>();    
203.         for (SearchHit hit : hits) {    
204.             results.add(hit.getSource());    
205.         }    
206.         return results;    
207.     }    
208.     
209.     /**   
210.      * Filters 查询方式   
211.      *    
212.      * 1. 1)QueryBuilders.queryString 获得基本查询   
213.      *    2)FilteredQueryBuilder query = QueryBuilders.filteredQuery(queryString,FilterBuilder)   
214.      *    3)通过上面封装成为查询,将这个query插入到reqBuilder中;完成操作   
215.      *       
216.      * 2.在   reqBuilder.setQuery(query);   
217.      *    
218.      * 3.介绍在2)中的FilterBuilder各种构造方式-参数都可以传String类型即可   
219.      * FilterBuilders.rangeFilter("taskState").lt(20) 小于 、 lte(20) 小于等于   
220.      * FilterBuilders.rangeFilter("taskState").gt(20)) 大于  、 gte(20) 大于等于   
221.      * FilterBuilders.rangeFilter("taskState").from(start).to(end)) 范围,也可以指定日期,用字符串就ok了   
222.      * @author 高国藩   
223.      * @date 2015年6月15日 下午10:06:05   
224.      * @param type   
225.      * @param field   
226.      * @param countents   
227.      * @param sortField   
228.      * @param order   
229.      * @param from   
230.      * @param size   
231.      * @return   
232.      */    
233.     public List<Map<String, Object>> queryForObjectForElasticSerch(String type,    
234.             String field, String content,int start,int end) {    
235.     
236.         SearchRequestBuilder reqBuilder = client.prepareSearch(esIndexName)    
237.                 .setTypes(type).setSearchType(SearchType.DEFAULT)    
238.                 .setExplain(true);    
239.         QueryStringQueryBuilder queryString = QueryBuilders.queryString("\""    
240.                 + content + "\"");    
241.             queryString.field(field);    
242.         queryString.minimumShouldMatch("10");    
243.             
244.         reqBuilder.setQuery(QueryBuilders.filteredQuery(queryString, FilterBuilders.rangeFilter("taskState").from(start).to(end)))    
245.                 .setExplain(true);    
246.     
247.         SearchResponse resp = reqBuilder.execute().actionGet();    
248.         SearchHit[] hits = resp.getHits().getHits();    
249.     
250.         List<Map<String, Object>> results = new ArrayList<Map<String, Object>>();    
251.         for (SearchHit hit : hits) {    
252.             results.add(hit.getSource());    
253.         }    
254.         return results;    
255.     }    
256.     
257.     public void afterPropertiesSet() throws Exception {    
258.         System.out.println("init...");    
259.     
260.     }    
261.     
262. }    

测试

[java] view plain copy

 

 print?

1. package com.sf.heros.mq.consumer;    
2.     
3. import java.util.ArrayList;    
4. import java.util.Collection;    
5. import java.util.HashSet;    
6. import java.util.List;    
7. import java.util.Map;    
8.     
9. import org.apache.log4j.Logger;    
10. import org.elasticsearch.search.sort.SortOrder;    
11. import org.junit.Test;    
12. import org.springframework.context.support.ClassPathXmlApplicationContext;    
13.     
14. import com.sf.heros.mq.consumer.service.ElasticsearchService;    
15. import com.sf.heros.mq.consumer.utils.APP;    
16. import com.sf.heros.mq.consumer.vo.TaskInfo;    
17.     
18. public class AppMain {    
19.     
20.     private static final Logger logger = Logger.getLogger(AppMain.class);    
21.     
22.     public void start() {    
23.         ClassPathXmlApplicationContext context = null;    
24.         try {    
25.             context = new ClassPathXmlApplicationContext("classpath:app.xml");    
26.         } catch (Exception e) {    
27.             logger.error("An error occurred, applicationContext will close.", e);    
28.             if (context != null) {    
29.                 context.close();    
30.             }    
31.             context = null;    
32.             logger.error(APP.CLOSED_MSG);    
33.         }    
34.     }    
35.     
36.     /**   
37.      * 插入   
38.     * @author 高国藩   
39.     * @date 2015年6月16日 上午10:14:21   
40.      */    
41.     @Test    
42.     public void insertNo() {    
43.         ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(    
44.                 "classpath:app.xml");    
45.         ElasticsearchService service = context    
46.                 .getBean(ElasticsearchService.class);    
47.         List<TaskInfo> taskInfoList = new ArrayList<TaskInfo>();    
48.         for (int i = 0; i < 20; i++) {    
49.             taskInfoList.add(new TaskInfo(String.valueOf((i + 5)), i + 5, "高国藩"    
50.                     + i, "taskArea", "taskTags", i + 5, "1996-02-03", "霍华德"));    
51.         }    
52.         service.insertOrUpdateTaskInfo(taskInfoList);    
53.     }    
54.     
55.     /**   
56.      * 查询   
57.     * @author 高国藩   
58.     * @date 2015年6月16日 上午10:14:21   
59.      */    
60.     @Test    
61.     public void serchNo() {    
62.         ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(    
63.                 "classpath:app.xml");    
64.         com.sf.daidongxi.web.service.ElasticsearchService service = (com.sf.daidongxi.web.service.ElasticsearchService) context    
65.                 .getBean("es");    
66.         List<Map<String, Object>> al = service.queryForObject("task_info",    
67.                 new String[] { "taskContent", "taskArea" }, "高国藩", "taskArea", SortOrder.DESC,    
68.                 0, 2);    
69.     
70.         for (int i = 0; i < al.size(); i++) {    
71.             System.out.println(al.get(i));    
72.         }    
73.             
74.     }    
75.         
76.     /**   
77.      * filter查询   
78.     * @author 高国藩   
79.     * @date 2015年6月16日 上午10:14:21   
80.      */    
81.     @Test    
82.     public void serchFilter() {    
83.         ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(    
84.                 "classpath:app.xml");    
85.         com.sf.daidongxi.web.service.ElasticsearchService service = (com.sf.daidongxi.web.service.ElasticsearchService) context    
86.                 .getBean("es");    
87.         List<Map<String, Object>> al = service.queryForObjectForElasticSerch("task_info", "taskContent", "高",19,20);    
88.     
89.         for (int i = 0; i < al.size(); i++) {    
90.             System.out.println(al.get(i));    
91.         }    
92.             
93.     }    
94. }    

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

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

elasticsearch spring 集成

标签：

原文地址：http://www.cnblogs.com/softidea/p/5891552.html