
看到标题的那一串英文,对于新手来说一定比较陌生,而说起检索,应该都知道吧。
这个ElasticSearch目前我们的首选,他主要有可以提供快速的存储、搜索、分析海量数据的作用。他是一个分布式搜索服务,提供了Restful API,底层基于Lucene(一个开源的搜索引擎工具包),使用shard的分片方式保证数据安全,且有自动resharding功能。我们知道的github、*等这类网站,都是采用这个服务的。
elasticsearch的安装
这里在使用前还要说明一点,很重要的:elasticsearch默认占用2G的堆内存空间,一般直接启用的话,一定会报错,所以我们还要做相应的处理才可以。
1)、首先是使用docker拉取该容器
docker pull elasticsearch
// 若拉取较慢,可以使用国内的docker加速
docker pull registry.docker-cn.com/library/elasticsearch
2)、启动镜像(限制内存占用的启动,9200是该引擎常用端口,9300是作为分布式使用时,各个节点的通信端口)
docker run -e ES_JAVA_OPTS="-Xms256m -Xms256m" -d -p 9200:9200 -p 9300:9300 --name ES_01 73e6fdf8bd4f
3)、检查一下,是否启动成功了,浏览器中键入 你服务器的ip:9200,打开以后是这样的,表示成功了~:(不要在意这个炫酷的json格式,是浏览器插件~)
elasticsearch的测试
1)、首先我们来看下官方文档(放心,中文的!):https://www.elastic.co/guide/cn/elasticsearch/guide/current/index.html
这里有最简单实用的安装和使用方法。我们先打开一个简单的示例,试一下:
按照这份文档,我们使用postman或jmeter等接口的工具来测试一下吧:
按照文档,我们使用put参数,地址格式: 服务器ip:9200/索引名称/类型名称/文件id 。可见创建成功了,返回了true。
将 HTTP 命令由 PUT
改为 GET
可以用来检索文档,同样的,可以使用 DELETE
命令来删除文档,以及使用 HEAD
指令来检查文档是否存在。如果想更新已存在的文档,只需再次 PUT
。
整合到springboot中
好的,我们看看如何把这个整合到springboot中吧。(另外注意下:我们的springboot的版本尽量在2.0+,这样你安装的elasticsearch的版本才能匹配到,不然运行的时候会有链接报错)
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-elasticsearch</artifactId>
</dependency>
SpringBoot默认支持两种技术与ES进行交互:Jest和SpringData ElasticSearch,而默认Jest是不生效的,想要使用,就要自己加载jest的jar包了。本文不做相关介绍,后边有需求,我可以单独补一篇文章。这里主要来说一下SpringData ElasticSearch的使用。
1)、首先我们启动主程序之前要添加一下的配置参数,然后直接启动主程序,看看是否可以正常运行。
spring.data.elasticsearch.cluster-name=elasticsearch #这里在浏览器中输入 服务器id:9200 就可以看到这个name是什么了
spring.data.elasticsearch.cluster-nodes=127.0.0.1:9300 #这里写的是 服务器id:9300
我们看到启动正常,并且add添加了这个9300的端口启动信息。
2)、接下来我们按照官网文档的两种写法,进行测试:
1.编写一个ElasticSearchRepository(有需要增删改查的后边自己补吧),一个需要用到的Book(注意注解的使用)。
import org.springframework.data.elasticsearch.annotations.Document; @Document(indexName = "oooodin", type = "book")
public class Book {
private Integer id;
private String bookName;
private String author; public Integer getId() {
return id;
} public void setId(Integer id) {
this.id = id;
} public String getBookName() {
return bookName;
} public void setBookName(String bookName) {
this.bookName = bookName;
} public String getAuthor() {
return author;
} public void setAuthor(String author) {
this.author = author;
} @Override
public String toString() {
return "Book{" +
"id=" + id +
", bookName='" + bookName + '\'' +
", author='" + author + '\'' +
'}';
}
}
import org.springframework.data.elasticsearch.repository.ElasticsearchRepository; public interface BookRepository extends ElasticsearchRepository<Book, Integer> {
}
然后来测试一下看看(创建一个测试类):
@RunWith(SpringRunner.class)
@SpringBootTest
public class RedisTest { @Autowired
BookRepository bookRepository; @Test
public void test01() {
Book book = new Book();
book.setId(1);
book.setBookName("晋升");
book.setAuthor("ice");
bookRepository.index(book);
} }
然后我们通过浏览器访问一下:
服务器ip:9300 就可以访问看到我们添加的内容了。