网站建设总结ppt,html静态网站开发个人博客,八大员考试报名官网,wordpress邮箱验证登录页面Java客户端调用elasticsearch进行深度分页查询 #xff08;search_after#xff09; 一. 代码二. 测试结果 前言 这是我在这个网站整理的笔记,有错误的地方请指出#xff0c;关注我#xff0c;接下来还会持续更新。 作者#xff1a;神的孩子都在歌唱 具体的Search_after解… Java客户端调用elasticsearch进行深度分页查询 search_after 一. 代码二. 测试结果 前言 这是我在这个网站整理的笔记,有错误的地方请指出关注我接下来还会持续更新。 作者神的孩子都在歌唱 具体的Search_after解释可以看我这篇文章 elasticsearch 深度分页查询 Search_after图文教程 一. 代码
public class Test {public static void main(String[] args) throws IOException {// 创建客户端final CredentialsProvider credentialsProvider new BasicCredentialsProvider();credentialsProvider.setCredentials(AuthScope.ANY,new UsernamePasswordCredentials(elastic, chenyunzhi));// 跳过ssl验证SSLFactory sslFactory SSLFactory.builder().withUnsafeTrustMaterial().withUnsafeHostnameVerifier().build();RestClientBuilder builder RestClient.builder(new HttpHost(192.168.1.47, 9200,https)).setHttpClientConfigCallback(new RestClientBuilder.HttpClientConfigCallback() {Overridepublic HttpAsyncClientBuilder customizeHttpClient(HttpAsyncClientBuilder httpClientBuilder) {return httpClientBuilder.setSSLContext(sslFactory.getSslContext()).setSSLHostnameVerifier(sslFactory.getHostnameVerifier()).setDefaultCredentialsProvider(credentialsProvider);}});// Create the transport with a Jackson mapperElasticsearchTransport transport new RestClientTransport(builder.build(), new JacksonJsonpMapper());// 客户端连接ElasticsearchClient client new ElasticsearchClient(transport);// 创建pitOpenPointInTimeRequest.Builder build new OpenPointInTimeRequest.Builder();OpenPointInTimeRequest.Builder builder1 build.index(test-000005).keepAlive(new Time.Builder().time(1m).build());OpenPointInTimeResponse openPointInTimeResponse client.openPointInTime(builder1.build());String id openPointInTimeResponse.id();// 构造查询条件SearchRequest.Builder sort new SearchRequest.Builder().size(5).pit(p-p.id(id).keepAlive(k-k.time(1m))).sort(s - s.field(f - f.field(name.keyword).order(SortOrder.Desc)));// 获取第一次查询的结果ListHitHashMap hits client.search(sort.build(), HashMap.class).hits().hits();// 检查 hits 列表是否为空if (!hits.isEmpty()) {// 获取最后一个值的sortListString sort1 hits.get(hits.size() - 1).sort();// 再次构造查询条件 加上searchAftersort new SearchRequest.Builder().size(5).pit(p-p.id(id).keepAlive(k-k.time(1m))).searchAfter(sort1).sort(s - s.field(f - f.field(name.keyword).order(SortOrder.Desc)));ListHitHashMap hits1 client.search(sort.build(), HashMap.class).hits().hits();System.out.println(-------------------------第一次查询结果-------------------------);System.out.println(hits);System.out.println(-------------------------最后一个值的sort-------------------------);System.out.println(sort1);System.out.println(-------------------------第二次查询结果-------------------------);System.out.println(hits1);}// 关闭client.closePointInTime(c-c.id(id));transport.close();}
}二. 测试结果 参考https://blog.csdn.net/qq_44056652/article/details/126341810 作者神的孩子都在歌唱 本人博客https://blog.csdn.net/weixin_46654114 转载说明务必注明来源附带本人博客连接。
