elasticsearch集成springboot全文检索实操

（目前不考虑数据量大的情况，简单运用）

步骤：

1. 导入依赖，配置文件写好配置
2. 创建两个实体类，一个实体类对应mysql的用户表，一个es实体类对应es的用户索引库（数据自己存入）
3. 先从es中根据关键字全文检索出数据，然后根据这些数据信息从mysql中查出对应的所有完整的数据。
4. 将查询出的完整数据响应回浏览器

     org.springframework.boot
     spring-boot-starter-data-elasticsearch

#elasticsearch
spring.elasticsearch.rest.uris=http://localhost:9200

    private String nickname;  //昵称
    private String phone;  //手机
    private String email;  //邮箱

    @JsonIgnore
    private String password; //密码
    private Integer gender = GENDER_SECRET; //性别
    private Integer level = 0;  //用户级别
    private String city;  //所在城市
    private String headImgUrl; //头像
    private String info;  //个性签名
    private Integer state = STATE_NORMAL; //状态

@Getter
@Setter
@document(indexName="userinfo")
public class UserInfoEs implements Serializable {
    public static final String INDEX_NAME = "userinfo";
    @Id
    //@Field 每个文档的字段配置（类型、是否分词、是否存储、分词器 ）
    @Field(store=true, index = false,type = FieldType.Long)
    private Long id;  //用户id
    @Field(index=true,analyzer="ik_max_word",store=true,searchAnalyzer="ik_max_word",type = FieldType.Text)
    private String nickname;
    @Field(index=true,store=true,type = FieldType.Keyword)
    private String city;
    @Field(index=true,analyzer="ik_max_word",store=true,searchAnalyzer="ik_max_word",type = FieldType.Text)
    private String info;
}

public interface UserInfoEsRepository extends ElasticsearchRepository {
    
    @Query("{"multi_match":{"query":"?0","fields": ["info", "city"]}}")//?0表示替换下面的第几个形参
    @Highlight(
            fields = {
                    @HighlightField(name = "info"),
                    @HighlightField(name = "city"),
            },
            parameters = @HighlightParameters(
                    preTags = "",
                    postTags = ""
            )
    )
    List> findAllByInfoOrCity(String keyword);
}

public interface IUserInfoEsService {
    void save(UserInfoEs userInfoEs);
    void update(UserInfoEs userInfoEs);
    UserInfoEs get(Long id);
    List list();
    void delete(Long id);
    
    Map searchData(String keyword);
}

   //service实现类
    @Override
    public Map searchData(String keyword) {
        //从es全文检索出所有相关的数据 (查询结果都是SearchHit类型)
        List> userInfoEsList = userInfoEsRepository.findAllByInfoOrCity(keyword);
        List userInfoList = new ArrayList<>();
        //根据从es检索的数据查出mysql中对应的数据并封装
        for (SearchHit hit : userInfoEsList) {
            UserInfoEs userInfoEs = hit.getContent();
            UserInfo userInfo = userInfoService.getById(userInfoEs.getId());
            Map> highlightFields = hit.getHighlightFields();
            //将查出来的高亮信息修改到查出来的对象上
            for (String key : highlightFields.keySet()) {
                if (key.equals("info")) {
                    userInfo.setInfo(highlightFields.get(key).get(0));
                }
                if (key.equals("city")) {
                    userInfo.setCity(highlightFields.get(key).get(0));
                }
            }
            userInfoList.add(userInfo);
        }

        Map map = new HashMap<>();
        map.put("users",userInfoList);
        return map;
    }

    @GetMapping("q")
    public JsonResult query(String keyword) {
        return JsonResult.success(userInfoEsService.searchData(keyword));
    }