全文檢索工具elasticsearch：第三章： Java程序中的應(yīng)用

搭建模塊

 







創(chuàng)建二個(gè)項(xiàng)目

 










gmall-list-service的appliction.properties:

    server.port=8073
    spring.datasource.url=jdbc:mysql://localhost:3306/gmall?characterEncoding=UTF-8
    spring.datasource.username=root
    spring.datasource.password=root
     
    mybatis.configuration.map-underscore-to-camel-case=true
    mybatis.mapper-locations=classpath:mapper/*Mapper.xml
     
    spring.dubbo.registry.protocol=zookeeper
    spring.dubbo.registry.address=192.168.0.100:2181
     
    spring.dubbo.application.name=gmall-list-service
    spring.dubbo.protocol.name=dubbo
    spring.dubbo.base-package=com.javawxid
     
    spring.elasticsearch.jest.uris=http://192.168.0.100:9200
     
    logging.level.root=info
     

gmall-list-service的pom.xml:

   

  1. <?xml version="1.0" encoding="UTF-8"?>
  2.     <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  3.         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  4.         <modelVersion>4.0.0</modelVersion>
  5.         <parent>
  6.             <groupId>com.javawxid.gmall</groupId>
  7.             <artifactId>gmall-parent</artifactId>
  8.             <version>1.0-SNAPSHOT</version>
  9.         </parent>
  10.         <groupId>com.javawxid.gmall</groupId>
  11.         <artifactId>gmall-list-service</artifactId>
  12.         <version>0.0.1-SNAPSHOT</version>
  13.         <name>gmall-list-service</name>
  14.         <description>Demo project for Spring Boot</description>
  15.      
  16.         <properties>
  17.             <java.version>1.8</java.version>
  18.         </properties>
  19.      
  20.         <dependencies>
  21.             <dependency>
  22.                 <groupId>com.javawxid.gmall</groupId>
  23.                 <artifactId>gmall-service-util</artifactId>
  24.                 <version>1.0-SNAPSHOT</version>
  25.             </dependency>
  26.      
  27.             <dependency>
  28.                 <groupId>com.javawxid.gmall</groupId>
  29.                 <artifactId>gmall-api</artifactId>
  30.                 <version>1.0-SNAPSHOT</version>
  31.             </dependency>
  32.      
  33.             <dependency>
  34.                 <groupId>org.springframework.boot</groupId>
  35.                 <artifactId>spring-boot-starter-data-elasticsearch</artifactId>
  36.             </dependency>
  37.                     <!-- 導(dǎo)入Jest依賴 -->
  38.             <!-- https://mvnrepository.com/artifact/io.searchbox/jest -->
  39.             <dependency>
  40.                 <groupId>io.searchbox</groupId>
  41.                 <artifactId>jest</artifactId>
  42.                 <version>5.3.3</version>
  43.             </dependency>
  44.      
  45.      
  46.             <!-- https://mvnrepository.com/artifact/net.java.dev.jna/jna -->
  47.             <dependency>
  48.                 <groupId>net.java.dev.jna</groupId>
  49.                 <artifactId>jna</artifactId>
  50.                 <version>4.5.1</version>
  51.             </dependency>
  52.         </dependencies>
  53.      
  54.         <build>
  55.             <plugins>
  56.                 <plugin>
  57.                     <groupId>org.springframework.boot</groupId>
  58.                     <artifactId>spring-boot-maven-plugin</artifactId>
  59.                 </plugin>
  60.             </plugins>
  61.         </build>
  62.      
  63.     </project>

其中jest和jna請(qǐng)將版本號(hào)，部分納入gmall-parent中管理。spring-boot-starter-data-elasticsearch不用管理版本號(hào)，其版本跟隨springboot的1.5.10大版本號(hào)。

gmall-list-web的appliction.properties:

    server.port=8083
     
    spring.dubbo.registry.address=192.168.0.100:2181
     
    spring.dubbo.protocol.name=dubbo
    spring.dubbo.application.name=gmall-list-web
    spring.dubbo.base-package=com.javawxid
     
    spring.dubbo.consumer.timeout=600000
    spring.dubbo.consumer.check=false
     
    spring.thymeleaf.mode=LEGACYHTML5
    spring.thymeleaf.cache=false
     
    logging.level.root=info

gmall-list-web的pom.xml:

  

  1.  <?xml version="1.0" encoding="UTF-8"?>
  2.     <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  3.         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  4.         <modelVersion>4.0.0</modelVersion>
  5.         <parent>
  6.             <groupId>com.javawxid.gmall</groupId>
  7.             <artifactId>gmall-parent</artifactId>
  8.             <version>1.0-SNAPSHOT</version>
  9.         </parent>
  10.         <groupId>com.javawxid.gmall</groupId>
  11.         <artifactId>gmall-list-web</artifactId>
  12.         <version>0.0.1-SNAPSHOT</version>
  13.         <name>gmall-list-web</name>
  14.         <description>Demo project for Spring Boot</description>
  15.      
  16.         <properties>
  17.             <java.version>1.8</java.version>
  18.         </properties>
  19.      
  20.         <dependencies>
  21.             <dependency>
  22.                 <groupId>com.javawxid.gmall</groupId>
  23.                 <artifactId>gmall-api</artifactId>
  24.                 <version>1.0-SNAPSHOT</version>
  25.             </dependency>
  26.      
  27.             <dependency>
  28.                 <groupId>com.javawxid.gmall</groupId>
  29.                 <artifactId>gmall-web-util</artifactId>
  30.                 <version>1.0-SNAPSHOT</version>
  31.             </dependency>
  32.         </dependencies>
  33.      
  34.         <build>
  35.             <plugins>
  36.                 <plugin>
  37.                     <groupId>org.springframework.boot</groupId>
  38.                     <artifactId>spring-boot-maven-plugin</artifactId>
  39.                 </plugin>
  40.             </plugins>
  41.         </build>
  42.      
  43.     </project>

 
2、 關(guān)于es 的java 客戶端的選擇

目前市面上有兩類客戶端

一類是TransportClient 為代表的ES原生客戶端，不能執(zhí)行原生dsl語(yǔ)句必須使用它的Java api方法。

另外一種是以Rest Api為主的missing client，最典型的就是jest。 這種客戶端可以直接使用dsl語(yǔ)句拼成的字符串，直接傳給服務(wù)端，然后返回json字符串再解析。

兩種方式各有優(yōu)劣，但是最近elasticsearch官網(wǎng)，宣布計(jì)劃在7.0以后的版本中廢除TransportClient。以RestClient為主。

所以在官方的RestClient 基礎(chǔ)上，進(jìn)行了簡(jiǎn)單包裝的Jest客戶端，就成了首選，而且該客戶端也與springboot完美集成。
3、插入數(shù)據(jù)

PUT /movie_chn/movie/1

{ "id":1,

  "name":"紅海行動(dòng)",

  "doubanScore":8.5,

  "actorList":[  

  {"id":1,"name":"張譯"},

  {"id":2,"name":"海清"},

  {"id":3,"name":"張涵予"}

 ]

}

PUT /movie_chn/movie/2

{

  "id":2,

  "name":"湄公河行動(dòng)",

  "doubanScore":8.0,

  "actorList":[  

{"id":3,"name":"張涵予"}

]

}

PUT /movie_chn/movie/3

{

  "id":3,

  "name":"紅海事件",

  "doubanScore":5.0,

  "actorList":[  

{"id":4,"name":"張晨"}

]

}
4、在測(cè)試類中測(cè)試ES

    package com.javawxid;
     
    import io.searchbox.client.JestClient;
    import io.searchbox.core.Search;
    import io.searchbox.core.SearchResult;
    import org.junit.Test;
    import org.junit.runner.RunWith;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.boot.test.context.SpringBootTest;
    import org.springframework.test.context.junit4.SpringRunner;
    import java.io.IOException;
    import java.util.HashMap;
    import java.util.List;
     
    @RunWith(SpringRunner.class)
    @SpringBootTest
    public class GmallListServiceApplicationTests {
     
        @Autowired
        JestClient jestClient;
     
        @Test
        public void testEs() throws IOException {
            String query="{\n" +
                    "  \"query\": {\n" +
                    "    \"match\": {\n" +
                    "      \"actorList.name\": \"張譯\"\n" +
                    "    }\n" +
                    "  }\n" +
                    "}";
            Search search = new Search.Builder(query).addIndex("movie_chn").addType("movie").build();
     
            SearchResult result = jestClient.execute(search);
     
            List<SearchResult.Hit<HashMap, Void>> hits = result.getHits(HashMap.class);
     
            for (SearchResult.Hit<HashMap, Void> hit : hits) {
                HashMap source = hit.source;
                System.err.println("source = " + source);
            }
     
        }
     
        
     
    }
     

打印結(jié)果：

    source = {doubanScore=8.5, es_metadata_id=1, name=紅海行動(dòng), actorList=[{id=1.0, name=張譯}, {id=2.0, name=海清}, {id=3.0, name=張涵予}], id=1.0}
    source = {doubanScore=5.0, es_metadata_id=3, name=紅海事件, actorList=[{id=4.0, name=張晨}], id=3.0}
    source = {doubanScore=8.0, es_metadata_id=2, name=湄公河行動(dòng), actorList=[{id=3.0, name=張涵予}], id=2.0}

以上技術(shù)方面的準(zhǔn)備就做好了。