elasticsearch版本不同,批量查询也不相同
生活随笔
收集整理的這篇文章主要介紹了
elasticsearch版本不同,批量查询也不相同
小編覺得挺不錯的,現在分享給大家,幫大家做個參考.
網上搜到批量查詢可以通過TransportClient實現,但官方推薦使用RestHighLevelClient實現
注意:
We plan on deprecating the TransportClient in Elasticsearch 7.0 and removing it completely in 8.0. Instead, you should be using the Java High Level REST Client, which executes HTTP requests rather than serialized Java requests.查找最新的RestHighLevelClient api文檔
https://www.elastic.co/guide/en/elasticsearch/client/java-rest/6.5/java-rest-high-multi-search.html
MultiSearchRequest request = new MultiSearchRequest(); SearchRequest firstSearchRequest = new SearchRequest(); SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder(); searchSourceBuilder.query(QueryBuilders.matchQuery("user", "kimchy")); firstSearchRequest.source(searchSourceBuilder); request.add(firstSearchRequest); SearchRequest secondSearchRequest = new SearchRequest(); searchSourceBuilder = new SearchSourceBuilder(); searchSourceBuilder.query(QueryBuilders.matchQuery("user", "luca")); secondSearchRequest.source(searchSourceBuilder); request.add(secondSearchRequest); MultiSearchResponse response = client.msearch(request, RequestOptions.DEFAULT);但嘗試發現,沒有msearch這個方法,發現版本為6.1的 不支持這個方法
https://www.elastic.co/guide/en/elasticsearch/client/java-api/6.1/java-search-msearch.html
SearchRequestBuilder srb1 = client.prepareSearch().setQuery(QueryBuilders.queryStringQuery("elasticsearch")).setSize(1); SearchRequestBuilder srb2 = client.prepareSearch().setQuery(QueryBuilders.matchQuery("name", "kimchy")).setSize(1);MultiSearchResponse sr = client.prepareMultiSearch().add(srb1).add(srb2).get();// You will get all individual responses from MultiSearchResponse#getResponses() long nbHits = 0; for (MultiSearchResponse.Item item : sr.getResponses()) {SearchResponse response = item.getResponse();nbHits += response.getHits().getTotalHits(); }只能使用TransportClient來實現
import java.io.IOException; import java.net.InetAddress;import org.elasticsearch.action.search.MultiSearchResponse; import org.elasticsearch.action.search.MultiSearchResponse.Item; import org.elasticsearch.action.search.SearchRequest; import org.elasticsearch.client.transport.TransportClient; import org.elasticsearch.common.settings.Settings; import org.elasticsearch.common.transport.TransportAddress; import org.elasticsearch.search.builder.SearchSourceBuilder; import org.elasticsearch.transport.client.PreBuiltTransportClient;public class App4 {@SuppressWarnings("resource")public static void main(String[] args) throws IOException {TransportClient client=new PreBuiltTransportClient(Settings.EMPTY).addTransportAddress(new TransportAddress(InetAddress.getByName("127.0.0.1"), 9300)); //1st ES Node host and portSearchRequest req=new SearchRequest("person");SearchSourceBuilder builder=new SearchSourceBuilder();builder.size(10);req.source(builder);SearchRequest req1=new SearchRequest("posts");SearchSourceBuilder builder1=new SearchSourceBuilder();builder.size(10);req.source(builder1);MultiSearchResponse bulkResponse=client.prepareMultiSearch().add(req).add(req1).get();for (Item item : bulkResponse.getResponses()) {if (item.isFailure()) { System.out.println(item.getFailureMessage());}else {System.out.println("-----------------------------------------------------------------------");System.out.println(item.getResponse().toString());}}/**** Done ****/System.out.println("Done");}}?
轉載于:https://www.cnblogs.com/davidwang456/p/9965055.html
總結
以上是生活随笔為你收集整理的elasticsearch版本不同,批量查询也不相同的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: lucene源码分析(4)Similar
- 下一篇: 万亿级日志与行为数据存储查询技术剖析