Elasticsearch—(MacOs)

news2024/11/28 1:18:43

1⃣️环境准备

  1. 准备 Java 环境：终端输入 java -version 命令来确认版本是否符合 Elasticsearch 要求
  2. 下载并解压 Elasticsearch：前往（https://www.elastic.co/downloads/elasticsearch）选择适合你的 Mac 系统的 Elasticsearch 版本进行下载
  3. 设置 Elasticsearch 配置：在 config 目录下找到并打开 elasticsearch.yml 配置文件。根据你的需求，修改其中的一些设置，比如监听的端口、集群名称等
  4. 启动 Elasticsearch：打开终端，进入 Elasticsearch 解压目录，执行以下命令启动 Elasticsearch： 
    ./bin/elasticsearch
  5. 验证 Elasticsearch 是否正常运行：打开浏览器，访问 http://localhost:9200 地址，如果能看到返回的 JSON 格式的信息，说明 Elasticsearch 已经成功安装并运行。

2⃣️使用

要使用Elasticsearch进行增删改查等操作，你可以通过Postman来实现。下面我将提供一个使用RESTful API来演示的示例：

💫创建索引库

💫添加文档(添加行)

💫查询索引库

💫修改索引库

💫删除索引库

 3⃣️与Java使用

如何使用Java与Elasticsearch进行索引的创建、文档的增加、查询、修改和删除操作：

💠添加Elasticsearch Maven依赖：

在pom.xml文件中添加以下依赖项：

<dependencies>
    <dependency>
        <groupId>org.elasticsearch.client</groupId>
        <artifactId>elasticsearch-rest-high-level-client</artifactId>
        <version>7.13.3</version>
    </dependency>
    <dependency>
        <groupId>org.elasticsearch.client</groupId>
        <artifactId>elasticsearch-rest-client</artifactId>
        <version>7.13.3</version>
    </dependency>
</dependencies>

💠创建索引库：

import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.client.indices.CreateIndexRequest;
import org.elasticsearch.client.indices.CreateIndexResponse;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.common.settings.Settings;
import org.elasticsearch.common.xcontent.XContentBuilder;
import org.elasticsearch.common.xcontent.XContentType;
import org.elasticsearch.common.xcontent.json.JsonXContent;

// 创建RestHighLevelClient客户端
RestHighLevelClient client = new RestHighLevelClient(
        RestClient.builder("localhost:9200"));

// 创建索引请求
CreateIndexRequest request = new CreateIndexRequest("my_index");
request.settings(Settings.builder()
        .put("index.number_of_shards", 1)
        .put("index.number_of_replicas", 0));

// 创建映射
XContentBuilder mapping = JsonXContent.contentBuilder()
        .startObject()
        .startObject("properties")
        .startObject("user")
        .field("type", "keyword")
        .endObject()
        .startObject("postDate")
        .field("type", "date")
        .endObject()
        .startObject("message")
        .field("type", "text")
        .endObject()
        .endObject()
        .endObject();
request.mapping(mapping);

// 执行创建索引请求
CreateIndexResponse response = client.indices().create(request, RequestOptions.DEFAULT);
if (response.isAcknowledged()) {
    System.out.println("索引创建成功");
} else {
    System.out.println("索引创建失败");
}

// 关闭客户端
client.close();

💠添加文档：

import org.elasticsearch.action.index.IndexRequest;
import org.elasticsearch.action.index.IndexResponse;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.common.xcontent.XContentType;
import org.elasticsearch.client.RestClient;

// 创建RestHighLevelClient客户端
RestHighLevelClient client = new RestHighLevelClient(
        RestClient.builder("localhost:9200"));

// 构建索引请求
IndexRequest request = new IndexRequest("my_index");
request.id("1");
String jsonString = "{" +
                      "\"user\":\"John\"," +
                      "\"postDate\":\"2023-09-25\"," +
                      "\"message\":\"This is a sample document\"" +
                    "}";
request.source(jsonString, XContentType.JSON);

// 执行索引请求
IndexResponse response = client.index(request, RequestOptions.DEFAULT);

// 获取响应结果
String index = response.getIndex();
String id = response.getId();
if (response.getResult() == DocWriteResponse.Result.CREATED) {
    System.out.println("文档创建成功，索引：" + index + "，id：" + id);
} else if (response.getResult() == DocWriteResponse.Result.UPDATED) {
    System.out.println("文档更新成功，索引：" + index + "，id：" + id);
}

// 关闭客户端
client.close();

💠查询索引库

import org.elasticsearch.action.search.SearchRequest;
import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.search.SearchHit;
import org.elasticsearch.search.SearchHits;
import org.elasticsearch.search.builder.SearchSourceBuilder;
import org.elasticsearch.client.RestClient;

// 创建RestHighLevelClient客户端
RestHighLevelClient client = new RestHighLevelClient(
        RestClient.builder("localhost:9200"));

// 构建搜索请求
SearchRequest request = new SearchRequest("my_index");
SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
searchSourceBuilder.query(QueryBuilders.matchQuery("message", "sample"));
request.source(searchSourceBuilder);

// 执行搜索请求
SearchResponse response = client.search(request, RequestOptions.DEFAULT);

// 处理搜索结果
SearchHits hits = response.getHits();
for (SearchHit hit : hits.getHits()) {
    String sourceAsString = hit.getSourceAsString();
    System.out.println(sourceAsString);
}

// 关闭客户端
client.close();

💠修改索引库：

import org.elasticsearch.action.update.UpdateRequest;
import org.elasticsearch.action.update.UpdateResponse;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.common.xcontent.XContentFactory;
import org.elasticsearch.client.RestClient;

// 创建RestHighLevelClient客户端
RestHighLevelClient client = new RestHighLevelClient(
        RestClient.builder("localhost:9200"));

// 构建更新请求
UpdateRequest request = new UpdateRequest("my_index", "1")
        .doc(XContentFactory.jsonBuilder()
                .startObject()
                .field("message", "Updated document")
                .endObject());

// 执行更新请求
UpdateResponse response = client.update(request, RequestOptions.DEFAULT);
String index = response.getIndex();
String id = response.getId();
if (response.getResult() == DocWriteResponse.Result.UPDATED) {
    System.out.println("文档更新成功，索引：" + index + "，id：" + id);
} else if (response.getResult() == DocWriteResponse.Result.NOOP) {
    System.out.println("文档未发生更新，索引：" + index + "，id：" + id);
}

// 关闭客户端
client.close();

💠删除索引库：

import org.elasticsearch.action.delete.DeleteRequest;
import org.elasticsearch.action.delete.DeleteResponse;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.client.RestClient;

// 创建RestHighLevelClient客户端
RestHighLevelClient client = new RestHighLevelClient(
        RestClient.builder("localhost:9200"));

// 构建删除请求
DeleteRequest request = new DeleteRequest("my_index", "1");

// 执行删除请求
DeleteResponse response = client.delete(request, RequestOptions.DEFAULT);
String index = response.getIndex();
String id = response.getId();
if (response.getResult() == DocWriteResponse.Result.DELETED) {
    System.out.println("文档删除成功，索引：" + index + "，id：" + id);
} else if (response.getResult() == DocWriteResponse.Result.NOT_FOUND) {
    System.out.println("文档未找到，索引：" + index + "，id：" + id);
}

// 关闭客户端
client.close();

 

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

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

【Linux学习】03Linux用户和权限

【Linux学习】03Linux用户和权限

Linux&#xff08;B站黑马&#xff09;学习笔记 01Linux初识与安装 02Linux基础命令 03Linux用户和权限 文章目录 Linux&#xff08;B站黑马&#xff09;学习笔记前言03Linux用户和权限认知root用户root用户&#xff08;超级管理员&#xff09;su和exit命令sudo命令 用户、用户…
阅读更多...
【Spring Boot】实战：实现数据缓存框架

【Spring Boot】实战：实现数据缓存框架

🌿欢迎来到@衍生星球的CSDN博文🌿 🍁本文主要学习【Spring Boot】实现数据缓存框架 🍁 🌱我是衍生星球，一个从事集成开发的打工人🌱 ⭐️喜欢的朋友可以关注一下🫰🫰🫰，下次更新不迷路⭐️💠作为一名热衷于分享知识的程序员，我乐于在CSDN上与广大开发者…
阅读更多...
Hbuilder本地调试微信H5项目（二）--添加UView框架插件

Hbuilder本地调试微信H5项目（二）--添加UView框架插件

摘要 在一个已创建的Hbuilder项目中&#xff0c;添加uView框架插件 前置准备 已安装Hbuilder 已创建uni-app的H5默认模板项目 实现逻辑 在Hbuilder官网找到组件说明页面 下载插件并导入HbuilderX 具体实现 访问网站 访问网址Hbuilder的uView1.8.6版本说明页 或者访问…
阅读更多...
MySQL索引是什么

MySQL索引是什么

1、索引是什么 1、MySQL官方对索引的定义为&#xff1a;索引&#xff08;Index&#xff09;是帮助MySQL高效获取数据的数据结构 索引的本质&#xff1a;数据结构。 索引的目的在于提高查询效率&#xff0c;可以类比字典或者一本书的目录&#xff0c;如果要查“mysql”这个单词…
阅读更多...
服务断路器_什么是灾难性雪崩效应

服务断路器_什么是灾难性雪崩效应

什么是灾难性雪崩效应 假设我们有两个访问量比较大的服务A和B&#xff0c;这两个服务分别依赖C和D,C和D服务都依赖E服务。 A和B不断的调用C,D处理客户请求和返回需要的数据。当E服务不能供服务的时候&#xff0c;C和D的超时和重试机制会被执行 由于新的调用不断的产生&#xf…
阅读更多...
【算法深入浅出】字符串匹配之 KMP 算法

【算法深入浅出】字符串匹配之 KMP 算法

KMP 算法是一种字符串匹配算法。字符串匹配算法的目标是&#xff1a;在字符串 s 中找到与模式串 p 相等的子串&#xff0c;输出其位置。例如&#xff1a;s “abcdef”&#xff0c;p “cdef”&#xff0c;p 在 s 中的位置是 2&#xff08;从 0 开始计数&#xff09;。 容易想到…
阅读更多...
高效管理生活：Microsoft To Do for Mac 微软待办事项软件

高效管理生活：Microsoft To Do for Mac 微软待办事项软件

在日常生活中&#xff0c;我们经常面临着琐碎的任务和繁忙的安排。为了更好地管理自己的时间和事务&#xff0c;一款强大而智能的待办事项软件是必不可少的。Microsoft To Do for Mac 微软待办事项软件将助您高效管理生活&#xff0c;让每件事都尽在掌握。 Microsoft To Do fo…
阅读更多...
WordPress主题网站首页添加好看的四格小工具教程

WordPress主题网站首页添加好看的四格小工具教程

直接到网站根目录创建一个css文件(文件名:sige.css),文件名可自定义(注意文件名一致) <link rel"stylesheet" href"你的网站/sige.css" type"text/css" > 然后在header.php模板最上方添加引入代码 也可自定义HTML里添加css代码最上方写…
阅读更多...
如何设计一个 JVM 语言下的 LLM 应用开发框架？以 Chocolate Factory 为例

如何设计一个 JVM 语言下的 LLM 应用开发框架？以 Chocolate Factory 为例

本文将介绍 Chocolate Factory 框架背后的一系列想法和思路。在我们探索和设计框架的过程中&#xff0c;受到了&#xff1a;LangChain4j、LangChain、LlamaIndex、Spring AI、Semantic Kernel、PromptFlow 的大量启发。 欢迎一起来探索&#xff1a;https://github.com/unit-mes…
阅读更多...
Mysql索引结构有哪些

Mysql索引结构有哪些

1、BTree索引 1、初始化介绍 一颗b树&#xff0c;浅蓝色的块我们称之为一个磁盘块&#xff0c;可以看到每个磁盘块包含几个数据项&#xff08;深蓝色所示&#xff09;和指针&#xff08;黄色所示&#xff09;&#xff0c;如磁盘块1包含数据项17和35&#xff0c;包含指针P1、P2…
阅读更多...
Jetpack Compose中的Navigation从入门到精通完全指南

Jetpack Compose中的Navigation从入门到精通完全指南

Jetpack Compose中的Navigation从入门到精通完全指南 什么是Android导航 导航帮助您理解应用程序在不同组件间的移动方式。 Android JetPack Navigation可以帮助您以简单的方式实现高级导航。 导航组件由三个主要部分组成&#xff1a; 导航图(Navigation Graph)&#xff1…
阅读更多...
Spring Boot：控制器调用模板引擎渲染数据的基本过程

Spring Boot：控制器调用模板引擎渲染数据的基本过程

目录 基础知识注解&#xff1a; Controller方法&#xff1a;RequestMapping 基本过程添加 FreeMarker 依赖创建控制器方法创建 FTL 文件 基础知识 注解&#xff1a; Controller 控制器注解&#xff0c;表示这个类是一个控制器类&#xff0c;里面定义了一些处理客户端请求的方…
阅读更多...
2023 “华为杯” 中国研究生数学建模竞赛（F题）深度剖析|数学建模完整代码+建模过程全解全析

2023 “华为杯” 中国研究生数学建模竞赛（F题）深度剖析|数学建模完整代码+建模过程全解全析

F题代码思路 当大家面临着复杂的数学建模问题时&#xff0c;你是否曾经感到茫然无措&#xff1f;作为2021年美国大学生数学建模比赛的O奖得主&#xff0c;我为大家提供了一套优秀的解题思路&#xff0c;让你轻松应对各种难题。 让我们一起看看研赛的F题呀&#xff01;全文都已…
阅读更多...
【OpenSSL】OpenSSL实现Base64

【OpenSSL】OpenSSL实现Base64

Base 64概述和应用场景 概述 Base64就是将二进制数据转换为字符串的一种算法。 应用场景 邮件编码xml或则json存储二进制内容网页传递数据URL数据库中以文本形式存放二进制数据可打印的比特币钱包地址base58Check(hash校验)网页上可以将图片直接使用Base64表达公私密钥的文…
阅读更多...
Python 用列表实现模拟手机通讯录（简易版）

Python 用列表实现模拟手机通讯录（简易版）

"""列表实现好友管理系统知识点&#xff1a;1、列表存储信息2、列表增删改查3、嵌套循环4、字符串分割和拼接&#xff08;重点&#xff09;5、列表索引"""# 暂存好友信息&#xff08;程序结束数据删除&#xff09; friend_info list()input_buf…
阅读更多...
opencv形态学-膨胀

opencv形态学-膨胀

opencv形态学-膨胀 膨胀就是取每一个位置结构元领域内最大值作为该位置的输出灰度值&#xff1b; 膨胀是取邻域内最大值&#xff0c;那么显然膨胀后图像整体亮度会比原先要高&#xff0c;图像中亮的物体尺寸会变大&#xff0c;相反暗的尺寸会减小&#xff0c;甚至是消失 结构元…
阅读更多...
流程图在线制作：5款专业流程图制作网站，无需下载，高效立现！

流程图在线制作：5款专业流程图制作网站，无需下载，高效立现！

流程图&#xff0c;是特定的图形符号加上说明&#xff0c;表示算法的图&#xff0c;是一种可视化工具。近年来流程图逐渐在工作、教育、项目管理等诸多领域大放异彩&#xff0c;市面上也流行着许多流程图制作软件&#xff0c;考虑到许多软件下载流程繁琐、并且还有下载盗版的风…
阅读更多...
pytorch学习笔记——BCE与CE

pytorch学习笔记——BCE与CE

BCELoss的话只需要网络输出一个通道&#xff0c;CE Loss(Cross Entropy Loss)需要输出n_class个通道。 对于二分类任务可以使用CE Loss输出两个通道&#xff0c;也可以使用BCE Loss输出一个通道。 https://www.jianshu.com/p/5b01705368bb https://zhuanlan.zhihu.com/p/372628…
阅读更多...
客户端负载均衡_负载均衡策略

客户端负载均衡_负载均衡策略

以前的Ribbon有多种负载均衡策略 RandomRule - 随性而为 解释&#xff1a; 随机 RoundRobinRule - 按部就班 解释&#xff1a; 轮询 RetryRule - 卷土重来 解释&#xff1a; 先按照RoundRobinRule的策略获取服务&#xff0c;如果获取服务失败则在指定时间内会进行重试。 Weigh…
阅读更多...
Learn Prompt- Midjourney案例:网页设计

Learn Prompt- Midjourney案例:网页设计

快速开始​ 用 “ web design for...” 或 “ modern web design for..” 来快速开始你的提示。 web design for a generic SaaS startup --ar 3:2否定提示-no​ 使用--no告诉 Midjourney 你不想要什么。Midjourney 的默认风格倾向于现实和详细。但这可能不适用于所有品牌。…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023