ElasticSearch6（二）-- Java API连接es

2022-08-15 11:59:13

此ElasticSearch系列基于最新版的6.2.4版本。

一、pom.xml依赖

    <dependencies>

        <dependency>

            <groupId>junit</groupId>

            <artifactId>junit</artifactId>

            <version>4.12</version>

            <scope>test</scope>

        </dependency>

        <dependency>

            <groupId>org.elasticsearch.client</groupId>

            <artifactId>transport</artifactId>

            <version>6.2.4</version>

        </dependency>

        <dependency>

            <groupId>org.elasticsearch</groupId>

            <artifactId>elasticsearch</artifactId>

            <version>6.2.4</version>

        </dependency>

        <dependency>

            <groupId>com.alibaba</groupId>

            <artifactId>fastjson</artifactId>

            <version>1.2.46</version>

        </dependency>

    </dependencies>

二、log4j2.xml

<!--日志级别以及优先级排序: OFF > FATAL > ERROR > WARN > INFO > DEBUG > TRACE > ALL -->

<!--Configuration后面的status，这个用于设置log4j2自身内部的信息输出，可以不设置，当设置成trace时，你会看到log4j2内部各种详细输出 -->

<!--monitorInterval：Log4j能够自动检测修改配置 文件和重新配置本身，设置间隔秒数 -->

<configuration status="WARN" monitorInterval="30">

    <!--先定义所有的appender -->

    <appenders>

        <!--这个输出控制台的配置 -->

        <console name="Console" target="SYSTEM_OUT">

            <!--输出日志的格式 -->

            <PatternLayout pattern="[%d{HH:mm:ss:SSS}] [%p] - %l - %m%n" />

        </console>

        <!--文件会打印出所有信息，这个log每次运行程序会自动清空，由append属性决定，这个也挺有用的，适合临时测试用 -->

        <File name="log" fileName="log/test.log" append="false">

            <PatternLayout

                pattern="%d{HH:mm:ss.SSS} %-5level %class{36} %L %M - %msg%xEx%n" />

        </File>

        <!-- 这个会打印出所有的info及以下级别的信息，每次大小超过size，则这size大小的日志会自动存入按年份-月份建立的文件夹下面并进行压缩，作为存档 -->

        <RollingFile name="RollingFileInfo" fileName="${sys:user.home}/logs/info.log"

            filePattern="${sys:user.home}/logs/$${date:yyyy-MM}/info-%d{yyyy-MM-dd}-%i.log">

            <!--控制台只输出level及以上级别的信息（onMatch），其他的直接拒绝（onMismatch） -->

            <ThresholdFilter level="info" onMatch="ACCEPT"

                onMismatch="DENY" />

            <PatternLayout pattern="[%d{HH:mm:ss:SSS}] [%p] - %l - %m%n" />

            <Policies>

                <TimeBasedTriggeringPolicy />

                <SizeBasedTriggeringPolicy size="100 MB" />

            </Policies>

        </RollingFile>

        <RollingFile name="RollingFileWarn" fileName="${sys:user.home}/logs/warn.log"

            filePattern="${sys:user.home}/logs/$${date:yyyy-MM}/warn-%d{yyyy-MM-dd}-%i.log">

            <ThresholdFilter level="warn" onMatch="ACCEPT"

                onMismatch="DENY" />

            <PatternLayout pattern="[%d{HH:mm:ss:SSS}] [%p] - %l - %m%n" />

            <Policies>

                <TimeBasedTriggeringPolicy />

                <SizeBasedTriggeringPolicy size="100 MB" />

            </Policies>

            <!-- DefaultRolloverStrategy属性如不设置，则默认为最多同一文件夹下7个文件，这里设置了20 -->

            <DefaultRolloverStrategy max="20" />

        </RollingFile>

        <RollingFile name="RollingFileError" fileName="${sys:user.home}/logs/error.log"

            filePattern="${sys:user.home}/logs/$${date:yyyy-MM}/error-%d{yyyy-MM-dd}-%i.log">

            <ThresholdFilter level="error" onMatch="ACCEPT"

                onMismatch="DENY" />

            <PatternLayout pattern="[%d{HH:mm:ss:SSS}] [%p] - %l - %m%n" />

            <Policies>

                <TimeBasedTriggeringPolicy />

                <SizeBasedTriggeringPolicy size="100 MB" />

            </Policies>

        </RollingFile>

    </appenders>

    <!--然后定义logger，只有定义了logger并引入的appender，appender才会生效 -->

    <loggers>

        <!--过滤掉spring和mybatis的一些无用的DEBUG信息 -->

        <logger name="org.springframework" level="INFO" />

        <logger name="org.mybatis" level="INFO" />

        <root level="INFO">

            <appender-ref ref="Console" />

            <appender-ref ref="RollingFileInfo" />

            <appender-ref ref="RollingFileWarn" />

            <appender-ref ref="RollingFileError" />

        </root>

    </loggers>

</configuration>

三、获取es 连接

package com.xsjt.util;

import java.net.InetAddress;

import org.elasticsearch.client.transport.TransportClient;

import org.elasticsearch.common.settings.Settings;

import org.elasticsearch.common.transport.TransportAddress;

import org.elasticsearch.transport.client.PreBuiltTransportClient;

/**

 * ClassName:GetConnection Date: 2018年3月20日 下午8:12:07

 *

 * @author xbq

 * @version

 * @since JDK 1.8

 */

public class GetConnection {

    public final static String HOST = "192.168.10.58";

    // http请求的端口是9200，客户端是9300

    public final static int PORT = 9300; 

    /**

     * getConnection:(获取es连接).

     * @author xbq Date:2018年3月21日上午11:52:02

     * @return

     * @throws Exception

     */

    @SuppressWarnings({"resource", "unchecked"})

    public static TransportClient getConnection() throws Exception {

        // 设置集群名称

        Settings settings = Settings.builder().put("cluster.name", "nmtx-cluster").build();

        // 创建client

        TransportClient client = new PreBuiltTransportClient(settings)

                .addTransportAddresses(new TransportAddress(InetAddress.getByName(HOST), PORT));

        client.close();

        return client;

    }

    public static void main(String[] args) throws Exception {

        TransportClient client = getConnection();

        System.out.println("client==" + client.toString());

    }

}

码农公寓

一、pom.xml依赖

二、log4j2.xml

三、获取es 连接

相关文章