ES搜索（java-api）

package com.qlyd.searchhelper;

import java.util.Map;

import net.sf.json.JSONObject;

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.common.text.Text;
import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.search.SearchHit;
import org.elasticsearch.search.SearchHits;
import org.elasticsearch.search.highlight.HighlightField;

import com.qlyd.business.newsinfo.po.NewsInfo;
import com.qlyd.common.QlydConstants;
import com.qlyd.utils.ESTools;
import com.qlyd.utils.JsonUtils;
/**
 * 
 * 
 * @类编号:
 * @类名称:ElasticSearchHandler
 * @内容摘要: //搜索控制类
 * @author:鹿伟伟
 * @创建日期:2016年3月22日 下午3:26:52
 * @修改人:
 * @修改日期:
 * @修改描述:简单描述修改的内容
 * @version 1.0.0
 *
 */
public class ElasticSearchHandler {
    private Client client = ESTools.getClient();

    public void searcher(String key, String indexId, String type) {
        try {

            // 创建查询索引,参数productindex表示要查询的索引库为productindex
            SearchRequestBuilder searchRequestBuilder = client
                    .prepareSearch(indexId);

            // 设置查询索引类型,setTypes("productType1", "productType2","productType3");
            // 用来设定在多个类型中搜索
            searchRequestBuilder.setTypes(type);
            // 设置查询类型 1.SearchType.DFS_QUERY_THEN_FETCH = 精确查询 2.SearchType.SCAN
            // = 扫描查询,无序
            searchRequestBuilder.setSearchType(SearchType.DFS_QUERY_THEN_FETCH);
            // 设置查询关键词
            searchRequestBuilder
                    .setQuery(QueryBuilders.termQuery("title", key));

            // // 查询过滤器过滤价格在4000-5000内
            // 这里范围为[4000,5000]区间闭包含,搜索结果包含价格为4000和价格为5000的数据
            // searchRequestBuilder.setFilter(FilterBuilders.rangeFilter("price")
            // .from(4000).to(5000));
            //
            // // 分页应用
            // searchRequestBuilder.setFrom(0).setSize(3);

            // 设置是否按查询匹配度排序
            searchRequestBuilder.setExplain(true);

            // 设置高亮显示
            searchRequestBuilder.addHighlightedField("title");
            searchRequestBuilder
                    .setHighlighterPreTags("<span style=\"color:red\">");
            searchRequestBuilder.setHighlighterPostTags("</span>");
            // 执行搜索,返回搜索响应信息
            SearchResponse response = searchRequestBuilder.execute()
                    .actionGet();
//          System.out.println(response.toString());
            // 获取搜索的文档结果
            SearchHits searchHits = response.getHits();
            SearchHit[] hits = searchHits.getHits();
            // ObjectMapper mapper = new ObjectMapper();
            for (int i = 0; i < hits.length; i++) {
                SearchHit hit = hits[i];
                // 将文档中的每一个对象转换json串值
                String json = hit.getSourceAsString();
                // 将json串值转换成对应的实体对象
                // Product product = mapper.readValue(json, Product.class);
                NewsInfo newsInfo = JsonUtils
                        .readToObject(json, NewsInfo.class);
                // 获取对应的高亮域
                Map<String, HighlightField> result = hit.highlightFields();
                // 从设定的高亮域中取得指定域
                HighlightField titleField = result.get("title");
                // 取得定义的高亮标签
                Text[] titleTexts = titleField.fragments();
                System.out.println(titleTexts.toString());
                // 为title串值增加自定义的高亮标签
                String title = "";
                for (Text text : titleTexts) {
                    title += text;
                }
                // 将追加了高亮标签的串值重新填充到对应的对象
                newsInfo.setTitle(title);
                // 打印高亮标签追加完成后的实体对象
                System.out.println(newsInfo);
            }
            System.out.println("search success ..");
        } catch (Exception e) {
            // TODO: handle exception
        }
    }

    public static void main(String[] args) {
        ElasticSearchHandler esHandler = new ElasticSearchHandler();
        System.out.println("++++++高亮查询+++++++");
        esHandler.searcher("齐鲁壹点", QlydConstants.INDEX, QlydConstants.TYPE);
    }
}

SearchRequestBuilder常用方法说明

(1) setIndices(String... indices)：上文中描述过，参数可为一个或多个字符串，表示要进行检索的index；

(2) setTypes(String... types)：参数可为一个或多个字符串，表示要进行检索的type，当参数为0个或者不调用此方法时，表示查询所有的type；

setSearchType(SearchType searchType)：执行检索的类别，值为org.elasticsearch.action.search.SearchType的元素，SearchType是一个枚举类型的类，
   其值如下所示：
   QUERY_THEN_FETCH:查询是针对所有的块执行的，但返回的是足够的信息，而不是文档内容（Document）。结果会被排序和分级，基于此，只有相关的块的文档对象会被返回。由于被取到的仅仅是这些，故而返回的hit的大小正好等于指定的size。这对于有许多块的index来说是很便利的（返回结果不会有重复的，因为块被分组了）
   QUERY_AND_FETCH:最原始（也可能是最快的）实现就是简单的在所有相关的shard上执行检索并返回结果。每个shard返回一定尺寸的结果。由于每个shard已经返回了一定尺寸的hit，这种类型实际上是返回多个shard的一定尺寸的结果给调用者。
   DFS_QUERY_THEN_FETCH：与QUERY_THEN_FETCH相同，预期一个初始的散射相伴用来为更准确的score计算分配了的term频率。
   DFS_QUERY_AND_FETCH:与QUERY_AND_FETCH相同，预期一个初始的散射相伴用来为更准确的score计算分配了的term频率。
   SCAN：在执行了没有进行任何排序的检索时执行浏览。此时将会自动的开始滚动结果集。
   COUNT：只计算结果的数量，也会执行facet。

(4) setSearchType(String searchType)，与setSearchType(SearchType searchType)类似，区别在于其值为字符串型的SearchType，值可为dfs_query_then_fetch、dfsQueryThenFetch、dfs_query_and_fetch、dfsQueryAndFetch、query_then_fetch、queryThenFetch、query_and_fetch或queryAndFetch；

(5) setScroll(Scroll scroll)、setScroll(TimeValue keepAlive)和setScroll(String keepAlive)，设置滚动，参数为Scroll时，直接用new Scroll(TimeValue)构造一个Scroll，为TimeValue或String时需要将TimeValue和String转化为Scroll；

(6) setTimeout(TimeValue timeout)和setTimeout(String timeout)，设置搜索的超时时间；

(7) setQuery，设置查询使用的Query；

(8) setFilter，设置过滤器；

(9) setMinScore，设置Score的最小数量；

(10) setFrom，从哪一个Score开始查；

(11) setSize，需要查询出多少条结果；