useradd es

chown es:es -hR .

maven package

POST url : localhost:9200/ngramtestContent-Type: application/json{    "settings": {        "analysis": {            "analyzer": {                "charSplit": {                    "type": "custom",                     "tokenizer": "my_ngram_tokenizer",                    "filter":["lowercase"]                }            },            "tokenizer": {                "my_ngram_tokenizer": {                    "type": "nGram",                     "min_gram": "2",                     "max_gram": "4",                     "token_chars": ["letter","digit","punctuation"]                }            }        }    },     "mappings": {        "myType": {            "dynamic": "strict",             "properties": {                "content": {                    "type": "string",                     "analyzer": "charSplit",                     "search_analyzer": "charSplit"                }            }        }    }}

min_gram：单个词的最小长度，默认1max_gram：单个词的最大长度，默认2token_chars：可以接受的字符集(即遇到不在列表中的字符集会进行文本分割)字符集包括letter           字母或汉字  a, b, ï or 京digit            数字 3 or 7whitespace       空白(空格、回车、tab等)  " " or "\n"punctuation      标点符号  ! , 。or "symbol           标志(区别于标点符号) $ or √

POST 192.168.5.222:9200/yuqingtest/_analyze?pretty&analyzer=charSplit商业核心和$标准化技术

{  "tokens": [    {      "token": "商业核",      "start_offset": 0,      "end_offset": 3,      "type": "word",      "position": 0    },    {      "token": "商业核心",      "start_offset": 0,      "end_offset": 4,      "type": "word",      "position": 1    },    {      "token": "业核心",      "start_offset": 1,      "end_offset": 4,      "type": "word",      "position": 2    },    {      "token": "业核心和",      "start_offset": 1,      "end_offset": 5,      "type": "word",      "position": 3    },    {      "token": "核心和",      "start_offset": 2,      "end_offset": 5,      "type": "word",      "position": 4    },    {      "token": "标准化",      "start_offset": 6,      "end_offset": 9,      "type": "word",      "position": 5    },    {      "token": "标准化技",      "start_offset": 6,      "end_offset": 10,      "type": "word",      "position": 6    },    {      "token": "准化技",      "start_offset": 7,      "end_offset": 10,      "type": "word",      "position": 7    },    {      "token": "准化技术",      "start_offset": 7,      "end_offset": 11,      "type": "word",      "position": 8    },    {      "token": "化技术",      "start_offset": 8,      "end_offset": 11,      "type": "word",      "position": 9    }  ]}

...cluster.name: my-es-cluster...node.name: node1...network.host: 192.168.245.139...

#先进入ES安装路径su es //切换到之前创建的es用户bin/elasticsearch#bin/elasticsearch -d(也可以后台运行)

#创建indexcurl -XPUT http://192.168.5.222:9200/index_name/#删除indexcurl -XDELETE http://192.168.5.222:9200/index_name/#查看indexcurl -XGET http://192.168.5.222:9200/index_name/

#新增/更新Type(不在url的最后指定id的话，es会自动生成id)curl -XPOST http://192.168.5.222:9200/index_name/emp/1 -d ‘{"first_name" : "John","age" : 25,"about" : "I love to go rock climbing","interests": ["sports","music"]}‘#根据ID删除curl -XDELETE http://192.168.5.222:9200/index_name/emp/1#检索Typecurl -XGET http://192.168.5.222:9200/index_name/emp/1?pretty#查询所有字段curl –XGET http://192.168.5.222:9200/index_name/emp/1/_source#只返回部分字段curl -XGET http://192.168.5.222:9200/index_name/emp/1?_source=name,age#返回所有数据curl -XGET http://192.168.5.222:9200/index_name/emp/_search#简单的条件查询curl -XGET http://192.168.5.222:9200/index_name/emp/_search?q=first_name:Smith#条件删除curl -XDELETE ‘http://localhost:9200/index_name/emp,user/_query?q=user:kimchy‘#查看分词情况curl -XPOST http://192.168.5.222:9200/index_name/_analyze?pretty&analyzer=charSplit -d ‘商业核心和$标准化技术‘

POST 192.168.5.222:9200/yuqingtest/article/Content-Type: application/json{    "title" : "政协副主席建议提高境外黑匣子",    "content" : "使用了商业核心和$标准化技术，相比以前的非标$准化方案，更容易维护和支持哈哈有个黑匣子在外面。"}

{  "query": {    "multi_match": {      "query": "黑匣子",      "type": "phrase",      "slop": 1,      "fields": [        "content"      ],      "max_expansions": 1    }  },    "highlight" : {        "pre_tags" : ["<tag1>", "<tag2>"],        "post_tags" : ["</tag1>", "</tag2>"],        "fields" : {            "content" : {}        }    },    "sort":{        "createTime":{"order":"esc"}    }}

public interface ArticleRepository extends ElasticsearchRepository<ArticleEntity, String> {}

package com.ray.estest;import java.util.ArrayList;import java.util.List;import java.util.Map;import org.elasticsearch.action.search.SearchResponse;import org.elasticsearch.index.query.BoolQueryBuilder;import org.elasticsearch.index.query.QueryBuilders;import org.elasticsearch.index.query.RangeQueryBuilder;import org.elasticsearch.search.SearchHit;import org.elasticsearch.search.highlight.HighlightBuilder.Field;import org.elasticsearch.search.highlight.HighlightField;import org.elasticsearch.search.sort.SortBuilder;import org.elasticsearch.search.sort.SortBuilders;import org.elasticsearch.search.sort.SortOrder;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.data.domain.Page;import org.springframework.data.domain.PageRequest;import org.springframework.data.domain.Pageable;import org.springframework.data.elasticsearch.core.ElasticsearchTemplate;import org.springframework.data.elasticsearch.core.SearchResultMapper;import org.springframework.data.elasticsearch.core.aggregation.AggregatedPage;import org.springframework.data.elasticsearch.core.aggregation.impl.AggregatedPageImpl;import org.springframework.data.elasticsearch.core.query.NativeSearchQueryBuilder;import org.springframework.data.elasticsearch.core.query.SearchQuery;import com.product.yq_common.utils.StringUtils;import com.product.yq_service.entity.input.ArticleDetailInput;import com.product.yq_service.entity.input.ArticleQueryEntity;import com.product.yq_service.entity.output.ArticleSummaryInfoEntity;import com.product.yq_serviceimpl.entity.ArticleEntity;import com.product.yq_serviceimpl.repo.ArticleRepository;/** * @author Ray * 2017年3月30日 */public class ArticleServiceImpl {    @Autowired    private ArticleRepository repo;    @Autowired    private ElasticsearchTemplate elasticsearchTemplate;    public Object getArticles(ArticleQueryEntity entity) throws Exception {        List<ArticleSummaryInfoEntity> articles = new ArrayList<ArticleSummaryInfoEntity>();        // 分页        Pageable pager = new PageRequest(0, 10);        // 构建查询语句        BoolQueryBuilder qb = QueryBuilders.boolQuery().must(QueryBuilders.termQuery("deleted", false))                .must(QueryBuilders.termQuery("name", "Zhang"))// term一般用于not_analyzed                .must(QueryBuilders.matchQuery("favorite", entity.getType()));// match则用于analyzed        // 拼接条件        if (!StringUtils.isEmpty(entity.getSearchWord())) {            // multiMatchQuery 混合查询 同时检索多个字段            qb = qb.must(QueryBuilders.multiMatchQuery(entity.getSearchWord(), "title", "summary"));        }        if (!StringUtils.isEmpty(entity.getStartDate()) || !StringUtils.isEmpty(entity.getEndDate())) {            // 区间查询 gt,lt,gte,lte,from-to,            RangeQueryBuilder rqb = QueryBuilders.rangeQuery("createDate");            if (!StringUtils.isEmpty(entity.getStartDate())) {                rqb = rqb.gte(entity.getStartDate());            }            if (!StringUtils.isEmpty(entity.getEndDate())) {                rqb = rqb.lte(entity.getEndDate());            }            qb = qb.must(rqb);        }        // 排序(最好不要用字符串类型的Field做排序)        SortBuilder sort = SortBuilders.fieldSort("createTime").order(SortOrder.DESC);        // 开始组装        SearchQuery query = new NativeSearchQueryBuilder().withQuery(qb).withSort(sort).withPageable(pager).build();        // 返回的是带有分页数据的对象        Page<ArticleEntity> entities = repo.search(query);        long total = entities.getTotalElements();        int pages = entities.getTotalPages();        List<ArticleEntity> rst = entities.getContent();        return rst;    }    /**     * 更新     */    public void update(ArticleDetailInput entity) throws Exception {        ArticleEntity oriES = repo.findOne(entity.getArticleId());        oriES.setTitle(entity.getTitle());        oriES.setContent(entity.getContent());        repo.save(oriES);    }    /**     * 添加     */    public String add(ArticleDetailInput entity) throws Exception {        ArticleEntity oriES = new ArticleEntity();        oriES.setTitle("这是title");        oriES.setContent("这是content");        oriES = repo.save(oriES);        return oriES.getArticleId();// articleId映射ES中的ID    }    /**     * 获取详情     */    public Object detail(String id) throws Exception {        return repo.findOne(id);    }    /**     * 删除     */    public void delete(String id) throws Exception {        repo.delete(id);    }    /**     * 根据关键词进行搜索并返回高亮内容     */    public Object searchByWords(String word) throws Exception {        List<ArticleSummaryInfoEntity> articles = new ArrayList<ArticleSummaryInfoEntity>();        Pageable pager = new PageRequest(0, 10);        // 构建查询语句        BoolQueryBuilder qb = QueryBuilders.boolQuery().must(QueryBuilders.termQuery("deleted", false))                .must(QueryBuilders.multiMatchQuery(word, "title", "content"));        String preTags = "<span class=‘highlight‘>";        String postTags = "</span>";        // 设置要高亮的字段，高亮的前后标签，高亮内容的截取长度        Field fTitle = new Field("title").preTags(preTags).postTags(postTags).fragmentSize(100);        Field fContent = new Field("content").preTags(preTags).postTags(postTags).fragmentSize(100);        SearchQuery query = new NativeSearchQueryBuilder().withQuery(qb).withPageable(pager)                .withHighlightFields(fTitle, fContent).build();        elasticsearchTemplate.queryForPage(query, ArticleEntity.class, new SearchResultMapper() {            @SuppressWarnings("unchecked")            @Override            public <T> AggregatedPage<T> mapResults(SearchResponse response, Class<T> clazz, Pageable pageable) {                // 总个数                long total = response.getHits().getTotalHits();                // 总页数                int pages = (int) Math.ceil((double) total / pager.getPageSize());                if (response.getHits().getTotalHits() <= 0) {                    return null;                }                for (SearchHit searchHit : response.getHits()) {                    ArticleSummaryInfoEntity item = new ArticleSummaryInfoEntity();                    articles.add(item);                    Map<String, Object> source = searchHit.getSource();                    item.setArticleId(source.get("articleId").toString());                    Map<String, HighlightField> highlightFields = searchHit.getHighlightFields();                    // 查看高亮字段是否命中                    HighlightField hlTitleField = highlightFields.get("title");                    if (hlTitleField != null && hlTitleField.fragments() != null) {                        item.setTitle((hlTitleField.fragments()[0].string()));                    } else {                        item.setTitle((String) source.get("title"));                    }                    HighlightField hlContentField = highlightFields.get("content");                    if (hlContentField != null && hlContentField.fragments() != null) {                        item.setSummary(hlContentField.fragments()[0].string());                    } else {                        item.setSummary((String) source.get("summary"));                    }                }                return new AggregatedPageImpl<T>((List<T>) articles);            }        });        return articles;    }}

......// 构建查询语句BoolQueryBuilder qb = QueryBuilders.boolQuery().must(QueryBuilders.multiMatchQuery(search, "content").slop(1).type(Type.PHRASE));......