Elasticsearch在java中的使用【同步MySQL数据】【模糊查询】【代码】

本文主要是介绍Elasticsearch在java中的使用【同步MySQL数据】【模糊查询】【代码】，对大家解决编程问题具有一定的参考价值，需要的程序猿们随着小编来一起学习吧！

环境准备

确认已经装好了Elasticsearch【Elasticsearch安装教程 - 博客园】

参考教程

参考自关于在Java中简单的将Mysql中的数据添加到es中并且定时同步更新 - CSDN

参考教程 Java中ElasticSearch的各种查询（普通，模糊，前缀，高亮，聚合，范围） - CSDN

引入依赖

注意！！！

elasticsearch.version 要和自己安装的版本协同

pom依赖代码

<properties>
     <elasticsearch.version>7.15.2</elasticsearch.version>
</properties>

<!-- ElasticSearch模糊查询的依赖 fastJson -->
<dependency>
    <groupId>com.alibaba</groupId>
    <artifactId>fastjson</artifactId>
    <version>1.2.36</version>
</dependency>
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-elasticsearch</artifactId>
</dependency>
<!-- 不知道这个是什么依赖，但是教程说要要 -->
<!-- 注意以下依赖和 所安装的 Elasticsearch 的版本协同 -->
<dependency>
    <groupId>org.elasticsearch.client</groupId>
    <artifactId>elasticsearch-rest-high-level-client</artifactId>
    <version>7.15.2</version>
    <exclusions>
        <exclusion>
            <groupId>org.elasticsearch</groupId>
            <artifactId>elasticsearch</artifactId>
        </exclusion>
        <exclusion>
            <groupId>org.elasticsearch.client</groupId>
            <artifactId>elasticsearch-rest-client</artifactId>
        </exclusion>
    </exclusions>
</dependency>
<!-- client依赖 -->
<dependency>
    <groupId>org.elasticsearch.client</groupId>
    <artifactId>elasticsearch-rest-client</artifactId>
    <version>7.15.2</version>
</dependency>
<!-- elasticsearch依赖 -->
<dependency>
    <groupId>org.elasticsearch</groupId>
    <artifactId>elasticsearch</artifactId>
    <version>7.15.2</version>
</dependency>
<!-- 依然不知道这是什么依赖 -->
<dependency>
    <groupId>org.elasticsearch.client</groupId>
    <artifactId>elasticsearch-rest-client</artifactId>
    <version>7.15.2</version>
    <exclusions>
        <exclusion>
            <groupId>commons-logging</groupId>
            <artifactId>commons-logging</artifactId>
        </exclusion>
    </exclusions>
</dependency>

可能遇到的问题

fastjson 的版本报红，不下载。

可能是这个 fastjson 版本和 pom 文件的别的设置冲突了，改一下 fastjson 版本就行
pom 文件更新的时候报错 Connot connect

~~谁知道这是什么问题啊【应该是我手贱又下载了个JDK导致的自动更新】~~

可能是 jdk 环境被自动改了。File -- Setting -- Maven -- Importing -- 查看 JDK for Inporting 的设置是否正确

创建配置类

import org.apache.http.HttpHost;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestHighLevelClient;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

// Elasticsearch的配置类【配置es链接】
@Configuration
public class ElasticSearchClientConfig
{
    // 这一段感觉应该是初始化了一个 RequestOptions 变量
    public static final RequestOptions COMMON_OPTIONS;
    static
    {
        RequestOptions.Builder builder = RequestOptions.DEFAULT.toBuilder();
        COMMON_OPTIONS = builder.build();
    }

    /**
     * 无账号密码登录
     * @return RestHighLevelClient
     */
    @Bean
    public static RestHighLevelClient restHighLevelClient()
    {
        // 集群配置法
        RestHighLevelClient client = new RestHighLevelClient
                (RestClient.builder(new HttpHost("127.0.0.1", 9200, "http")));
        return client;
    }
}

将数据库的数据同步到ES

import com.alibaba.fastjson.JSONObject;
import com.placename.general.config.ElasticSearchClientConfig;
import com.placename.general.mapper.PogOfficialInfoMapper;
import com.placename.general.model.domain.PogOfficialInfo;
import org.elasticsearch.action.bulk.BulkRequest;
import org.elasticsearch.action.index.IndexRequest;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.common.xcontent.XContentType;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
import java.io.IOException;
import java.util.List;

@EnableScheduling // 定时器
@Component
public class ElasticsearchImpl
{
    @Autowired
    @Resource
    // 这个是要被同步的数据表所对应的Mapper
    private PogOfficialInfoMapper pogOfficialInfoMapper;

    // 定时器注解，每过去5秒执行这个方法
    @Scheduled(cron = "0/5 * * * * ?")
    public void Escalculating()
    {
        // 查询 OfficialInfo 表中的所有数据，待会这些数据全部放在 es 里
        List<PogOfficialInfo> list = pogOfficialInfoMapper.getall();

        // 调用高层对象
        // ElasticSearchClientConfig 为之前写的 Elasticsearch 配置类，restHighLevelClient 是其中的静态方法
        RestHighLevelClient client = ElasticSearchClientConfig.restHighLevelClient();

        // 存储刚刚 list 里获得的对象
        for(PogOfficialInfo temp:list)
        {
            // 创建构造器指定index索引
            IndexRequest indexRequest = new IndexRequest("officialinfo");  // 索引的名字
            indexRequest.id(temp.getId().toString());

            // 创建批量操作的对象
            BulkRequest request = new BulkRequest();

            // 将查询到的数据转化为Json
            indexRequest.source(JSONObject.toJSONString(temp), XContentType.JSON);
            // Json数据放入批量操作对象中
            request.add(indexRequest);

            // 执行操作
            try
            {
                client.bulk(request,ElasticSearchClientConfig.COMMON_OPTIONS);
            }
            catch (IOException e)
            {
                e.printStackTrace();
            }
            System.out.println(temp);
        }
    }
}

Elasticsearch查询示例

GET officialinfo/_search
{
  "query":{
    "match": {
      "content": {
        "query": "疫情 核酸",
        "operator": "or"
      }
    }
  }
}

使用Elasticsearch进行查询

测试类测试

import com.placename.general.model.domain.PogOfficialInfo;
import org.apache.http.HttpHost;
import org.apache.lucene.util.QueryBuilder;
import org.elasticsearch.action.get.GetRequest;
import org.elasticsearch.action.get.GetResponse;
import org.elasticsearch.action.search.SearchRequest;
import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.client.indices.GetIndexRequest;
import org.elasticsearch.client.indices.GetIndexResponse;
import org.elasticsearch.client.transport.TransportClient;
import org.elasticsearch.common.transport.TransportAddress;
import org.elasticsearch.index.query.Operator;
import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.search.SearchHit;
import org.elasticsearch.search.builder.SearchSourceBuilder;
import org.junit.jupiter.api.BeforeAll;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;

import java.io.IOException;
import java.util.ArrayList;
import java.util.List;

@SpringBootTest
public class ElasticsearchApplicationTest
{
    // 连接客户端
    @Autowired
    RestHighLevelClient client;

    @Test
    public void testClient() throws IOException
    {
        // 初始化客户端
        // 正常操作应该是把这个方法加上 @Before 注解实现比较好
        System.out.println(client);
        HttpHost serverHost = new HttpHost("localhost",9200);
        client = new RestHighLevelClient(RestClient.builder(serverHost));

        /* // 验证索引是否正常 - OK
        // 查询索引信息
        // GetIndexRequest("officialinfo") 中的 officialinfo 为索引名称
        GetIndexRequest request = new GetIndexRequest("officialinfo");
        GetIndexResponse response = client.indices().get(request, RequestOptions.DEFAULT);
        // 获取别名
        System.out.println(response.getAliases().toString());
        // 获取默认设置
        System.out.println(response.getDefaultSettings().toString());
        // 获取索引信息
        System.out.println(response.getIndices().toString());
        // 获取映射信息
        System.out.println(response.getMappings().toString());
        */

        /*
        // 验证文档是否正常 - OK
        // 文档查询【查询 id 为 1 的数据】
        // officialinfo 为索引名称
        GetRequest request = new GetRequest().index("officialinfo").id("1");
        GetResponse response = client.get(request,RequestOptions.DEFAULT);
        System.out.println(response);
        */

        // 模糊查询
        // 创建查询request
        // officialinfo 为索引名称
        SearchRequest request = new SearchRequest("officialinfo");
        // 这个request.type() 可能因为 Elasticsearch 版本的问题，已经不用了，如果用的话，会报错
        // 【[types removal] Specifying types in search requests is deprecated."]】
        // request.types("text");
        // 指定查询条件
        SearchSourceBuilder builder = new SearchSourceBuilder();
        // 选择模糊查询匹配的模式是 and 还是 or
        // 也可以不加后面的 .operator(Operator.OR) ，如果不加，就是直接匹配
        builder.query(QueryBuilders.matchQuery("content","防疫 核酸").operator(Operator.OR));
        request.source(builder);
        // 执行查询
        SearchResponse response = client.search(request,RequestOptions.DEFAULT);

        // 结果打印【为什么用 Hit ，需要去看 Elasticsearch 查询的结果，看结果很容易就明白了】
        for(SearchHit hit:response.getHits().getHits())
        {
            System.out.println(hit.getSourceAsMap());
        }

        // 销毁客户端 【同上，理论上应该用 @After 注解实现】
        if(client == null)
        {
            try
            {
                client.close();
            }
            catch(Exception e)
            {
                e.printStackTrace();
            }
        }
    }
}

~~详细的Elasticsearch的使用我将会再写一个教程，如果有需要，请到我的博客中去寻找阿巴阿巴，这个可以当作初版，或者说代码版~~

这篇关于Elasticsearch在java中的使用【同步MySQL数据】【模糊查询】【代码】的文章就介绍到这儿，希望我们推荐的文章对大家有所帮助，也希望大家多多支持为之网！

Java教程

Elasticsearch在java中的使用【同步MySQL数据】【模糊查询】【代码】

环境准备

参考教程

引入依赖

pom依赖代码

可能遇到的问题

创建配置类

将数据库的数据同步到ES

Elasticsearch查询示例

使用Elasticsearch进行查询

前端开发

后端开发

移动端开发

数据库

服务器运维

人工智能

区块链

游戏开发

网站运营

大数据/云计算

软件工程

软件/开发工具使用

资讯