zoukankan      html  css  js  c++  java
  • 全文检索工具elasticsearch:第三章: Java程序中的应用

    搭建模块

    创建二个项目

    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:

    <?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>
    	<parent>
    		<groupId>com.javawxid.gmall</groupId>
    		<artifactId>gmall-parent</artifactId>
    		<version>1.0-SNAPSHOT</version>
    	</parent>
    	<groupId>com.javawxid.gmall</groupId>
    	<artifactId>gmall-list-service</artifactId>
    	<version>0.0.1-SNAPSHOT</version>
    	<name>gmall-list-service</name>
    	<description>Demo project for Spring Boot</description>
    
    	<properties>
    		<java.version>1.8</java.version>
    	</properties>
    
    	<dependencies>
    		<dependency>
    			<groupId>com.javawxid.gmall</groupId>
    			<artifactId>gmall-service-util</artifactId>
    			<version>1.0-SNAPSHOT</version>
    		</dependency>
    
    		<dependency>
    			<groupId>com.javawxid.gmall</groupId>
    			<artifactId>gmall-api</artifactId>
    			<version>1.0-SNAPSHOT</version>
    		</dependency>
    
    		<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter-data-elasticsearch</artifactId>
    		</dependency>
                    <!-- 导入Jest依赖 -->
    		<!-- https://mvnrepository.com/artifact/io.searchbox/jest -->
    		<dependency>
    			<groupId>io.searchbox</groupId>
    			<artifactId>jest</artifactId>
    			<version>5.3.3</version>
    		</dependency>
    
    
    		<!-- https://mvnrepository.com/artifact/net.java.dev.jna/jna -->
    		<dependency>
    			<groupId>net.java.dev.jna</groupId>
    			<artifactId>jna</artifactId>
    			<version>4.5.1</version>
    		</dependency>
    	</dependencies>
    
    	<build>
    		<plugins>
    			<plugin>
    				<groupId>org.springframework.boot</groupId>
    				<artifactId>spring-boot-maven-plugin</artifactId>
    			</plugin>
    		</plugins>
    	</build>
    
    </project>
    

    其中jest和jna请将版本号,部分纳入gmall-parent中管理。spring-boot-starter-data-elasticsearch不用管理版本号,其版本跟随springboot的1.5.10大版本号。 

    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:

    <?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>
    	<parent>
    		<groupId>com.javawxid.gmall</groupId>
    		<artifactId>gmall-parent</artifactId>
    		<version>1.0-SNAPSHOT</version>
    	</parent>
    	<groupId>com.javawxid.gmall</groupId>
    	<artifactId>gmall-list-web</artifactId>
    	<version>0.0.1-SNAPSHOT</version>
    	<name>gmall-list-web</name>
    	<description>Demo project for Spring Boot</description>
    
    	<properties>
    		<java.version>1.8</java.version>
    	</properties>
    
    	<dependencies>
    		<dependency>
    			<groupId>com.javawxid.gmall</groupId>
    			<artifactId>gmall-api</artifactId>
    			<version>1.0-SNAPSHOT</version>
    		</dependency>
    
    		<dependency>
    			<groupId>com.javawxid.gmall</groupId>
    			<artifactId>gmall-web-util</artifactId>
    			<version>1.0-SNAPSHOT</version>
    		</dependency>
    	</dependencies>
    
    	<build>
    		<plugins>
    			<plugin>
    				<groupId>org.springframework.boot</groupId>
    				<artifactId>spring-boot-maven-plugin</artifactId>
    			</plugin>
    		</plugins>
    	</build>
    
    </project>
    

     

    2、 关于es 的java 客户端的选择

    目前市面上有两类客户端

    一类是TransportClient 为代表的ES原生客户端,不能执行原生dsl语句必须使用它的Java api方法。

    另外一种是以Rest Api为主的missing client,最典型的就是jest。 这种客户端可以直接使用dsl语句拼成的字符串,直接传给服务端,然后返回json字符串再解析。

    两种方式各有优劣,但是最近elasticsearch官网,宣布计划在7.0以后的版本中废除TransportClient。以RestClient为主。

    所以在官方的RestClient 基础上,进行了简单包装的Jest客户端,就成了首选,而且该客户端也与springboot完美集成。

    3插入数据

    PUT /movie_chn/movie/1

    { "id":1,

      "name":"红海行动",

      "doubanScore":8.5,

      "actorList":[  

      {"id":1,"name":"张译"},

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

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

     ]

    }

    PUT /movie_chn/movie/2

    {

      "id":2,

      "name":"湄公河行动",

      "doubanScore":8.0,

      "actorList":[  

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

    ]

    }

    PUT /movie_chn/movie/3

    {

      "id":3,

      "name":"红海事件",

      "doubanScore":5.0,

      "actorList":[  

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

    ]

    }

    4、在测试类中测试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="{
    " +
    				"  "query": {
    " +
    				"    "match": {
    " +
    				"      "actorList.name": "张译"
    " +
    				"    }
    " +
    				"  }
    " +
    				"}";
    		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);
    		}
    
    	}
    
    	
    
    }
    
    

    打印结果:

    source = {doubanScore=8.5, es_metadata_id=1, name=红海行动, 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=湄公河行动, actorList=[{id=3.0, name=张涵予}], id=2.0}

    以上技术方面的准备就做好了。

  • 相关阅读:
    一、JQuery选择器
    二、HelloMaven-第一个Maven项目
    一、maven的简介和环境搭建
    Junit源码
    五、spring和Hibernate整合
    JS 冒泡排序从学到优化
    JS小案例(基础好烦恼少)----持续更新
    JS+PHP实现用户输入数字后取得最大的值并显示为第几个
    将博客搬至CSDN
    HTML表单相关
  • 原文地址:https://www.cnblogs.com/javawxid/p/12811990.html
Copyright © 2011-2022 走看看