Spring Boot整合elasticsearch的详细步骤

#下载镜像

docker pull elasticsearch

#启动镜像，elasticsearch 启动是会默认分配2g的内存 ，我们启动是设置小一点，防止我们内存不够启动失败

# 9200 是elasticsearch 默认的web通信接口， 9300 是分布式情况下，elasticsearch个节点通信的端口

docker run -e es_java_opts= "-xms256m -xmx256m" -d -p 9200 : 9200 -p 9300 : 9300 --name es01 5c1e1ecfe33a

<?xml version= "1.0" encoding= "utf-8" ?>

<project xmlns= "http://maven.apache.org/pom/4.0.0" xmlns:xsi= "http://HdhCmsTestw3.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.gf</groupid>

   <artifactid>springboot-elasticsearch</artifactid>

   <version> 0.0 . 1 -snapshot</version>

   <packaging>jar</packaging>

   <name>springboot-elasticsearch</name>

   <description>demo project for spring boot</description>

   <parent>

     <groupid>org.springframework.boot</groupid>

     <artifactid>spring-boot-starter-parent</artifactid>

     <version> 2.1 . 1 .release</version>

     <relativepath/> <!-- lookup parent from repository -->

   </parent>

   <properties>

     <project.build.sourceencoding>utf- 8 </project.build.sourceencoding>

     <project.reporting.outputencoding>utf- 8 </project.reporting.outputencoding>

     <java.version> 1.8 </java.version>

   </properties>

   <dependencies>

     <dependency>

     <groupid>org.springframework.boot</groupid>

     <artifactid>spring-boot-starter-data-elasticsearch</artifactid>

   </dependency>

     <dependency>

       <groupid>io.searchbox</groupid>

       <artifactid>jest</artifactid>

       <version> 5.3 . 3 </version>

     </dependency>

     <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>

   </dependencies>

   <build>

     <plugins>

       <plugin>

         <groupid>org.springframework.boot</groupid>

         <artifactid>spring-boot-maven-plugin</artifactid>

       </plugin>

     </plugins>

   </build>

</project>

spring.elasticsearch.jest.uris=http: //127.0.0.1:9200

package com.gf.entity;

import io.searchbox.annotations.jestid;

public class article {

   @jestid

   private integer id;

   private string author;

   private string title;

   private string content;

   public integer getid() {

     return id;

   }

   public void setid(integer id) {

     this .id = id;

   }

   public string getauthor() {

     return author;

   }

   public void setauthor(string author) {

     this .author = author;

   }

   public string gettitle() {

     return title;

   }

   public void settitle(string title) {

     this .title = title;

   }

   public string getcontent() {

     return content;

   }

   public void setcontent(string content) {

     this .content = content;

   }

   @override

   public string tostring() {

     final stringbuilder sb = new stringbuilder( "{\"article\":{" );

     sb.append( "\"id\":" )

         .append( id );

     sb.append( ",\"author\":\"" )

         .append( author ).append( '\"' );

     sb.append( ",\"title\":\"" )

         .append( title ).append( '\"' );

     sb.append( ",\"content\":\"" )

         .append( content ).append( '\"' );

     sb.append( "}}" );

     return sb.tostring();

   }

}

package com.gf;

import com.gf.entity.article;

import io.searchbox.client.jestclient;

import io.searchbox.core.index;

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;

@runwith (springrunner. class )

@springboottest

public class springbootelasticsearchapplicationtests {

   @autowired

   jestclient jestclient;

   @test

   public void createindex() {

     //1. 给es中索引(保存)一个文档

     article article = new article();

     article.setid( 1 );

     article.settitle( "好消息" );

     article.setauthor( "张三" );

     article.setcontent( "hello world" );

     //2. 构建一个索引

     index index = new index.builder( article ).index( "gf" ).type( "news" ).build();

     try {

       //3. 执行

       jestclient.execute( index );

     } catch (ioexception e) {

       e.printstacktrace();

     }

   }

   @test

   public void search() {

     //查询表达式

     string query = "{\n" +

         "  \"query\" : {\n" +

         "    \"match\" : {\n" +

         "      \"content\" : \"hello\"\n" +

         "    }\n" +

         "  }\n" +

         "}" ;

     //构建搜索功能

     search search = new search.builder( query ).addindex( "gf" ).addtype( "news" ).build();

     try {

       //执行

       searchresult result = jestclient.execute( search );

       system.out.println(result.getjsonstring());

     } catch (ioexception e) {

       e.printstacktrace();

     }

   }

}

spring.data.elasticsearch.cluster-name=elasticsearch

spring.data.elasticsearch.cluster-nodes= 127.0 . 0.1 : 9300

package com.gf.entity;

@document ( indexname = "gf" , type = "book" )

public class book {

   private integer id;

   private string bookname;

   private string author;

   public integer getid() {

     return id;

   }

   public void setid(integer id) {

     this .id = id;

   }

   public string getbookname() {

     return bookname;

   }

   public void setbookname(string bookname) {

     this .bookname = bookname;

   }

   public string getauthor() {

     return author;

   }

   public void setauthor(string author) {

     this .author = author;

   }

   @override

   public string tostring() {

     final stringbuilder sb = new stringbuilder( "{\"book\":{" );

     sb.append( "\"id\":" )

         .append( id );

     sb.append( ",\"bookname\":\"" )

         .append( bookname ).append( '\"' );

     sb.append( ",\"author\":\"" )

         .append( author ).append( '\"' );

     sb.append( "}}" );

     return sb.tostring();

   } 

}

package com.gf.repository;

import com.gf.entity.book;

import org.springframework.data.elasticsearch.repository.elasticsearchrepository;

import java.util.list;

public interface bookrepository extends elasticsearchrepository<book, integer>{

   list<book> findbybooknamelike(string bookname);

}

package com.gf;

import com.gf.entity.article;

import com.gf.entity.book;

import com.gf.repository.bookrepository;

import io.searchbox.client.jestclient;

import io.searchbox.core.index;

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.list;

@runwith (springrunner. class )

@springboottest

public class springbootelasticsearchapplicationtests {

   @autowired

   bookrepository bookrepository;

   @test

   public void createindex2(){

     book book = new book();

     book.setid( 1 );

     book.setbookname( "西游记" );

     book.setauthor( "吴承恩" );

     bookrepository.index( book );

   }

   @test

   public void usefind() {

     list<book> list = bookrepository.findbybooknamelike( "游" );

     for (book book : list) {

       system.out.println(book);

     }

   }

}

docker pull elasticsearch: 6.5 . 1

docker run -e es_java_opts= "-xms256m -xmx256m" -d -p 9200 : 9200 -p 9300 : 9300 --name es02 镜像id

spring.data.elasticsearch.cluster-name=docker-cluster

spring.data.elasticsearch.cluster-nodes= 127.0 . 0.1 : 9300