elasticsearch__1__java操作之连接es,创建Mapping,保存数据

2024-06-03 13:58
文章标签 java 数据 es 保存 操作 连接 创建 elasticsearch mapping

本文主要是介绍elasticsearch__1__java操作之连接es,创建Mapping,保存数据，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！


elasticsearch 分布式搜索系列专栏：http://blog.csdn.net/xiaohulunb/article/category/2399789

内容涉及代码GitHub地址: 点击打开链接



官方API：http://www.elasticsearch.org/guide/en/elasticsearch/client/java-api/current/index.html



操作demo所用javabean


package com.elasticsearch;import com.google.common.collect.Lists;
import com.util.date.Joda_Time;
import org.elasticsearch.common.xcontent.XContentBuilder;
import org.elasticsearch.common.xcontent.XContentFactory;import java.io.IOException;
import java.util.Date;
import java.util.List;/*** Created by lw on 14-7-8.*/
public class User {private String name;private String home;//家乡private double height;//身高private int age;private Date birthday;public User() {}public User(String name, String home, double height, int age, Date birthday) {this.name = name;this.home = home;this.height = height;this.age = age;this.birthday = birthday;}/*** 随机生成一个用户信息** @return*/public static User getOneRandomUser() {return new User("葫芦" + (int) (Math.random() * 1000) + "娃", "山西省太原市" + (int) (Math.random() * 1000) + "街道", (Math.random() * 1000), (int) (Math.random() * 100), new Date(System.currentTimeMillis() - (long) (Math.random() * 100000)));}/*** 随机生成num个用户信息** @param num 生成数量* @return*/public static List<User> getRandomUsers(int num) {List<User> users = Lists.newArrayList();if (num < 0) num = 10;for (int i = 0; i < num; i++) {users.add(new User("葫芦" + (int) (Math.random() * 1000) + "娃", "山西省太原市" + (int) (Math.random() * 1000) + "街道", (Math.random() * 1000), (int) (Math.random() * 100), new Date(System.currentTimeMillis() - (long) (Math.random() * 100000))));}return users;}/*** 封装对象的Json信息** @param user* @return* @throws IOException*/public static XContentBuilder getXContentBuilder(User user) throws IOException {return XContentFactory.jsonBuilder().startObject().field("name", user.getName())//该字段在上面的方法中mapping定义了,所以该字段就有了自定义的属性,比如 age等.field("home", user.getHome()).field("height", user.getHeight()).field("age", user.getAge()).field("birthday", user.getBirthday()).field("state", "默认属性,mapping中没有定义")//该字段在上面方法中的mapping中没有定义,所以该字段的属性使用es默认的..endObject();}public String getName() {return name;}public void setName(String name) {this.name = name;}public String getHome() {return home;}public void setHome(String home) {this.home = home;}public double getHeight() {return height;}public void setHeight(double height) {this.height = height;}public int getAge() {return age;}public void setAge(int age) {this.age = age;}public Date getBirthday() {return birthday;}public void setBirthday(Date birthday) {this.birthday = birthday;}}



java与elasticsearch的交互demo

package com.framework_technology.elasticsearch;import org.elasticsearch.action.admin.indices.alias.IndicesAliasesRequestBuilder;
import org.elasticsearch.action.admin.indices.alias.exists.AliasesExistRequestBuilder;
import org.elasticsearch.action.admin.indices.alias.exists.AliasesExistResponse;
import org.elasticsearch.action.admin.indices.create.CreateIndexRequestBuilder;
import org.elasticsearch.action.admin.indices.create.CreateIndexResponse;
import org.elasticsearch.action.admin.indices.stats.IndexStats;
import org.elasticsearch.action.bulk.BulkRequestBuilder;
import org.elasticsearch.action.bulk.BulkResponse;
import org.elasticsearch.action.index.IndexResponse;
import org.elasticsearch.common.xcontent.XContentBuilder;
import org.elasticsearch.common.xcontent.XContentFactory;import java.io.IOException;
import java.util.HashMap;
import java.util.List;
import java.util.Map;/*** Created by lw on 14-7-7.* <p>* mapping创建* 添加记录到es*/
public class Es_BuildIndex {/*** 索引的mapping* <p>* 预定义一个索引的mapping,使用mapping的好处是可以个性的设置某个字段等的属性* Es_Setting.INDEX_DEMO_01类似于数据库* mapping 类似于预设某个表的字段类型* <p>* Mapping,就是对索引库中索引的字段名及其数据类型进行定义，类似于关系数据库中表建立时要定义字段名及其数据类型那样，* 不过es的 mapping比数据库灵活很多，它可以动态添加字段。* 一般不需要要指定mapping都可以，因为es会自动根据数据格式定义它的类型，* 如果你需要对某 些字段添加特殊属性（如：定义使用其它分词器、是否分词、是否存储等），就必须手动添加mapping。* 有两种添加mapping的方法，一种是定义在配 置文件中，一种是运行时手动提交mapping，两种选一种就行了。** @throws Exception Exception*/protected static void buildIndexMapping() throws Exception {Map<String, Object> settings = new HashMap<>();settings.put("number_of_shards", 4);//分片数量settings.put("number_of_replicas", 0);//复制数量settings.put("refresh_interval", "10s");//刷新时间//在本例中主要得注意,ttl及timestamp如何用java ,这些字段的具体含义,请去到es官网查看CreateIndexRequestBuilder cib = Es_Utils.client.admin().indices().prepareCreate(Es_Utils.LOGSTASH_YYYY_MM_DD);cib.setSettings(settings);XContentBuilder mapping = XContentFactory.jsonBuilder().startObject().startObject("we3r")//.startObject("_ttl")//有了这个设置,就等于在这个给索引的记录增加了失效时间,//ttl的使用地方如在分布式下,web系统用户登录状态的维护..field("enabled", true)//默认的false的.field("default", "5m")//默认的失效时间,d/h/m/s 即天/小时/分钟/秒.field("store", "yes").field("index", "not_analyzed").endObject().startObject("_timestamp")//这个字段为时间戳字段.即你添加一条索引记录后,自动给该记录增加个时间字段(记录的创建时间),搜索中可以直接搜索该字段..field("enabled", true).field("store", "no").field("index", "not_analyzed").endObject()//properties下定义的name等等就是属于我们需要的自定义字段了,相当于数据库中的表字段 ,此处相当于创建数据库表.startObject("properties").startObject("@timestamp").field("type", "long").endObject().startObject("name").field("type", "string").field("store", "yes").endObject().startObject("home").field("type", "string").field("index", "not_analyzed").endObject().startObject("now_home").field("type", "string").field("index", "not_analyzed").endObject().startObject("height").field("type", "double").endObject().startObject("age").field("type", "integer").endObject().startObject("birthday").field("type", "date").field("format", "YYYY-MM-dd").endObject().startObject("isRealMen").field("type", "boolean").endObject().startObject("location").field("lat", "double").field("lon", "double").endObject().endObject().endObject().endObject();cib.addMapping(Es_Utils.LOGSTASH_YYYY_MM_DD_MAPPING, mapping);cib.execute().actionGet();}/*** 给 []index 创建别名* 重载方法可以按照过滤器或者Query 作为一个别名** @param aliases aliases别名* @param indices 多个 index* @return 是否完成*/protected static boolean createAliases(String aliases, String... indices) {IndicesAliasesRequestBuilder builder = Es_Utils.client.admin().indices().prepareAliases();return builder.addAlias(indices, aliases).execute().isDone();}/*** 查询此别名是否存在** @param aliases aliases* @return 是否存在*/protected static boolean aliasesExist(String... aliases) {AliasesExistRequestBuilder builder =Es_Utils.client.admin().indices().prepareAliasesExist(aliases);AliasesExistResponse response = builder.execute().actionGet();return response.isExists();}/*** 添加记录到es* <p>* 增加索引记录** @param user 添加的记录* @throws Exception Exception*/protected static void buildIndex(User user) throws Exception {// INDEX_DEMO_01_MAPPING为上个方法中定义的索引,prindextype为类型.jk8231为id,以此可以代替memchche来进行数据的缓存IndexResponse response = Es_Utils.client.prepareIndex(Es_Utils.LOGSTASH_YYYY_MM_DD, Es_Utils.LOGSTASH_YYYY_MM_DD_MAPPING).setSource(User.getXContentBuilder(user)).setTTL(8000)//这样就等于单独设定了该条记录的失效时间,单位是毫秒,必须在mapping中打开_ttl的设置开关.execute().actionGet();}/*** 批量添加记录到索引** @param userList 批量添加数据* @throws java.io.IOException IOException*/protected static void buildBulkIndex(List<User> userList) throws IOException {BulkRequestBuilder bulkRequest = Es_Utils.client.prepareBulk();// either use Es_Setting.client#prepare, or use Requests# to directly build index/delete requestsfor (User user : userList) {//通过add批量添加bulkRequest.add(Es_Utils.client.prepareIndex(Es_Utils.LOGSTASH_YYYY_MM_DD, Es_Utils.LOGSTASH_YYYY_MM_DD_MAPPING).setSource(User.getXContentBuilder(user)));}BulkResponse bulkResponse = bulkRequest.execute().actionGet();//如果失败if (bulkResponse.hasFailures()) {// process failures by iterating through each bulk response itemSystem.out.println("buildFailureMessage:" + bulkResponse.buildFailureMessage());}}}


数据查看










这篇关于elasticsearch__1__java操作之连接es,创建Mapping,保存数据的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/1027183。

相关文章

ESP32 esp-idf esp-adf环境安装及.a库创建与编译

ESP32 esp-idf esp-adf环境安装及.a库创建与编译

简介 ESP32 功能丰富的 Wi-Fi & 蓝牙 MCU, 适用于多样的物联网应用。使用freertos操作系统。 ESP-IDF 官方物联网开发框架。 ESP-ADF 官方音频开发框架。 文档参照 https://espressif-docs.readthedocs-hosted.com/projects/esp-adf/zh-cn/latest/get-started/index
阅读更多...
Java五子棋之坐标校正

Java五子棋之坐标校正

上篇针对了Java项目中的解构思维，在这篇内容中我们不妨从整体项目中拆解拿出一个非常重要的五子棋逻辑实现：坐标校正，我们如何使漫无目的鼠标点击变得有序化和可控化呢？ 目录 一、从鼠标监听到获取坐标 1.MouseListener和MouseAdapter 2.mousePressed方法 二、坐标校正的具体实现方法 1.关于fillOval方法 2.坐标获取 3.坐标转换 4.坐
阅读更多...
Spring Cloud：构建分布式系统的利器

Spring Cloud：构建分布式系统的利器

引言 在当今的云计算和微服务架构时代，构建高效、可靠的分布式系统成为软件开发的重要任务。Spring Cloud 提供了一套完整的解决方案，帮助开发者快速构建分布式系统中的一些常见模式（例如配置管理、服务发现、断路器等）。本文将探讨 Spring Cloud 的定义、核心组件、应用场景以及未来的发展趋势。 什么是 Spring Cloud Spring Cloud 是一个基于 Spring
阅读更多...
RedHat运维-Linux文本操作基础-AWK进阶

RedHat运维-Linux文本操作基础-AWK进阶

你不用整理，跟着敲一遍，有个印象，然后把它保存到本地，以后要用再去看，如果有了新东西，你自个再添加。这是我参考牛客上的shell编程专项题，只不过换成了问答的方式而已。不用背，就算是我自己亲自敲，我现在好多也记不住。 1. 输出nowcoder.txt文件第5行的内容 2. 输出nowcoder.txt文件第6行的内容 3. 输出nowcoder.txt文件第7行的内容 4. 输出nowcode
阅读更多...
Javascript高级程序设计(第四版)--学习记录之变量、内存

Javascript高级程序设计(第四版)--学习记录之变量、内存

原始值与引用值 原始值：简单的数据即基础数据类型，按值访问。 引用值：由多个值构成的对象即复杂数据类型，按引用访问。 动态属性 对于引用值而言，可以随时添加、修改和删除其属性和方法。 let person = new Object();person.name = 'Jason';person.age = 42;console.log(person.name,person.age);//'J
阅读更多...
java8的新特性之一（Java Lambda表达式）

java8的新特性之一（Java Lambda表达式）

1：Java8的新特性 Lambda 表达式： 允许以更简洁的方式表示匿名函数（或称为闭包）。可以将Lambda表达式作为参数传递给方法或赋值给函数式接口类型的变量。 Stream API： 提供了一种处理集合数据的流式处理方式，支持函数式编程风格。 允许以声明性方式处理数据集合（如List、Set等）。提供了一系列操作，如map、filter、reduce等，以支持复杂的查询和转
阅读更多...
【Altium】查找PCB上未连接的网络

【Altium】查找PCB上未连接的网络

【更多软件使用问题请点击亿道电子官方网站】 1、文档目标： PCB设计后期检查中找出没有连接的网络 应用场景：PCB设计后期，需要检查是否所有网络都已连接布线。虽然未连接的网络会有飞线显示，但是由于布线后期整板布线密度较高，虚连，断连的网络用肉眼难以轻易发现。用DRC检查也可以找出未连接的网络，如果PCB中DRC问题较多，查找起来就不是很方便。使用PCB Filter面板来达成目的相比DRC
阅读更多...
Java面试八股之怎么通过Java程序判断JVM是32位还是64位

Java面试八股之怎么通过Java程序判断JVM是32位还是64位

怎么通过Java程序判断JVM是32位还是64位 可以通过Java程序内部检查系统属性来判断当前运行的JVM是32位还是64位。以下是一个简单的方法： public class JvmBitCheck {public static void main(String[] args) {String arch = System.getProperty("os.arch");String dataM
阅读更多...
详细分析Springmvc中的@ModelAttribute基本知识（附Demo）

详细分析Springmvc中的@ModelAttribute基本知识（附Demo）

目录 前言1. 注解用法1.1 方法参数1.2 方法1.3 类 2. 注解场景2.1 表单参数2.2 AJAX请求2.3 文件上传 3. 实战4. 总结 前言 将请求参数绑定到模型对象上，或者在请求处理之前添加模型属性 可以在方法参数、方法或者类上使用 一般适用这几种场景： 表单处理：通过 @ModelAttribute 将表单数据绑定到模型对象上预处理逻辑：在请求处理之前
阅读更多...
eclipse运行springboot项目，找不到主类

eclipse运行springboot项目，找不到主类

解决办法尝试了很多种，下载sts压缩包行不通。最后解决办法如图： help--->Eclipse Marketplace--->Popular--->找到Spring Tools 3---->Installed。
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2