转载

SpringBoot集成Elasticsearch

一.ES简介

elasticsearch是一个高度可扩展的开源全文搜索和分析引擎，可以快速的、近实时地对大数据进行存储、搜索和分析，用来支撑复杂的数据搜索需求和企业级应用，主要用于海量系统日志的数据查询与分析。

二.ES安装

下载地址： https://www.elastic.co/downloads/elasticsearch 。
下载ES压缩包解压后，进入bin目录，双击elasticsearch.bat即可启动es
启动es服务后，访问localhost:9200,浏览器出现如下信息说明启动成功.

{
  "name" : "YNFljfo",
  "cluster_name" : "my-application",
  "cluster_uuid" : "iuLpWK05SJGSqp5evk7Gpg",
  "version" : {
    "number" : "6.2.4",
    "build_hash" : "ccec39f",
    "build_date" : "2018-04-12T20:37:28.497551Z",
    "build_snapshot" : false,
    "lucene_version" : "7.2.1",
    "minimum_wire_compatibility_version" : "5.6.0",
    "minimum_index_compatibility_version" : "5.0.0"
  },
  "tagline" : "You Know, for Search"
}

三.head插件的安装

head插件可以很方便的操作es，head插件与es的关系就像navicat与 MySQL 数据库的关系，不过head插件的界面是通过访问网址浏览的。

下载head插件： https://github.com/search?q=elasticsearch-head
因为head插件依赖node环境，所以需要安装node.js: https://nodejs.org/en/download/
运行head需要借助grunt命令，所以要安装。
在cmd窗口进入node.js安装的根目录，然后执行 npm install -g grunt -cli 。
安装pathomjs:
在cmd命令窗口进入head插件解压后的根目录，然后执行 npm install
连接es: 设置跨域访问，在es的安装根目录的config目录下有elasticsearch.yml，在此文件中添加如下内容：

http.cors.enabled: true
http.cors.allow-origin: "*"

将cluster.name: my-application的注释取消

运行head：

在cmd命令窗口进入head插件解压后的根目录，然后执行 grunt server ，如下图就启动成功。

SpringBoot集成Elasticsearch .png&originHeight=114&originWidth=472&size=5531&status=done&width=472)

然后访问 localhost:9100 看到如下画面就安装成功

SpringBoot集成Elasticsearch .png&originHeight=349&originWidth=990&size=28420&status=done&width=990)

四.Springboot集成ES

添加依赖及配置application.properties文件

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

spring.data.elasticsearch.cluster-name=my-application
spring.data.elasticsearch.cluster-nodes=127.0.0.1:9300

创建实体类及响应体

@Data
@Document(indexName = "person")
@AllArgsConstructor
@NoArgsConstructor
public class Person implements Serializable {
    @Id
    private String skuId;
    private String name;
    private String address;
    private Integer age;
    private String sex;
    private String city;
}

@Data
@AllArgsConstructor
@NoArgsConstructor
public class Response {

    private Integer code;
    private String message;
    private Object data;


    public static Response successMsg(){
        Response response=new Response();
        response.setCode(200);
        response.setMessage("请求成功");
        return response;
    }

    public static Response failed404(){
        Response response=new Response();
        response.setCode(404);
        response.setMessage("请求失败");
        return response;
    }
}

创建es的Service

自定义接口实现ElasticsearchRepository，类似于与数据库交互的dao层，提供了对es的基本操作。

public interface  PersonRepository extends ElasticsearchRepository<Person,String> {


}

@NoRepositoryBean
public interface ElasticsearchRepository<T, ID extends Serializable> extends ElasticsearchCrudRepository<T, ID> {
    <S extends T> S index(S var1);

    Iterable<T> search(QueryBuilder var1);

    Page<T> search(QueryBuilder var1, Pageable var2);

    Page<T> search(SearchQuery var1);

    Page<T> searchSimilar(T var1, String[] var2, Pageable var3);

    void refresh();

    Class<T> getEntityClass();
}

public interface PersonService {

    long count();

    Person save(Person person);

    void delete(Person person);

    Iterable<Person> getAll();

    List<Person> getByName(String name);

    Page<Person> pageQuery(Integer pageNo, Integer pageSize, String kw);
}

@Service
public class PersonServiceImpl implements PersonService {

    @Autowired
    private PersonRepository personRepository;

    @Override
    public long count() {
        return personRepository.count();
    }

    @Override
    public Person save(Person person) {
        return personRepository.save(person);
    }

    @Override
    public void delete(Person person) {
        personRepository.delete(person);
    }

    @Override
    public Iterable<Person> getAll() {
        return personRepository.findAll();
    }

    @Override
    public List<Person> getByName(String name) {
        List<Person> personList=new ArrayList<>();
        MatchQueryBuilder queryBuilder=new MatchQueryBuilder("name",name);
        Iterable<Person> personIterable=personRepository.search(queryBuilder);
        personIterable.forEach(personList::add);
        return personList;
    }

    @Override
    public Page<Person> pageQuery(Integer pageNo, Integer pageSize, String kw) {
        SearchQuery searchQuery=new NativeSearchQueryBuilder().withQuery(QueryBuilders.matchPhraseQuery("name",kw)).withPageable(PageRequest.of(pageNo,pageSize)).build();
        return personRepository.search(searchQuery);
    }
}

Junit测试

Springboot提供了ElasticsearchTemplate,也可实现的ES的数据操作。

@RunWith(SpringRunner.class)
@SpringBootTest
public class SpringEsApplicationTests {


    @Autowired
    public PersonService personService;

    @Autowired
    ElasticsearchTemplate elasticsearchTemplate;
    @Test
    public void contextLoads() {
        Person person=new Person("123456","zlc","西湖区",18,"男","hangzhou");
        personService.save(person);
        Person person1=new Person("98712","张三","余杭区",18,"男","hangzhou");
        IndexQuery indexQuery=new IndexQueryBuilder().withObject(person1).build();
        elasticsearchTemplate.index(indexQuery);

    }

}

创建controller

@RestController
@RequestMapping("/es")
public class EsController {


    @Autowired
    PersonService personService;


    /**
     * 向es添加数据
     */
    @RequestMapping("/insert")
    public Object insert(@RequestBody Person person){
        JSONObject object=null;
        try {
          Person savePerson=  personService.save(person);
          object= (JSONObject) JSON.toJSON(savePerson);
        } catch (Exception e) {
            e.printStackTrace();
        }

        return object;
    }


    /**
     * 从es删除数据
     * @param person
     * @return
     */
    @RequestMapping("/delete")
    public Object delete(@RequestBody Person person){

        try {
            personService.delete(person);
        } catch (Exception e) {
            e.printStackTrace();
            return Response.failed404();
        }
        return Response.successMsg();

    }


    /**
     * 查询操作
     * @param pageNo
     * @param pageSize
     * @param key
     * @return
     */
    @RequestMapping("/query")
    public Object query(@RequestParam(value = "pageNo",required = false)Integer pageNo,@RequestParam(value = "pageSize",required = false)Integer pageSize,
    @RequestParam(value = "key",required = false)String key){

        Response response=new Response();
        try {
            Page<Person> personPage= personService.pageQuery(pageNo,pageSize,key);
            response.setData(personPage);
        } catch (Exception e) {
            e.printStackTrace();
            return Response.failed404();
        }
        return response;

    }
}

通过Postman测试查询结果如下：

SpringBoot集成Elasticsearch .png&originHeight=858&originWidth=1098&size=38028&status=done&width=1098)

五.错误解决

SpringBoot加载elasticsearch节点失败

failed to load elasticsearch nodes : org.elasticsearch.client.transport.NoNodeAvailableException: None of the configured nodes are available:

初步判定，应该是spring-boot-starter-data-elasticsearch与Elasticsearch 7.x版本不兼容造成的。

通过测试发现，将Elasticsearch降级到6.x版本，即可解决。

2.修改elasticsearch.yml后双击elasticsearch.bat闪退

原因是elasticsearch.yml默认是utf-8编码，所以添加的属性保存时也得是utf-8编码的。

六.源码下载地址

https://github.com/liankaizha...

参考文献：

1. https://cloud.tencent.com/developer/article/1461537

原文 https://segmentfault.com/a/1190000022104027

正文到此结束

所属分类： Spring

本文标签： message ArrayList mysql struct sql Node.js key build 下载 Elasticsearch cat 大数据 json 企业 ACE springboot node 数据库 IDE Document Developer 删除 id cmd find 数据 App 开源 IO 源码 tar UI CTO REST http bean tag 测试 js 配置注释插件 entity Service junit spring https 安装需求 list src Transport zab 目录 git map GitHub value client
版权声明： 本文为互联网转载文章，出处已在文章中说明(部分除外)。如果侵权，请联系本站长删除，谢谢。
本文海报： 生成海报一生成海报二

SpringBoot集成Elasticsearch

一.ES简介

二.ES安装

三.head插件的安装

四.Springboot集成ES

五.错误解决

六.源码下载地址

热门推荐

相关文章

说给你听

本文目录

随机标签

书籍教程

近期评论

网站信息

其他链接

关于本站

问题交流