Springboot之Elasticsearch篇

太过爱你忘了你带给我的痛 2023-06-06 03:42 3阅读 0赞

pom.xml

<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>
    
      <groupId>1.0.0</groupId>
      <artifactId>springboot-elasticsearch</artifactId>
      <version>0.0.1-SNAPSHOT</version>
        <build>
            <plugins>
                <plugin>
                    <groupId>org.apache.maven.plugins</groupId>
                    <artifactId>maven-compiler-plugin</artifactId>
                    <configuration>
                        <source>6</source>
                        <target>6</target>
                    </configuration>
                </plugin>
            </plugins>
        </build>
        <packaging>jar</packaging>
    
      <name>springboot-elasticsearch</name>
      <url>http://maven.apache.org</url>
    
      <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
        <java.version>1.8</java.version>
        <springBoot>1.5.9.RELEASE</springBoot>
        <jest.version>5.3.3</jest.version>
      </properties>
    
    
        <dependencies>
    
            
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-data-elasticsearch</artifactId>
                 <version>${springBoot}</version>
            </dependency>
    
    		
    	<dependency>
        	<groupId>io.searchbox</groupId> 
       		 <artifactId>jest</artifactId>
        	<version>${jest.version}</version>
    	</dependency>
    
    
            
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
                 <version>${springBoot}</version>
            </dependency>
            
    		<dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-devtools</artifactId>
                <optional>true</optional> 
                 <version>${springBoot}</version>
            </dependency>  
            
            
            
            
            <dependency>
                <groupId>junit</groupId>
                <artifactId>junit</artifactId>
                <version>4.12</version>
            </dependency>
        </dependencies>
    </project>

application.properties

banner.charset=UTF-8
    server.tomcat.uri-encoding=UTF-8
    spring.http.encoding.charset=UTF-8
    spring.http.encoding.enabled=true
    spring.http.encoding.force=true
    spring.messages.encoding=UTF-8
    
    
    # ES
    server.port=8086
    spring.data.elasticsearch.repositories.enabled = true
    spring.data.elasticsearch.cluster-nodes =127.0.0.1\:9300
    
    # log
    logging.level.root=INFO
    logging.level.org.springframework.web=WARN
    logging.file=./logs/mylog.log
    logging.pattern.console=%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger- %msg%n
    logging.pattern.file=%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger- %msg%n

User:

package com.pancm.pojo;
    
    import java.io.Serializable;
    
    import org.springframework.data.elasticsearch.annotations.Document;
    
    @Document(indexName = "userindex", type = "user")
    public class User implements Serializable{
    	
    	private static final long serialVersionUID = 1L;
    	/** 编号 */
    	 private Long id;
    	 /** 姓名 */
    	 private String name;
    	 
    	 /** 年龄 */
    	 private Integer age;
    	 
    	 /** 描述 */  
    	 private String description;
    	 
    	 /** 创建时间 */
    	 private String createtm;
    	 
    	 
    	 public User(){
    	 }
    
    	
    	public User(Long id, String name, Integer age, String description, String createtm) {
    		super();
    		this.id = id;
    		this.name = name;
    		this.age = age;
    		this.description = description;
    		this.createtm = createtm;
    	}
    
    	/**  
    	 * 获取编号  
    	 * @return  id  
    	 */
    	public Long getId() {
    		return id;
    	}
    
    
    	/**  
    	 * 设置编号  
    	 * @param  id
    	 */
    	public void setId(Long id) {
    		this.id = id;
    	}
    
    
    	/**  
    	 * 获取姓名  
    	 * @return  name  
    	 */
    	public String getName() {
    		return name;
    	}
    
    
    	/**  
    	 * 设置姓名  
    	 * @param name
    	 */
    	public void setName(String name) {
    		this.name = name;
    	}
    
    
    	/**  
    	 * 获取年龄  
    	 * @return  age  
    	 */
    	public Integer getAge() {
    		return age;
    	}
    
    
    	/**  
    	 * 设置年龄  
    	 * @param  age
    	 */
    	public void setAge(Integer age) {
    		this.age = age;
    	}
    
    
    	/**  
    	 * 获取描述  
    	 * @return  description  
    	 */
    	public String getDescription() {
    		return description;
    	}
    
    
    	/**  
    	 * 设置描述  
    	 * @param  description
    	 */
    	public void setDescription(String description) {
    		this.description = description;
    	}
    
    
    	/**  
    	 * 获取创建时间  
    	 * @return  createtm  
    	 */
    	public String getCreatetm() {
    		return createtm;
    	}
    
    
    	/**  
    	 * 设置创建时间  
    	 * @param  createtm
    	 */
    	public void setCreatetm(String createtm) {
    		this.createtm = createtm;
    	}
    	
    	@Override
    	public String toString() {
    		return "User [id=" + id + ", name=" + name + ", age=" + age + ", description=" + description + ", createtm="
    				+ createtm + "]";
    	}
    }

UserDao:

public interface UserDao extends ElasticsearchRepository<User, Long>{
    
    }

UserService:

public interface UserService {
    	
    	/**
         * 新增用户信息
         *
         * @param user
         * @return
         */
        boolean insert(User user);
    
        /**
         * 根据关键字进行全文搜索
         * @param searchContent
         * @return
         */
        List<User> search(String searchContent);
        
        /**
         * 根据关键字进行搜索并分页
         * @param pageNumber
         * @param pageSize
         * @param searchContent
         * @return
         */
        List<User> searchUser(Integer pageNumber, Integer pageSize, String searchContent);
    	
        /**
         * 根据关键词权重进行查询
         * @param searchContent
         * @return
         */
        List<User> searchUserByWeight(String searchContent);
    }

UserServiceImpl:

@Service
    public class UserServiceImpl implements UserService {
    	@Autowired
        private UserDao userDao;
    	@Override
    	public boolean insert(User user) {
    		boolean falg=false;
    		try{
    			userDao.save(user);
    			falg=true;
    		}catch(Exception e){
    			e.printStackTrace();
    		}
    		return falg;
    	}
    
    	@Override
    	public List<User> search(String searchContent) {
    		  QueryStringQueryBuilder builder = new QueryStringQueryBuilder(searchContent);
    		  System.out.println("查询的语句:"+builder);
              Iterable<User> searchResult = userDao.search(builder);
              Iterator<User> iterator = searchResult.iterator();
              List<User> list=new ArrayList<User>();
              while (iterator.hasNext()) {
           	   	list.add(iterator.next());
              }
           return list;
    	}
    	
    	
    	
    	@Override
    	public List<User> searchUser(Integer pageNumber, Integer pageSize,String searchContent) {
    		 // 分页参数
            Pageable pageable = new PageRequest(pageNumber, pageSize);
            QueryStringQueryBuilder builder = new QueryStringQueryBuilder(searchContent);
            SearchQuery searchQuery = new NativeSearchQueryBuilder().withPageable(pageable).withQuery(builder).build();
            System.out.println("查询的语句:" + searchQuery.getQuery().toString());
            Page<User> searchPageResults = userDao.search(searchQuery);
            return searchPageResults.getContent();
    	}
    	
    
    	@Override
    	public List<User> searchUserByWeight(String searchContent) {
            // 根据权重进行查询
            FunctionScoreQueryBuilder functionScoreQueryBuilder = QueryBuilders.functionScoreQuery()
                    .add(QueryBuilders.boolQuery().should(QueryBuilders.matchQuery("name", searchContent)),
                        ScoreFunctionBuilders.weightFactorFunction(10))
                    .add(QueryBuilders.boolQuery().should(QueryBuilders.matchQuery("description", searchContent)),
                            ScoreFunctionBuilders.weightFactorFunction(100)).setMinScore(2);
            System.out.println("查询的语句:" + functionScoreQueryBuilder.toString());
            Iterable<User> searchResult = userDao.search(functionScoreQueryBuilder);
            Iterator<User> iterator = searchResult.iterator();
            List<User> list=new ArrayList<User>();
            while (iterator.hasNext()) {
         	   	list.add(iterator.next());
            }
            return list;
    	}
    
    
    }

Controller:

@RestController
    @RequestMapping(value = "/api")
    public class UserRestController { 
    	@Autowired
        private UserService userService;
    
        /** * * { * "id":2, * "name":"xiaoyi", * "age":18, * "description":"a very lucky boy!", * "createtm":"2019-10-09" * } * */
    
        @PostMapping("/user")
        public boolean createUser(@RequestBody User user) { 
            return userService.insert(user);
        }
    
        
        @GetMapping("/user/searchContent")
        public List<User> search(@RequestParam(value = "searchContent") String searchContent) { 
    		return userService.search(searchContent);
        }
        
        @GetMapping("/user")
        public List<User> searchUser(@RequestParam(value = "pageNumber") Integer pageNumber,
                                     @RequestParam(value = "pageSize", required = false) Integer pageSize,
                                     @RequestParam(value = "searchContent") String searchContent) { 
            return userService.searchUser(pageNumber, pageSize, searchContent);
        }
        
        
        @GetMapping("/user2")
        public List<User> searchUserByWeight(@RequestParam(value = "searchContent") String searchContent) { 
         return userService.searchUserByWeight(searchContent);
        }
    }

运行说明：  
（1）注意安装低版本的Elasticserach（即2版本以及更低版本）  
（2）最好安装采用postman工具，先添加（即先运行contrlloer里面的createUser），后查询。如下图：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3NjA2OTAx_size_16_color_FFFFFF_t_70]最后附上文件目录：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3NjA2OTAx_size_16_color_FFFFFF_t_70 1]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3NjA2OTAx_size_16_color_FFFFFF_t_70]: /images/20230601/ea9371887d454ed183d2f9b487483bb4.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3NjA2OTAx_size_16_color_FFFFFF_t_70 1]: /images/20230601/09bc9ec8dfbd46abaf212498c562297c.png