ElasticSearch教程——Java进行高亮显示

￡神魔★判官ぃ 2021-09-27 11:18 674阅读 0赞

**ElasticSearch汇总请查看：[ElasticSearch教程——汇总篇][ElasticSearch]**

**更多Java操作请移步**[ElasticSearch教程——Java常用操作][ElasticSearch_Java]

# 基础环境 #

注意pom中的jar包版本，最好是和服务器上的elasticsearch版本一致，目前就测试来看，不一致貌似也没啥大的影响

![70][]

# pom.xml #

<?xml version="1.0" encoding="UTF-8"?>
    <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    	xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    	<modelVersion>4.0.0</modelVersion>
    
    	<groupId>com.elasticsearch</groupId>
    	<artifactId>elasticSearch</artifactId>
    	<version>0.0.1-SNAPSHOT</version>
    	<packaging>jar</packaging>
    
    	<name>elasticSearch</name>
    	<description>Demo project for elasticsearch</description>
    
    	<parent>
    		<groupId>org.springframework.boot</groupId>
    		<artifactId>spring-boot-starter-parent</artifactId>
    		<version>2.0.5.RELEASE</version>
    		<relativePath/> 
    	</parent>
    
    	<properties>
    		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    		<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
    		<java.version>1.8</java.version>
    		<elsaticsearch.version>6.4.0</elsaticsearch.version>
    	</properties>
    
    	<dependencies>
    		<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter-web</artifactId>
    		</dependency>
    
    		<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter-test</artifactId>
    			<scope>test</scope>
    		</dependency>
    		<dependency>
    		    <groupId>org.elasticsearch.client</groupId>
    		    <artifactId>elasticsearch-rest-client</artifactId>
    		    <version>${elsaticsearch.version}</version>
    		</dependency>
    		<dependency>
    	        <groupId>org.elasticsearch.client</groupId>
    	        <artifactId>transport</artifactId>
    	        <version>${elsaticsearch.version}</version>
    		</dependency>
    		<dependency>
    	        <groupId>org.elasticsearch.plugin</groupId>
    	        <artifactId>transport-netty4-client</artifactId>
    	        <version>${elsaticsearch.version}</version>
    	   </dependency>
    		<dependency>
    		    <groupId>org.elasticsearch</groupId>
    		    <artifactId>elasticsearch</artifactId>
    		    <version>${elsaticsearch.version}</version>
    		</dependency>
    		<dependency>
    		    <groupId>org.elasticsearch.client</groupId>
    		    <artifactId>elasticsearch-rest-high-level-client</artifactId>
    		    <version>${elsaticsearch.version}</version>
    		    <type>pom</type>
    		</dependency>
    		<dependency>
    		    <groupId>commons-lang</groupId>
    		    <artifactId>commons-lang</artifactId>
    		    <version>2.6</version>
    		</dependency>
    	</dependencies>
    
    	<build>
    		<plugins>
    			<plugin>
    				<groupId>org.springframework.boot</groupId>
    				<artifactId>spring-boot-maven-plugin</artifactId>
    			</plugin>
    		</plugins>
    	</build>
    </project>

# HighLight.java #

package com.gwd.elasticsearch.test;
    
    import java.net.InetAddress;
    import java.net.UnknownHostException;
    
    import org.elasticsearch.action.search.SearchResponse;
    import org.elasticsearch.client.transport.TransportClient;
    import org.elasticsearch.common.settings.Settings;
    import org.elasticsearch.common.text.Text;
    import org.elasticsearch.common.transport.TransportAddress;
    import org.elasticsearch.index.query.QueryBuilder;
    import org.elasticsearch.index.query.QueryBuilders;
    import org.elasticsearch.search.SearchHit;
    import org.elasticsearch.search.SearchHits;
    import org.elasticsearch.search.fetch.subphase.highlight.HighlightBuilder;
    import org.elasticsearch.transport.client.PreBuiltTransportClient;
    
    /**
     * Description:
     * 作者：gu.weidong(Jack)
     * date:2018年9月18日
     * ProjectName:elasticSearch
     */
    public class HighLight {
    	public static void main(String[] args) throws UnknownHostException {
            // TODO Auto-generated method stub
            // 设置集群名称
            Settings settings = Settings.builder()
                    .put("cluster.name", "elasticsearch").build();
            // 创建client
            TransportClient client = new PreBuiltTransportClient(settings). addTransportAddress(new TransportAddress(InetAddress.getByName("XXX.XXX.XX.XX"), 9300));//本地的话，可以使用 localhost，9300是默认的 api 访问接口
            QueryBuilder matchQuery = QueryBuilders.matchQuery("title", "Elasticsearch");
            HighlightBuilder hiBuilder=new HighlightBuilder();
            hiBuilder.preTags("<h2>");
            hiBuilder.postTags("</h2>");
            hiBuilder.field("title");
            // 搜索数据
            SearchResponse response = client.prepareSearch("blog")
                    .setQuery(matchQuery)
                    .highlighter(hiBuilder)
                    .execute().actionGet();
            //获取查询结果集
            SearchHits searchHits = response.getHits();
            System.out.println("共搜到:"+searchHits.getTotalHits()+"条结果!");
            //遍历结果
            for(SearchHit hit:searchHits){
                System.out.println("String方式打印文档搜索内容:");
                System.out.println(hit.getSourceAsString());
                System.out.println("Map方式打印高亮内容");
                System.out.println(hit.getHighlightFields());
    
                System.out.println("遍历高亮集合，打印高亮片段:");
                Text[] text = hit.getHighlightFields().get("title").getFragments();
                for (Text str : text) {
                    System.out.println(str.string());
                }
            }
        }
    }

# 注意 #

在pom.xml配置文件中务必加入

dependency>
    	 <groupId>org.elasticsearch.plugin</groupId>
    	 <artifactId>transport-netty4-client</artifactId>
    	 <version>6.4.0</version>
    </dependency>

否则会报如下错误：

Exception in thread "main" java.lang.NoClassDefFoundError: org/elasticsearch/common/transport/InetSocketTransportAddress
    	at org.elasticsearch.transport.Netty4Plugin.getSettings(Netty4Plugin.java:55)
    	at org.elasticsearch.plugins.PluginsService.lambda$getPluginSettings$0(PluginsService.java:87)
    	at java.util.stream.ReferencePipeline$7$1.accept(ReferencePipeline.java:267)
    	at java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1380)
    	at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:481)
    	at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:471)
    	at java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:708)
    	at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
    	at java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:499)
    	at org.elasticsearch.plugins.PluginsService.getPluginSettings(PluginsService.java:87)
    	at org.elasticsearch.client.transport.TransportClient.buildTemplate(TransportClient.java:145)
    	at org.elasticsearch.client.transport.TransportClient.<init>(TransportClient.java:283)
    	at org.elasticsearch.transport.client.PreBuiltTransportClient.<init>(PreBuiltTransportClient.java:128)
    	at org.elasticsearch.transport.client.PreBuiltTransportClient.<init>(PreBuiltTransportClient.java:114)
    	at org.elasticsearch.transport.client.PreBuiltTransportClient.<init>(PreBuiltTransportClient.java:104)
    	at com.gwd.elasticsearch.test.HighLight.main(HighLight.java:31)
    Caused by: java.lang.ClassNotFoundException: org.elasticsearch.common.transport.InetSocketTransportAddress
    	at java.net.URLClassLoader.findClass(URLClassLoader.java:381)
    	at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
    	at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:335)
    	at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
    	... 16 more

# 查询结果 #

共搜到:2条结果!
    String方式打印文档搜索内容:
    
    {
          "title": "New version of Elasticsearch released!",
          "content": "Version 1.0 released today!",
          "priority": 10,
          "tags": ["announce", "elasticsearch", "release"]
    }
    Map方式打印高亮内容
    {title=[title], fragments[[New version of <h2>Elasticsearch</h2> released!]]}
    遍历高亮集合，打印高亮片段:
    New version of <h2>Elasticsearch</h2> released!
    String方式打印文档搜索内容:
    
    {
          "id": "1",
          "title": "New version of Elasticsearch released!",
          "content": "Version 1.0 released today!",
          "priority": 10,
          "tags": ["announce", "elasticsearch", "release"]
    }
    Map方式打印高亮内容
    {title=[title], fragments[[New version of <h2>Elasticsearch</h2> released!]]}
    遍历高亮集合，打印高亮片段:
    New version of <h2>Elasticsearch</h2> released!

[ElasticSearch]: https://blog.csdn.net/gwd1154978352/article/details/82781731
[ElasticSearch_Java]: https://blog.csdn.net/gwd1154978352/article/details/82777273
[70]: /images/20210923/2e43550ce13847dab18e4e658876d0ce.png