SpringBoot 2.0 集成 spring-data-elasticsearch

其实是 spring cloud 集成 es 的, 但是我想了下 还是把标题写成 spring boot 的吧,因为 cloud 的实现都是基于 spring boot ,我这 es 模块也是 cloud 里的一个服务而已....

微服务目录结构...

我在 module 下新建了一个 spring boot 取名 es ,用来 ElasticSearch 独立服务使用

pom 依赖...

aerocloud-es
com.aerocloud
1.0.0

4.0.0

<artifactId>aerocloud-es-server</artifactId>
<packaging>jar</packaging>
<version>1.0.0</version>
<dependencies>
    <!-- es 依赖-->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-data-elasticsearch</artifactId>
    </dependency>

    <!--<dependency>-->
        <!--<groupId>org.springframework.data</groupId>-->
        <!--<artifactId>spring-data-elasticsearch</artifactId>-->
    <!--</dependency>-->


    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-test</artifactId>
        <scope>test</scope>
    </dependency>

    <dependency>
        <groupId>com.aerocloud</groupId>
        <artifactId>aerocloud-commons-tools</artifactId>
        <version>1.0.0</version>
    </dependency>
    <!--<dependency>-->
        <!--<groupId>com.aerocloud</groupId>-->
        <!--<artifactId>aerocloud-commons-mybatis</artifactId>-->
        <!--<version>1.0.0</version>-->
    <!--</dependency>-->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework</groupId>
        <artifactId>spring-context-support</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-stream</artifactId>
    </dependency>


    <!--<dependency>-->
        <!--<groupId>com.aerocloud</groupId>-->
        <!--<artifactId>aerocloud-commons-dynamic-datasource</artifactId>-->
        <!--<version>1.0.0</version>-->
    <!--</dependency>-->
    <dependency>
        <groupId>de.codecentric</groupId>
        <artifactId>spring-boot-admin-starter-client</artifactId>
        <version>${spring.boot.admin.version}</version>
    </dependency>



    <dependency>
        <groupId>io.swagger</groupId>
        <artifactId>swagger-annotations</artifactId>
        <version>1.5.20</version>
        <scope>compile</scope>
    </dependency>
    <dependency>
        <groupId>io.springfox</groupId>
        <artifactId>springfox-swagger2</artifactId>
    </dependency>
    <dependency>
        <groupId>com.aerocloud</groupId>
        <artifactId>aerocloud-es-client</artifactId>
        <version>1.0.0</version>
        <scope>compile</scope>
    </dependency>
    <dependency>
        <groupId>com.aerocloud</groupId>
        <artifactId>aerocloud-analysis-client</artifactId>
        <version>1.0.0</version>
        <scope>compile</scope>
    </dependency>

</dependencies>
<build>
    <finalName>${project.artifactId}</finalName>
    <plugins>
        <plugin>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-maven-plugin</artifactId>
            <configuration>
                <includeSystemScope>true</includeSystemScope>
            </configuration>
        </plugin>
        <plugin>
            <groupId>org.apache.maven.plugins</groupId>
            <artifactId>maven-surefire-plugin</artifactId>
            <configuration>
                <skipTests>true</skipTests>
            </configuration>
        </plugin>
        <plugin>
            <groupId>com.spotify</groupId>
            <artifactId>docker-maven-plugin</artifactId>
        </plugin>
    </plugins>
</build>

yml 配置

spring:
   data:
        elasticsearch:
            #cluster-name: #默认为elasticsearch
            cluster-nodes: 127.0.0.1:9300 #配置es节点信息，逗号分隔，如果没有指定，则启动ClientNode（9200端口是http查询使用的。9300集群使用。这里使用9300.）
            properties:
                path:
                  logs: ./elasticsearch/log #elasticsearch日志存储目录
                  data: ./elasticsearch/data #elasticsearch数据存储目录

/**
@Document注解里面的几个属性，类比mysql的话是这样：

index –> DB
type –> Table
Document –> row

 */
@Data
@Document(indexName = "cpdb", type = "cptesttable", shards = 1, replicas = 0)
public class cpTest {
    @Id
    private Long id;
    @Field(type = FieldType.Text, analyzer = "ik_max_word")
    private String title; //标题
    @Field(type = FieldType.Keyword)
    private String category;// 分类

    @Field(type = FieldType.Keyword)
    private String brand; // 品牌

    @Field(type = FieldType.Double)
    private Double price; // 价格

    @Field(index = false, type = FieldType.Keyword)
    private String images; // 图片地址


}

加上 @Id 注解后，在 Elasticsearch 里对应的该列就是主键了，在查询时就可以直接用主键查询。其实和 mysql 非常类似，基本就是一个数据库。

@Persistent
@Inherited
@Retention(RetentionPolicy.RUNTIME)
@Target({ElementType.TYPE})
public @interface Document {
    String indexName();//索引库的名称，个人建议以项目的名称命名
    String type() default "";//类型，个人建议以实体的名称命名
    short shards() default 5;//默认分区数
    short replicas() default 1;//每个分区默认的备份数
    String refreshInterval() default "1s";//刷新间隔
    String indexStoreType() default "fs";//索引文件存储类型
}

加上了 @Document 注解之后，默认情况下这个实体中所有的属性都会被建立索引、并且分词。
通过 @Field 注解来进行详细的指定，如果没有特殊需求，那么只需要添加 @Document 即可。

@Field注解的定义如下：  

@Retention(RetentionPolicy.RUNTIME)
@Target(ElementType.FIELD)
@Documented
@Inherited
public @interface Field {

    FieldType type() default FieldType.Auto;#自动检测属性的类型
    FieldIndex index() default FieldIndex.analyzed;#默认情况下分词
    DateFormat format() default DateFormat.none;
    String pattern() default "";
    boolean store() default false;#默认情况下不存储原文
    String searchAnalyzer() default "";#指定字段搜索时使用的分词器
    String indexAnalyzer() default "";#指定字段建立索引时指定的分词器
    String[] ignoreFields() default {};#如果某个字段需要被忽略
    boolean includeInParent() default false;
}

ElasticsearchRepository

/**
 * 只需要写接口 不需要写实现
*  不需要加@Component，直接可以@Autowared
 * spring data 自动通过方法命名去实现
 * 例子 findbyId    这个方法名自动实现通过Id查询对象
 */
public interface cpTestRepository extends ElasticsearchRepository<cpTest, Long> {



    List<cpTest> findByBrand(String name);



}

ElasticsearchRepository 内置了 crud 方法 方便简单功能使用
复杂的查询还是得 了解 dsl 语法用 elasticsearchTemplate 来构造条件去请求