使用Java客户端的Elasticsearch查询序列化

Question

我正在使用官方的Elasticsearch Java客户端。它工作得很好，但不幸的是，它的对象没有实现可序列化的接口。我特别需要序列化QueryBuilder的实例。

我发现了两种使用客户端序列化对象的方法。其中之一就是使用QueryBuilder。writeTo（）。另一个是使用：

Strings.toString(queryBuilder.toXContent(XContentFactory.jsonBuilder(), ToXContent.EMPTY_PARAMS))

但是我找不到如何在这两种情况下反序列化对象。

我也不确定这是否是解决这项任务的最佳方式。

Answer 1

最后，我得到了以下代码：

序列化：

// wrap query with source to deserialize any type of query
SearchSourceBuilder query = new SearchSourceBuilder().query(this.query);

String sourceJson = Strings.toString(query);

反序列化：

private static final NamedXContentRegistry xContentRegistry;

static {
    SearchModule searchModule =
        new SearchModule(Settings.EMPTY, false, Collections.emptyList());

    xContentRegistry =
        new NamedXContentRegistry(searchModule.getNamedXContents());
}

...

XContentParser parser =
        XContentType.JSON.xContent().createParser(xContentRegistry,
                                                  LoggingDeprecationHandler.INSTANCE,
                                                  sourceJson);

SearchSourceBuilder sourceBuilder = SearchSourceBuilder.fromXContent(parser);

this.query = sourceBuilder.query();

因此，您可以将此代码添加到readObject（）和WriteObject（）方法中，为ES查询对象提供（反）序列化。

使用Elasticsearch 7.5.1客户端库实现。