使用 Java 客户端通过 HTTPS 连接到 Easysearch

Easysearch 一直致力于提高易用性,这也是我们的核心宗旨,然而之前一直没有官方的 Java 客户端,也对用户使用造成了一些困扰,现在,我们正式发布了第一个 Java 客户端 Easysearch-client:1.0.1

这一里程碑式的更新为开发人员带来了前所未有的便利性,使得与 Easysearch 集群的交互变得更加简洁和直观。通过 Easysearch-client,开发者可以直接使用 Java 方法和数据结构来进行交互,而不再需要依赖于传统的 HTTP 方法和 JSON。
这一变化大大简化了操作流程,使得数据管理和索引更加高效。Java 客户端的功能范围包括处理数据操作,管理集群,包括查看和维护集群的健康状态,并对 Security 模块全面兼容。它提供了一系列 API,用于管理角色、用户、权限、角色映射和账户。
这意味着安全性和访问控制现在可以更加细粒度地管理,确保了数据的安全性和合规性。

在这篇博客中,你将学习如何配置 Easysearch-client 客户端以通过 HTTPS 连接到 Easysearch。为了演示目的,我将首先设置一个带有 SSL 证书的 Easysearch 服务器。如果你已经有一个在运行,你可以跳过这一步。
接下来,我将引导你完成在 Java 应用程序中配置和使用 Java 客户端的步骤。

设置 Easysearch 服务器

首先从极限科技官网下载最新的 Mac 版本。我使用的是 1.6.1 版本,这是我写这篇文章时的最新版本。

wget https://dl-global.infinilabs.com/easysearch/stable/easysearch-1.6.1-214-mac-amd64.zip

确保您的系统已经安装并设置了 java 环境变量,版本在 11 以上。

解压下载文件。

unzip easysearch-1.6.1-214-mac-amd64.zip -d easysearch-1.6.1

cd 到 easysearch-1.6.1 执行初始化脚本来生成证书并自动下载插件。

 bin/initialize.sh

脚本执行后会自动输出随机生成的 admin 用户密码。

启动 Easysearch

bin/easysearch

此时,您的服务器已经准备就绪。您可以查看 logs/initialize.log 里显示的 curl 命令来进行验证。

curl -ku admin:xxxxxxxxx https://localhost:9200

显示类似的输出响应

{"name" : "MacBook-Pro.local","cluster_name" : "easysearch","cluster_uuid" : "1gRYQ6ssTiKGqcyuEN0Dbg","version" : {"distribution" : "easysearch","number" : "1.6.1","distributor" : "INFINI Labs","build_hash" : "14846e460e9976ba6d68c80bb9eca52af1179dcf","build_date" : "2023-10-19T14:43:02.636639Z","build_snapshot" : false,"lucene_version" : "8.11.2","minimum_wire_lucene_version" : "7.7.0","minimum_lucene_index_compatibility_version" : "7.7.0"},"tagline" : "You Know, For Easy Search!"
}

下面我们来看如何设置和使用客户端。

设置 Java 客户端

Easysearch 的 Java 客户端可在 中央仓库:https://repo1.maven.org/maven2/ 上获得。将其作为依赖项添加到你的 Java 应用程序中。
对于 Gradle 构建系统,在项目的 build.gradle 文件中包含以下依赖项:

dependencies {implementation 'com.infinilabs:easysearch-client:1.0.1'implementation "org.apache.logging.log4j:log4j-api:2.19.0"implementation "org.apache.logging.log4j:log4j-core:2.19.0"implementation 'org.apache.httpcomponents:httpclient:4.5.10'implementation 'org.apache.httpcomponents:httpcore-nio:4.4.12'implementation 'org.apache.httpcomponents:httpasyncclient:4.1.4'implementation 'joda-time:joda-time:2.10.4'implementation ('org.apache.lucene:lucene-core:8.11.2') {exclude group: '*', module: '*'}implementation ('org.apache.lucene:lucene-analyzers-common:8.11.2') {exclude group: '*', module: '*'}implementation ('org.apache.lucene:lucene-backward-codecs:8.11.2') {exclude group: '*', module: '*'}implementation ('org.apache.lucene:lucene-grouping:8.11.2') {exclude group: '*', module: '*'}implementation ('org.apache.lucene:lucene-highlighter:8.11.2') {exclude group: '*', module: '*'}implementation ('org.apache.lucene:lucene-join:8.11.2') {exclude group: '*', module: '*'}implementation ('org.apache.lucene:lucene-memory:8.11.2') {exclude group: '*', module: '*'}implementation ('org.apache.lucene:lucene-misc:8.11.2') {exclude group: '*', module: '*'}implementation ('org.apache.lucene:lucene-queries:8.11.2') {exclude group: '*', module: '*'}implementation ('org.apache.lucene:lucene-queryparser:8.11.2') {exclude group: '*', module: '*'}implementation ('org.apache.lucene:lucene-sandbox:8.11.2') {exclude group: '*', module: '*'}implementation ('org.apache.lucene:lucene-spatial3d:8.11.2') {exclude group: '*', module: '*'}implementation ('org.apache.lucene:lucene-suggest:8.11.2') {exclude group: '*', module: '*'}......
}

对于 Maven 构建系统,在项目的 pom.xml 文件中包含以下依赖项:

<dependencies><dependency><groupId>com.infinilabs</groupId><artifactId>easysearch-client</artifactId><version>1.0.1</version></dependency><dependency><groupId>org.apache.httpcomponents</groupId><artifactId>httpclient</artifactId><version>4.5.10</version></dependency><dependency><groupId>org.apache.httpcomponents</groupId><artifactId>httpcore-nio</artifactId><version>4.4.12</version></dependency><dependency><groupId>org.apache.httpcomponents</groupId><artifactId>httpasyncclient</artifactId><version>4.1.4</version></dependency><dependency><groupId>joda-time</groupId><artifactId>joda-time</artifactId><version>2.10.4</version></dependency><dependency><groupId>org.apache.lucene</groupId><artifactId>lucene-core</artifactId><version>8.11.2</version><scope>compile</scope><exclusions><exclusion><artifactId>*</artifactId><groupId>*</groupId></exclusion></exclusions></dependency><dependency><groupId>org.apache.lucene</groupId><artifactId>lucene-analyzers-common</artifactId><version>8.11.2</version><scope>compile</scope><exclusions><exclusion><artifactId>*</artifactId><groupId>*</groupId></exclusion></exclusions></dependency><dependency><groupId>org.apache.lucene</groupId><artifactId>lucene-backward-codecs</artifactId><version>8.11.2</version><scope>compile</scope><exclusions><exclusion><artifactId>*</artifactId><groupId>*</groupId></exclusion></exclusions></dependency><dependency><groupId>org.apache.lucene</groupId><artifactId>lucene-grouping</artifactId><version>8.11.2</version><scope>compile</scope><exclusions><exclusion><artifactId>*</artifactId><groupId>*</groupId></exclusion></exclusions></dependency><dependency><groupId>org.apache.lucene</groupId><artifactId>lucene-highlighter</artifactId><version>8.11.2</version><scope>compile</scope><exclusions><exclusion><artifactId>*</artifactId><groupId>*</groupId></exclusion></exclusions></dependency><dependency><groupId>org.apache.lucene</groupId><artifactId>lucene-join</artifactId><version>8.11.2</version><scope>compile</scope><exclusions><exclusion><artifactId>*</artifactId><groupId>*</groupId></exclusion></exclusions></dependency><dependency><groupId>org.apache.lucene</groupId><artifactId>lucene-memory</artifactId><version>8.11.2</version><scope>compile</scope><exclusions><exclusion><artifactId>*</artifactId><groupId>*</groupId></exclusion></exclusions></dependency><dependency><groupId>org.apache.lucene</groupId><artifactId>lucene-misc</artifactId><version>8.11.2</version><scope>compile</scope><exclusions><exclusion><artifactId>*</artifactId><groupId>*</groupId></exclusion></exclusions></dependency><dependency><groupId>org.apache.lucene</groupId><artifactId>lucene-queries</artifactId><version>8.11.2</version><scope>compile</scope><exclusions><exclusion><artifactId>*</artifactId><groupId>*</groupId></exclusion></exclusions></dependency><dependency><groupId>org.apache.lucene</groupId><artifactId>lucene-queryparser</artifactId><version>8.11.2</version><scope>compile</scope><exclusions><exclusion><artifactId>*</artifactId><groupId>*</groupId></exclusion></exclusions></dependency><dependency><groupId>org.apache.lucene</groupId><artifactId>lucene-sandbox</artifactId><version>8.11.2</version><scope>compile</scope><exclusions><exclusion><artifactId>*</artifactId><groupId>*</groupId></exclusion></exclusions></dependency><dependency><groupId>org.apache.lucene</groupId><artifactId>lucene-spatial3d</artifactId><version>8.11.2</version><scope>compile</scope><exclusions><exclusion><artifactId>*</artifactId><groupId>*</groupId></exclusion></exclusions></dependency><dependency><groupId>org.apache.lucene</groupId><artifactId>lucene-suggest</artifactId><version>8.11.2</version><scope>compile</scope><exclusions><exclusion><artifactId>*</artifactId><groupId>*</groupId></exclusion></exclusions></dependency>
</dependencies>

接下来,在你的 Java 应用程序中创建一个 client 实例,并使用它在 Easysearch 中创建索引并插入一些数据。但在此之前,为了使其工作,你需要将签署服务器证书的根机构证书添加到你的应用程序信任库中。让我们看看如何配置 Java 应用程序的信任库。

为了使用 java client,你需要将根 CA 证书 ca.crt 添加到应用程序信任库中。这告诉你的 Java 应用程序信任由此根机构签署的任何证书。easysearch-1.6.1/config/ 目录下已经生成了 ca.crt 文件。你可以将其添加到自定义信任库中,并在 Java 应用程序中使用该自定义信任库。

使用 Java keytool 创建一个自定义信任库并导入证书。keytool 不理解 .pem 格式,所以你需要首先使用 openssl 加密库将证书转换为 .der 格式,然后使用 Java keytool 将其添加到自定义信任库中。假设您的操作系统已经预装了 openssl。

第 1 步:将 CA 证书从 .pem 格式转换为 .der 格式。

openssl x509 -in easysearch-1.6.1/config/ca.crt -inform pem -out ca.der --outform der

第 2 步:创建自定义信任库并添加 ca.der 证书。
将 ca 证书添加到应用程序信任库中,表示应用程序信任由此 CA 签署的任何证书。

keytool -import -file ca.der -alias easysearch -keystore myTrustStore

过程中会提示您输入密钥库口令: 我为了测试用输入的 123456。

通过列出信任库中的证书来确认操作成功,这里的 123456 是我上面设置的密码,会显示出 easysearch 证书。

keytool -keystore myTrustStore -storepass 123456 -list

第 3 步:在 Java 应用程序代码中设置指向自定义信任库的系统属性,并连接集群,创建索引,插入数据。
可以通过设置系统属性,以指定 SSL/TLS 通信时使用的信任库:

 System.setProperty("javax.net.ssl.trustStore", "/full/path/to/myTrustStore");
System.setProperty("javax.net.ssl.trustStorePassword", "123456");HttpHost[] httpHostArray = new HttpHost[1];
// infini.cloud 和 CN=infini.cloud 保持一致
httpHostArray[0] = new HttpHost("infini.cloud", 9200, "https");
final CredentialsProvider credentialsProvider = new BasicCredentialsProvider();
credentialsProvider.setCredentials(AuthScope.ANY, new UsernamePasswordCredentials("admin", "1933791fb2b9f6c6146d"));RestHighLevelClient client = new RestHighLevelClient(RestClient.builder(httpHostArray).setHttpClientConfigCallback((HttpAsyncClientBuilder httpAsyncClientBuilder) -> {httpAsyncClientBuilder.setDefaultCredentialsProvider(credentialsProvider);return httpAsyncClientBuilder;}));CreateIndexRequest createIndexRequest = new CreateIndexRequest("test-index");
createIndexRequest.settings(Settings.builder().put("index.number_of_shards", 1).put("index.number_of_replicas", 1)
);//Create index
client.indices().create(createIndexRequest, RequestOptions.DEFAULT);// Bulk
BulkRequest bulkRequest = new BulkRequest();
for (int i = 0; i < 10; i++) {IndexRequest indexRequest = new IndexRequest("test-index").id(Integer.toString(i)).source("{\"field1\":\"value" + i + "\"}", XContentType.JSON);bulkRequest.add(indexRequest);
}BulkResponse bulkResponse = client.bulk(bulkRequest, RequestOptions.DEFAULT);
System.out.println(Strings.toString(bulkResponse));

信任已签署 Easysearch 正在使用的证书的 CA 的示例,当 CA 证书以 PEM 编码文件的形式可用时:

Path caCertificatePath = Paths.get("/easysearch-test/easysearch-1.6.1/config/ca.crt");
CertificateFactory factory = CertificateFactory.getInstance("X.509");
Certificate trustedCa;
try (InputStream is = Files.newInputStream(caCertificatePath)) {trustedCa = factory.generateCertificate(is);
}
KeyStore trustStore = KeyStore.getInstance("pkcs12");
trustStore.load(null, null);
trustStore.setCertificateEntry("ca", trustedCa);
SSLContextBuilder sslContextBuilder = SSLContexts.custom().loadTrustMaterial(trustStore, null);
final SSLContext sslContext = sslContextBuilder.build();HttpHost[] httpHostArray = new HttpHost[1];
httpHostArray[0] = new HttpHost("infini.cloud", 9200, "https");
final CredentialsProvider credentialsProvider = new BasicCredentialsProvider();
credentialsProvider.setCredentials(AuthScope.ANY, new UsernamePasswordCredentials("admin", "1933791fb2b9f6c6146d"));RestHighLevelClient client = new RestHighLevelClient(RestClient.builder(httpHostArray).setHttpClientConfigCallback((HttpAsyncClientBuilder httpAsyncClientBuilder) -> {httpAsyncClientBuilder.setDefaultCredentialsProvider(credentialsProvider);httpAsyncClientBuilder.setSSLContext(sslContext);return httpAsyncClientBuilder;}));

现在,您已经成功设置了 Java 客户端,并以安全的 HTTPS 通道连接到了 Easysearch 集群。除此之外,Java 客户端还具备强大的权限控制管理 API,具体请参考我们的官网文档:https://www.infinilabs.com/docs/latest/easysearch/references/client/security/

关于 Easysearch

about easysearch

INFINI Easysearch 是一个分布式的近实时搜索与分析引擎,核心引擎基于开源的 Apache Lucene。Easysearch 的目标是提供一个轻量级的 Elasticsearch 可替代版本,并继续完善和支持更多的企业级功能。 与 Elasticsearch 相比,Easysearch 更关注在搜索业务场景的优化和继续保持其产品的简洁与易用性。

官网文档:https://www.infinilabs.com/docs/latest/easysearch

下载地址:https://www.infinilabs.com/download

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/172224.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

成为AI产品经理——TPR、FPR、ROC、AUC

目录 一、PR图、BEP 1.PR图 2.BEP 二、灵敏度、特异度 1.灵敏度 2.特异度 三、真正率、假正率 1.真正率 2.假正率 三、ROC、AUC 1.ROC 2.AUC 四、KS值 一、PR图、BEP 1.PR图 二分类问题模型通常输出的是一个概率值&#xff0c;我们需要设定一个阈值&#xff…

Android aidl的简单使用

一.服务端 1.创建aidl文件&#xff0c;然后记得build下生成java文件 package com.example.aidlservice31;// Declare any non-default types here with import statementsinterface IMyAidlServer {// 接收一个字符串参数void setData(String value);// 返回一个字符串String …

数据结构与算法之贪心: LeetCode 122. 买卖股票的最佳时机II (Typescript版)

买卖股票的最佳时机II 给你一个整数数组 prices &#xff0c;其中 prices[i] 表示某支股票第 i 天的价格。 在每一天&#xff0c;你可以决定是否购买和/或出售股票。你在任何时候 最多 只能持有 一股 股票。你也可以先购买&#xff0c;然后在 同一天 出售。 返回 你能获得的 …

mybatis配置文件中配置类型别名的方式

在MyBatis配置文件&#xff08;通常是mybatis-config.xml&#xff09;中&#xff0c;可以通过以下方式配置类型别名&#xff1a; 1. 使用typeAliases元素配置全局类型别名 <configuration> <typeAliases> <typeAlias alias"YourAlias" type"…

简单订单和支付业务的相关流程

1、订单创建、支付及订单处理流程图 2、创建HTTP客户端工具类 Slf4j public class HttpclientUtil {//类中定义了一个私有静态成员变量instance&#xff0c;并且将其初始化为HttpclientUtil类的一个实例&#xff0c;用于实现单例模式。private static HttpclientUtil instance…

单片机学习6——定时器/计数功能的概念

在8051单片机中有两个定时器/计数器&#xff0c;分别是定时器/计数器0和定时器/计数器1。 T/C0: 定时器/计数器0 T/C1: 定时器/计数器1 T0: 定时器0 T1: 定时器1 C0: 计数器0 C1: 计数器1 如果是对内部振荡源12分频的脉冲信号进行计数&#xff0c;对每个机器周期计数&am…

基于springboot+vue的学生宿舍管理系统(前后端分离)

博主主页&#xff1a;猫头鹰源码 博主简介&#xff1a;Java领域优质创作者、CSDN博客专家、公司架构师、全网粉丝5万、专注Java技术领域和毕业设计项目实战 主要内容&#xff1a;毕业设计(Javaweb项目|小程序等)、简历模板、学习资料、面试题库、技术咨询 文末联系获取 项目介绍…

时间序列预测 — LSTM实现单变量风电滚动预测(Keras)

目录 1 数据处理 1.1 数据集简介 1.2 数据集处理 2 模型训练与预测 2.1 模型训练 2.2 模型滚动预测 2.3 结果可视化 1 数据处理 1.1 数据集简介 实验数据集采用数据集5&#xff1a;风电机组运行数据集&#xff08;下载链接&#xff09;&#xff0c;包括风速、风向、温…

JC/T 456-2015 陶瓷马赛克检测

陶瓷马赛克是指可拼接贴成联的或可单独铺贴的小规格陶瓷砖&#xff0c;可用于墙面和地面起保护及装饰作用。 JC/T 456-2015 陶瓷马赛克测试&#xff1a; 测试项目 测试方法 尺寸允许偏差 JC/T 456 外观质量 JC/T 456 吸水率 GB/T 3810.3 耐磨性 GB/T 3810.6 GB/T 381…

编程语言发展史:JavaScript语言的发展和应用

预计更新 第一部分&#xff1a;早期编程语言 1.1布尔代数和机器语言 1.2汇编语言的出现和发展 1.3高级语言的兴起 第二部分&#xff1a;主流编程语言 1.1 C语言的诞生及其影响 1.2 C语言的发展和应用 1.3 Java语言的出现和发展 1.4 Python语言的兴起和特点 1.5 JavaScript语言…

华为OD机试 - 游戏分组(Java JS Python C)

题目描述 部门准备举办一场王者荣耀表演赛,有 10 名游戏爱好者参与,分为两队,每队 5 人。 每位参与者都有一个评分,代表着他的游戏水平。为了表演赛尽可能精彩,我们需要把 10 名参赛者分为示例尽量相近的两队。 一队的实力可以表示为这一队 5 名队员的评分总和。 现在…

使用Rust开发小游戏

本文是对 使用 Rust 开发一个微型游戏【已完结】[1]的学习与记录. cargo new flappy 在Cargo.toml的[dependencies]下方增加: bracket-lib "~0.8.7" main.rs中: use bracket_lib::prelude::*;struct State {}impl GameState for State { fn tick(&mut self,…

每日一题--相交链表

离思五首-元稹 曾经沧海难为水&#xff0c;除却巫山不是云。 取次花丛懒回顾&#xff0c;半缘修道半缘君。 目录 题目描述&#xff1a; 思路分析&#xff1a; 方法及时间复杂度&#xff1a; 法一 计算链表长度(暴力解法) 法二 栈 法三 哈希集合 法四 map或unordered_map…

【面经八股】搜广推方向:常见面试题(二)

【面经&八股】搜广推方向:常见面试题(二) 文章目录 【面经&八股】搜广推方向:常见面试题(二)1. FTRL 是什么?(Follow The Regularized Leader)2. 梯度下降方法3. 推荐系统中常见的Embedding方法有哪些?4. Embedding与推荐系统有哪些结合5. FM 和 FFM6. FNN7. 深…

一文学会使用React-Router v6

文章目录 基本格式createBrowserRouterType Declarationroutesbasenamefuture and window ... 省略 <RouterProvider>fall上述文本提到 createBrowserRouter 函数的一个特性&#xff1a;在非服务器端渲染应用程序时&#xff0c;当它挂载时会初始化所有匹配的路由加载器。…

解决hbuilder使用android studio模拟器不能热更新

hbuilder使用android studio模拟器编&#xff0c;在编写代码时&#xff0c;不能热更新&#xff0c;总是需要重启虚拟机中的程序&#xff0c;hbuilderx的版本是3.1.22&#xff0c;android studio的版本是4.2.2 同时在hbuilderx中出现如下报错信息&#xff1a; 报错信息&#x…

HuggingFace学习笔记--AutoModel的使用

1--AutoModel的使用 官方文档 AutoModel 用于加载模型&#xff1b; 1-1--简单Demo 测试代码&#xff1a; from transformers import AutoTokenizer, AutoModelif __name__ "__main__":checkpoint "distilbert-base-uncased-finetuned-sst-2-english"t…

java进阶---多态

多态的概述 什么是多态 同一个对象,在不同时刻表现出来的不同形态 多态的前提 要有继承或实现关系要有方法的重写要有父类引用指向子类对象 多态的具体实现 对象的多态是多态的核心和重点 规则: 一个对象的编译类型与运行类型可以不一致编译类型在定义对象时,就确定了,…

三数之和问题

给你一个整数数组 nums &#xff0c;判断是否存在三元组 [nums[i], nums[j], nums[k]] 满足 i ! j、i ! k 且 j ! k &#xff0c;同时还满足 nums[i] nums[j] nums[k] 0 。请 你返回所有和为 0 且不重复的三元组。 注意&#xff1a;答案中不可以包含重复的三元组。 示例 1&…

【笔记 Pytorch 08】深度学习模板 (未完)

文章目录 一、声明二、工程结构三、文件内容main.pymodel.pydataset.pyutils.py 四、问题汇总 一、声明 非常感谢这些资料的作者&#xff1a; 【参考1】、【PyTorch速成教程 (by Sung Kim)】 二、工程结构 ├── main.py&#xff1a;实现训练 (train) 、验证(validation)和…