使用netstat -lntp来看看有侦听在网络某端口的进程。当然，也可以使用 lsof。

[原创] ElasticSearch集群故障案例分析: 警惕通配符查询

Elasticsearch | 作者 kennywu76 | 发布于2017年05月11日 | | 阅读数：22824
分享到：QQ空间新浪微博微信QQ好友印象笔记有道云笔记
[携程旅行网： 吴晓刚]
 许多有RDBMS/SQL背景的开发者，在初次踏入ElasticSearch世界的时候，很容易就想到使用(Wildcard Query)来实现模糊查询（比如用户输入补全)，因为这是和SQL里like操作最相似的查询方式，用起来感觉非常舒适。然而近期我们线上一个搜索集群的故障揭示了，滥用wildcard query可能带来灾难性的后果。

故障经过
线上有一个10来台机器组成的集群，用于某个产品线的产品搜索。数据量并不大，实时更新量也不高，并发搜索量在几百次/s。通常业务高峰期cpu利用率不超过10%，系统负载看起来很低。 但最近这个集群不定期（1天或者隔几天)会出现CPU冲高到100%的问题，持续时间从1分钟到几分钟不等。最严重的一次持续了20来分钟，导致大量的用户搜索请无求响应，从而造成生产事故。

问题排查
细节太多，此处略过，直接给出CPU无故飙高的原因: 研发在搜索实现上，根据用户输入的关键词，在首尾加上通配符，使用wildcard query来实现模糊搜索，例如使用"*迪士尼*"来搜索含有“迪士尼”关键字的产品。 然而用户输入的字符串长度没有做限制，导致首尾通配符中间可能是很长的一个字符串。 后果就是对应的wildcard Query执行非常慢，非常消耗CPU。

复现方法
1. 创建一个只有一条文档的索引
POST test_index/type1/?refresh=true

{

  "foo": "bar"

}
2. 使用wildcard query执行一个首尾带有通配符*的长字符串查询
POST /test_index/_search

{

  "query": {

    "wildcard": {

      "foo": {

        "value": "*在迪士尼乐园，点亮心中奇梦。它是一个充满创造力、冒险精神与无穷精彩的快地。您可在此游览全球最大的迪士尼城堡——奇幻童话城堡，探索别具一格又令人难忘的六大主题园区——米奇大街、奇想花园、梦幻世界、探险岛、宝藏湾和明日世界，和米奇朋友在一起，感觉欢乐时光开业于2016年上海国际旅游度假区秀沿路亚朵酒店位于上海市浦东新区沪南公路（沪南公路与秀沿路交汇处），临近周浦万达广场、地铁11号线秀沿路站，距离上海南站、人民广场约20公里，距离迪线距*"

      }

    }

  }

}
3. 查看结果
{

  "took": 3445,

  "timed_out": false,

  "_shards": {

    "total": 5,

    "successful": 5,

    "failed": 0

  },

  "hits": {

    "total": 0,

    "max_score": null,

    "hits": 

  }

}
即使no hits，耗时却是惊人的3.4秒 (测试机是macbook pro, i7 CPU)，并且执行过程中，CPU有一个很高的尖峰。
 
线上的查询比我这个范例要复杂得多，会同时查几个字段，实际测试下来，一个查询可能会执行十几秒钟。 在有比较多长字符串查询的时候，集群可能就DOS了。

探查深层次根源
为什么对只有一条数据的索引做这个查询开销这么高？ 直觉上应该是瞬间返回结果才对!

回答这个问题前，可以再做个测试，如果继续加大查询字符串的长度，到了一定长度后，ES直接抛异常了，服务器ES里异常给出的cause如下:


 
Caused by: org.apache.lucene.util.automaton.TooComplexToDeterminizeException: Determinizing automaton with 22082 states and 34182 transitions would result in more than 10000 states. at org.apache.lucene.util.automaton.Operations.determinize(Operations.java:741) ~[lucene-core-6.4.1.jar:6.4.1
 


该异常来自org.apache.lucene.util.automaton这个包，异常原因的字面含义是说“自动机过于复杂而无法确定状态： 由于状态和转换太多，确定一个自动机需要生成的状态超过10000个上限"

网上查找了大量资料后，终于搞清楚了问题的来龙去脉。为了加速通配符和正则表达式的匹配速度，Lucene4.0开始会将输入的字符串模式构建成一个DFA (Deterministic Finite Automaton)，带有通配符的pattern构造出来的DFA可能会很复杂，开销很大。这个链接的博客using-dfa-for-wildcard-matching-problem比较形象的介绍了如何为一个带有通配符的pattern构建DFA。借用博客里的范例，a*bc构造出来的DFA如下图:

屏幕快照_2017-05-11_18.56_.06_.png


Lucene构造DFA的实现
看了一下Lucene的里相关的代码，构建过程大致如下:
1. org.apache.lucene.search.WildcardQuery里的toAutomaton方法，遍历输入的通配符pattern，将每个字符变成一个自动机(automaton)，然后将每个字符的自动机链接起来生成一个新的自动机
public static Automaton toAutomaton(Term wildcardquery) {

    List<Automaton> automata = new ArrayList<>();

    

    String wildcardText = wildcardquery.text();

    

    for (int i = 0; i < wildcardText.length();) {

      final int c = wildcardText.codePointAt(i);

      int length = Character.charCount(c);

      switch(c) {

        case WILDCARD_STRING: 

          automata.add(Automata.makeAnyString());

          break;

        case WILDCARD_CHAR:

          automata.add(Automata.makeAnyChar());

          break;

        case WILDCARD_ESCAPE:

          // add the next codepoint instead, if it exists

          if (i + length < wildcardText.length()) {

            final int nextChar = wildcardText.codePointAt(i + length);

            length += Character.charCount(nextChar);

            automata.add(Automata.makeChar(nextChar));

            break;

          } // else fallthru, lenient parsing with a trailing \

        default:

          automata.add(Automata.makeChar(c));

      }

      i += length;

    }

    

    return Operations.concatenate(automata);

  }
2. 此时生成的状态机是不确定状态机，也就是Non-deterministic Finite Automaton（NFA)。
3. org.apache.lucene.util.automaton.Operations类里的determinize方法则会将NFA转换为DFA  
/**

   * Determinizes the given automaton.

   * <p>

   * Worst case complexity: exponential in number of states.

   * @param maxDeterminizedStates Maximum number of states created when

   *   determinizing.  Higher numbers allow this operation to consume more

   *   memory but allow more complex automatons.  Use

   *   DEFAULT_MAX_DETERMINIZED_STATES as a decent default if you don't know

   *   how many to allow.

   * @throws TooComplexToDeterminizeException if determinizing a creates an

   *   automaton with more than maxDeterminizedStates

   */

  public static Automaton determinize(Automaton a, int maxDeterminizedStates) {
 代码注释里说这个过程的时间复杂度最差情况下是状态数量的指数级别！为防止产生的状态过多，消耗过多的内存和CPU，类里面对最大状态数量做了限制
  /**

   * Default maximum number of states that {@link Operations#determinize} should create.

   */

  public static final int DEFAULT_MAX_DETERMINIZED_STATES = 10000;
在有首尾通配符，并且字符串很长的情况下，这个determinize过程会产生大量的state，甚至会超过上限。
 
至于NFA和DFA的区别是什么？ 如何相互转换？ 网上有很多数学层面的资料和论文，限于鄙人算法方面有限的知识，无精力去深入探究。 但是一个粗浅的理解是: NFA在输入一个条件的情况下，可以从一个状态转移到多种状态，而DFA只会有一个确定的状态可以转移，因此DFA在字符串匹配时速度更快。 DFA虽然搜索的时候快，但是构造方面的时间复杂度可能比较高，特别是带有首部通配符+长字符串的时候。

回想Elasticsearch官方文档里对于wildcard query有特别说明，要避免使用通配符开头的term。


" Note that this query can be slow, as it needs to iterate over many terms. In order to prevent extremely slow wildcard queries, a wildcard term should not start with one of the wildcards * or ?."



结合对上面wildcard query底层实现的探究，也就不难理解这句话的含义了！

总结： wildcard query应杜绝使用通配符打头，实在不得已要这么做，就一定需要限制用户输入的字符串长度。 最好换一种实现方式，通过在index time做文章，选用合适的分词器，比如nGram tokenizer预处理数据，然后使用更廉价的term query来实现同等的模糊搜索功能。 对于部分输入即提示的应用场景，可以考虑优先使用completion suggester, phrase/term suggeter一类性能更好,模糊程度略差的方式查询，待suggester没有匹配结果的时候，再fall back到更模糊但性能较差的wildcard, regex, fuzzy一类的查询。
 
-----------
补记： 有同学问regex, fuzzy query是否有同样的问题，答案是有，原因在于他们底层和wildcard一样，都是通过将pattern构造成DFA来加速字符串匹配速度的。 
[尊重社区原创，转载请保留或注明出处]
本文地址：http://elasticsearch.cn/article/171
20
fanmo3yuan medcl maerkov BrickXu denghc0607 venyowang Yuna Loading Zhang anson snows shjdwxy java_mr wutiancheng hanxiaobei Javmain yanyl sardineYJA xiongge.club cccthought huangzhiwei

12 个评论

maerkov

maerkov

太牛了膜拜
2017-05-12 10:55
tiantian

tiantian

您好，这个分享太及时了，我们的模糊搜索也有类似的问题，搜索字段设置都是not_analyzed的，搜索的时候都是在字符串前后加了通配符 “ * ”, 查询确实很慢。 现在看了您的分享，也只想到了限制字符串长度来缓解es集群压力，没有想到更好的办法来优化， 看lucene里介绍说有用suffix query来解决这个问题的，但是es里没有这个查询。 不知道您那有没有更好的方案？ 多谢
2017-05-14 12:14
kennywu76

kennywu76 回复 tiantian

如果搜索的是字符串，比如邮政编码， 商品编号一类的，或者英文单词的部分匹配，可以使用ngrams对字符串分成多个terms，然后使用terms query，参考https://www.elastic.co/guide/en/elasticsearch/guide/2.x/_ngrams_for_partial_matching.html

但如果是对语句做部分匹配，比如中文句子，那么应该是采用分词器将句子分成词，再配合term query.
2017-05-14 22:51
tiantian

tiantian 回复 kennywu76

多谢啦， 我们是对中文句子做模糊搜索，类似聊天记录查找， 回头我试一下，看看效果怎么样
2017-05-15 07:54
denghc0607

denghc0607

好文章!!!mark!!!!!
2017-05-18 14:43
chenshoulu

chenshoulu

不错不错
2017-07-11 14:17
jackyyin

jackyyin

我们最近也遇到这个问题了，不过之前不知道es有这个问题，通过jvm的角度定位到cpu消耗最高的线程，确实就是在lucene里面的automation这一块，下面是线程堆栈.

- java.lang.Integer.valueOf(int) @bci=23, line=832 (Compiled frame)
- org.apache.lucene.util.automaton.Operations$PointTransitionSet.find(int) @bci=8, line=596 (Compiled frame)
- org.apache.lucene.util.automaton.Operations$PointTransitionSet.add(org.apache.lucene.util.automaton.Transition) @bci=5, line=637 (Compiled frame)
- org.apache.lucene.util.automaton.Operations.determinize(org.apache.lucene.util.automaton.Automaton, int) @bci=198, line=714 (Compiled frame)
- org.apache.lucene.util.automaton.Operations.getCommonSuffixBytesRef(org.apache.lucene.util.automaton.Automaton, int) @bci=5, line=1165 (Compiled frame)
- org.apache.lucene.util.automaton.CompiledAutomaton.<init>(org.apache.lucene.util.automaton.Automaton, java.lang.Boolean, boolean, int, boolean) @bci=329, line=238 (Compiled frame)
- org.apache.lucene.search.AutomatonQuery.<init>(org.apache.lucene.index.Term, org.apache.lucene.util.automaton.Automaton, int, boolean) @bci=29, line=103 (Compiled frame)
- org.apache.lucene.search.AutomatonQuery.<init>(org.apache.lucene.index.Term, org.apache.lucene.util.automaton.Automaton, int) @bci=5, line=81 (Compiled frame)
- org.apache.lucene.search.AutomatonQuery.<init>(org.apache.lucene.index.Term, org.apache.lucene.util.automaton.Automaton) @bci=6, line=65 (Compiled frame)
- org.apache.lucene.search.WildcardQuery.<init>(org.apache.lucene.index.Term) @bci=6, line=57 (Compiled frame)
- org.elasticsearch.index.query.WildcardQueryParser.parse(org.elasticsearch.index.query.QueryParseContext) @bci=352, line=104 (Compiled frame)
- org.elasticsearch.common.xcontent.json.JsonXContentParser.nextToken() @bci=5, line=53 (Compiled frame)
- org.elasticsearch.index.query.QueryParseContext.parseInnerQuery() @bci=230, line=253 (Compiled frame)
- org.elasticsearch.index.query.BoolQueryParser.parse(org.elasticsearch.index.query.QueryParseContext) @bci=769, line=129 (Compiled frame)
- org.elasticsearch.common.xcontent.json.JsonXContentParser.nextToken() @bci=5, line=53 (Compiled frame)
- org.elasticsearch.index.query.QueryParseContext.parseInnerQuery() @bci=230, line=253 (Compiled frame)
- org.elasticsearch.index.query.BoolQueryParser.parse(org.elasticsearch.index.query.QueryParseContext) @bci=719, line=120 (Compiled frame)
- org.elasticsearch.common.xcontent.json.JsonXContentParser.nextToken() @bci=5, line=53 (Compiled frame)
- org.elasticsearch.index.query.QueryParseContext.parseInnerQuery() @bci=230, line=253 (Compiled frame)
- org.elasticsearch.index.query.IndexQueryParserService.innerParse(org.elasticsearch.index.query.QueryParseContext, org.elasticsearch.common.xcontent.XContentParser) @bci=19, line=324 (Compiled frame)
- org.elasticsearch.index.query.IndexQueryParserService.parse(org.elasticsearch.index.query.QueryParseContext, org.elasticsearch.common.xcontent.XContentParser) @bci=3, line=224 (Compiled frame)
- org.elasticsearch.index.query.IndexQueryParserService.parse(org.elasticsearch.common.xcontent.XContentParser) @bci=12, line=219 (Compiled frame)
- org.elasticsearch.search.query.QueryParseElement.parse(org.elasticsearch.common.xcontent.XContentParser, org.elasticsearch.search.internal.SearchContext) @bci=6, line=33 (Compiled frame)
- org.elasticsearch.common.xcontent.json.JsonXContentParser.nextToken() @bci=5, line=53 (Compiled frame)
- org.elasticsearch.search.SearchService.parseSource(org.elasticsearch.search.internal.SearchContext, org.elasticsearch.common.bytes.BytesReference) @bci=67, line=848 (Compiled frame)
- org.elasticsearch.search.SearchService.createContext(org.elasticsearch.search.internal.ShardSearchRequest, org.elasticsearch.index.engine.Engine$Searcher) @bci=184, line=667 (Compiled frame)
- org.elasticsearch.search.SearchService.createAndPutContext(org.elasticsearch.search.internal.ShardSearchRequest) @bci=3, line=633 (Compiled frame)
- org.elasticsearch.search.SearchService.executeQueryPhase(org.elasticsearch.search.internal.ShardSearchRequest) @bci=2, line=377 (Compiled frame)
- org.elasticsearch.search.action.SearchServiceTransportAction$SearchQueryTransportHandler.messageReceived(org.elasticsearch.search.internal.ShardSearchTransportRequest, org.elasticsearch.transport.TransportCha
nnel) @bci=8, line=368 (Compiled frame)
- org.elasticsearch.search.action.SearchServiceTransportAction$SearchQueryTransportHandler.messageReceived(org.elasticsearch.transport.TransportRequest, org.elasticsearch.transport.TransportChannel) @bci=6, lin
e=365 (Compiled frame)
- org.elasticsearch.transport.TransportRequestHandler.messageReceived(org.elasticsearch.transport.TransportRequest, org.elasticsearch.transport.TransportChannel, org.elasticsearch.tasks.Task) @bci=3, line=33 (C
ompiled frame)
- org.elasticsearch.transport.RequestHandlerRegistry.processMessageReceived(org.elasticsearch.transport.TransportRequest, org.elasticsearch.transport.TransportChannel) @bci=57, line=77 (Compiled frame)
- org.elasticsearch.transport.netty.MessageChannelHandler$RequestHandler.doRun() @bci=12, line=293 (Compiled frame)
- org.elasticsearch.common.util.concurrent.AbstractRunnable.run() @bci=1, line=37 (Compiled frame)
- java.util.concurrent.ThreadPoolExecutor.runWorker(java.util.concurrent.ThreadPoolExecutor$Worker) @bci=95, line=1142 (Compiled frame)
- java.util.concurrent.ThreadPoolExecutor$Worker.run() @bci=5, line=617 (Interpreted frame)
- java.lang.Thread.run() @bci=11, line=745 (Interpreted frame)
2017-12-20 10:46
smile_sunshine

smile_sunshine

膜拜，解答了我非常疑惑之问题。非常感谢分享！
2018-11-27 08:59
wutiancheng

wutiancheng

感谢大佬，文章分析的到位！刚好解决了我的一个问题！！！
2019-06-17 11:40
UnigroupAi

UnigroupAi

https://blog.csdn.net/qq_35190492/article/details/103396661
这个文章给你这个90%的雷同，是被抄袭了嘛
2021-12-27 11:47
kennywu76

kennywu76 回复 UnigroupAi

很明显抄袭了我的原文，对比下文章发表日期。
2022-01-04 16:39
UnigroupAi

UnigroupAi 回复 kennywu76

是啊，我就是提醒一下大佬要有维权意识啊
2022-03-24 10:57

要回复文章请先登录或注册

Copyright © 2024 · CC BY-NC-SA 3.0

本站服务器及带宽由 提供赞助