spring5+spring-data-elasticsearch集成

怼烎@ 2022-05-31 03:08 281阅读 0赞

#### 一、搞定依赖    ####

<properties>
    	<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    	<spring.version>5.0.0.RELEASE</spring.version>
    	<spring-data-es.version>3.0.0.RELEASE</spring-data-es.version>
    	<java.encoding>UTF-8</java.encoding>
    	<java.version>1.8</java.version>
    	<jackson.version>2.9.0</jackson.version>
    	<dubbo.version>2.5.5.cat-SNAPSHOT</dubbo.version>
    </properties>

<dependency>
    	<groupId>org.springframework</groupId>
    	<artifactId>spring-aop</artifactId>
    	<version>${spring.version}</version>
    </dependency>
    <dependency>
    	<groupId>org.springframework</groupId>
    	<artifactId>spring-beans</artifactId>
    	<version>${spring.version}</version>
    </dependency>
    <dependency>
    	<groupId>org.springframework</groupId>
    	<artifactId>spring-context</artifactId>
    	<version>${spring.version}</version>
    </dependency>
    <dependency>
    	<groupId>org.springframework</groupId>
    	<artifactId>spring-context-support</artifactId>
    	<version>${spring.version}</version>
    </dependency>
    <dependency>
    	<groupId>org.springframework</groupId>
    	<artifactId>spring-core</artifactId>
    	<version>${spring.version}</version>
    </dependency>
    <dependency>
    	<groupId>org.springframework</groupId>
    	<artifactId>spring-expression</artifactId>
    	<version>${spring.version}</version>
    </dependency>
    <dependency>
    	<groupId>org.springframework</groupId>
    	<artifactId>spring-jdbc</artifactId>
    	<version>${spring.version}</version>
    </dependency>
    <dependency>
    	<groupId>org.springframework</groupId>
    	<artifactId>spring-orm</artifactId>
    	<version>${spring.version}</version>
    </dependency>
    <dependency>
    	<groupId>org.springframework</groupId>
    	<artifactId>spring-tx</artifactId>
    	<version>${spring.version}</version>
    </dependency>
    <dependency>
    	<groupId>org.springframework</groupId>
    	<artifactId>spring-web</artifactId>
    	<version>${spring.version}</version>
    </dependency>
    <dependency>
    	<groupId>org.springframework</groupId>
    	<artifactId>spring-webmvc</artifactId>
    	<version>${spring.version}</version>
    </dependency>
    <dependency>
    	<groupId>org.springframework</groupId>
    	<artifactId>spring-aspects</artifactId>
    	<version>${spring.version}</version>
    </dependency>
    <dependency>
    	<groupId>org.springframework</groupId>
    	<artifactId>spring-test</artifactId>
    	<version>${spring.version}</version>
    </dependency>

<dependency>
    	<groupId>org.springframework.data</groupId>
    	<artifactId>spring-data-elasticsearch</artifactId>
    	<version>${spring-data-es.version}</version>
    </dependency>

以上供参考，供参考。

#### 二、spring配置 ####

<?xml version="1.0" encoding="UTF-8"?>
    <beans xmlns="http://www.springframework.org/schema/beans"
           xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
           xmlns:elasticsearch="http://www.springframework.org/schema/data/elasticsearch"
           xsi:schemaLocation="
           http://www.springframework.org/schema/data/elasticsearch
           http://www.springframework.org/schema/data/elasticsearch/spring-elasticsearch.xsd
           http://www.springframework.org/schema/beans
    	   http://www.springframework.org/schema/beans/spring-beans.xsd">
    
        
        
         <elasticsearch:transport-client id="es.transport.client"
                                         cluster-nodes="${cluster-nodes}"
                                         cluster-name="${clusterName}"
                                         client-transport-sniff="true"/>
    
        
        <bean id="elasticsearchTemplate" class="org.springframework.data.elasticsearch.core.ElasticsearchTemplate">
            <constructor-arg name="client" ref="es.transport.client"/>
        </bean>
    
        
        <elasticsearch:repositories base-package="com.**.elasticsearch.dao"/>
    
        
        <context:component-scan base-package="com.**.elasticsearch.service"/>
    
    </beans>

#### 三、编写代码 ####

model类：

import org.springframework.data.annotation.Id;
    import org.springframework.data.elasticsearch.annotations.Document;
    
    @Document(indexName="aa", type = "bb")
    public class Goods {
        @Id
        private String id; // id必须有
        private String udateTime;
        private String sku_no;
    // 省略get/set

dao类：

import org.springframework.data.elasticsearch.annotations.Query;
    import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
    
    public interface GoodsDao extends ElasticsearchRepository<Goods, String> {
    
        /**
         * 根据skuNo查询商品
         * 此处必须有 @Query指定查询字段名称：sku_no，否则报错
         */
        @Query("{\"bool\" : {\"must\" : {\"term\" : {\"sku_no\" : \"?0\"}}}}")
        Goods findBySkuNo(String skuNo);
    
        /**
         * 功能描述：根据udateTime查询商品
         */
        Goods findByUdateTime(String udateTime);
    }

service类：

@Service
    public class GoodsService {
        @Autowired
        private GoodsDao esDao;
    
        public Goods findBySkuNo(String skuNo) {
            return esDao.findBySkuNo(skuNo);
        }
    
        public Goods findByUdateTime(String udateTime) {
            return esDao.findByUdateTime(udateTime);
        }
    }

controller类：

@Controller
    @RequestMapping("/")
    public class TestController {
        @Autowired
        private GoodsService goodsService;
    
        @RequestMapping("get")
        @ResponseBody
        public Object get(String skuNo) {
            return goodsService.findBySkuNo(skuNo);
        }
        // 以下省略

#### 四、错误排查 ####

1、NoNodeAvailableException\[None of the configured nodes are available

原因：es客户端版本与服务端版本不一致。客户端与服务端大版本必须一致。

2、Caused by: java.lang.AbstractMethodError: org.springframework.data.elasticsearch.repository.config.ElasticsearchRepositoryConfigExtension.getRepositoryFactoryClassName()Ljava/lang/String;  
原因：spring-data-commons包冲突。升级为2.0.0.RELEASE，并排除低版本依赖

3、netty版本排除，只保留spring-data-elasticsearch引入的netty

<exclusion>  
                    <groupId>io.netty</groupId>  
                    <artifactId>netty-all</artifactId>  
                </exclusion>

4、Initialization of bean failed; java.lang.AbstractMethodError  
解决：升级spring版本到合适版本