准备
jdk1.8
elasticsearch 5.5.2
springboot 1.5.6RELEASE
maven 3.5.0
node.js 8.11.4
postman工具
jdk，maven，node，postman的安装就不管了
1、安装elasticsearch
下载压缩包
到elastic官网：https://www.elastic.co/cn/downloads/past-releases下载
我这里下载的是5.5.2windows版本的
image.png
修改配置文件
解压后，修改config文件夹下的配置文件jvm.options,默认jvm的内容是2g，我修改为256m，测试嘛我就搞小点，不改也行，只要电脑的内存够用就行
image.png
修改之后
image.png
启动
在bin目录下，点击elasticsearch.bat文件启动，看到关键字started就是启动成功了
image.png
elastic默认端口是9200，到浏览器访问localhost:9200
image.png
2、elasticsearch的head插件（es界面）
下载
下载地址：https://github.com/mobz/elasticsearch-head
启动
进入elasticsearch-head-master文件夹
下载依赖： npm install
启动：npm run start
image.png
访问localhost:9100
image.png
结果是未连接，暂时不知道什么原因，以后知道了再补充上，但是建立起elasticsearch的集群后他就连接成功了,就先放着了，接着看安装elastic的集群搭建
3、elasticsearch集群安装
主节点
修改配置文件elasticsearch.yml,将下面这些配置添加进去
#指定集群的名称
cluster.name: syf
#节点名称
node.name: master
#是不是主节点
node.master: true
node.attr.rack: r1
#最大集群节点数
node.max_local_storage_nodes: 3
#网关地址
network.host: 127.0.0.1
#端口
http.port: 9200
#内部节点之间沟通端口
transport.tcp.port: 9300
# 开启安全防护(启用跨域访问)
http.cors.enabled: true
http.cors.allow-origin: "*"
#时间放长，防止脑裂
discovery.zen.ping_timeout: 120s
client.transport.ping_timeout: 60s
http.cors.allow-headers: Authorization,X-Requested-With,Content-Length,Content-Type
#配置有机会参与选举为master的节点
discovery.zen.ping.unicast.hosts: ["127.0.0.1:9300","127.0.0.1:9301","127.0.0.1:9302"]
#elasticSearch服务器的数据目录和日志目录，可以自行新建后配置路径使elasticSearch服务启动后将运行数据和日志生成到指定目录下
path.data: E:\syf\down\elasticsearch-5.5.2\data
path.logs: E:\syf\down\elasticsearch-5.5.2\logs
其中path.data和path.logs换成你自己的路径,
从节点
将主节点复制两份作为两个从节点
image.png
分别修改elasticsearch.yml配置文件
#指定集群的名称
cluster.name: syf
#节点名称
node.name: slave1
#是不是主节点
node.master: false
node.attr.rack: r1
#最大集群节点数
node.max_local_storage_nodes: 3
#网关地址
network.host: 127.0.0.1
#端口
http.port: 9201
#内部节点之间沟通端口
transport.tcp.port: 9301
# 开启安全防护(启用跨域访问)
http.cors.enabled: true
http.cors.allow-origin: "*"
#时间放长，防止脑裂
discovery.zen.ping_timeout: 120s
client.transport.ping_timeout: 60s
http.cors.allow-headers: Authorization,X-Requested-With,Content-Length,Content-Type
#配置有机会参与选举为master的节点
discovery.zen.ping.unicast.hosts: ["127.0.0.1:9300","127.0.0.1:9301","127.0.0.1:9302"]
#elasticSearch服务器的数据目录和日志目录，可以自行新建后配置路径使elasticSearch服务启动后将运行数据和日志生成到指定目录下
path.data: E:\syf\down\elasticsearch-5.5.2.1\data
path.logs: E:\syf\down\elasticsearch-5.5.2.1\logs
#指定集群的名称
cluster.name: syf
#节点名称
node.name: slave2
#是不是主节点
node.master: false
node.attr.rack: r1
#最大集群节点数
node.max_local_storage_nodes: 3
#网关地址
network.host: 127.0.0.1
#端口
http.port: 9202
#内部节点之间沟通端口
transport.tcp.port: 9302
# 开启安全防护(启用跨域访问)
http.cors.enabled: true
http.cors.allow-origin: "*"
#时间放长，防止脑裂
discovery.zen.ping_timeout: 120s
client.transport.ping_timeout: 60s
http.cors.allow-headers: Authorization,X-Requested-With,Content-Length,Content-Type
#配置有机会参与选举为master的节点
discovery.zen.ping.unicast.hosts: ["127.0.0.1:9300","127.0.0.1:9301","127.0.0.1:9302"]
#elasticSearch服务器的数据目录和日志目录，可以自行新建后配置路径使elasticSearch服务启动后将运行数据和日志生成到指定目录下
path.data: E:\syf\down\elasticsearch-5.5.2.2\data
path.logs: E:\syf\down\elasticsearch-5.5.2.2\logs
启动集群
依次启动三个节点，再访问localhost:9100，直接访问可能还得不到效果，需要等一会儿，这里我在搭建的时候等了大概3分钟，所有节点才启动了完了，
image.png
4、elasticsearch的CRUD
直接使用head插件进行操作的话，似乎只能进行创建索引这样的操作，所以我们使用工具，postman，elasticsearch提供了restful的api，postman是一个调试接口的利器
在进行crud操作前，先说明几个概念
| 概念 | 描述 |
|---|---|
| 索引（index） | 可以简单理解为数据库中的 库（database） |
| 类型（type） | 就相当于数据库中 表（table） |
| 文档（doc） | 就相当于一条数据 |
| 分片 | es创建索引时默认5个分片，5个分片共同存放一个索引 |
| 备份 | es默认一个分片一个备份 |
打开postman创建一个book索引，其中给一个novel类型并定义文档的结构
image.png
创建索引的json
{
"settings":{
"number_of_shards":5,
"number_of_replicas":1
},
"mappings":{
"novel":{
"properties":{
"title":{
"type":"text"
},
"price":{
"type":"integer"
},
"date":{
"type":"date",
"format":"yyyy-MM-dd"
}
}
}
}
}
下图表示成功
image.png
访问localhost:9100
image.png
其中细线的代表备份，比如细线0为粗线0的备份，以此类推
增加一个文档
image.png
image.png
修改文档
image.png
image.png
书名成功修改为了西游记
获取文档
image.png
image.png
删除文档
5、springboot整合elasticsearch
创建一个maven项目
目录结构
image.png
pom依赖
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>1.5.6.RELEASE</version>
</parent>
<properties>
<elasticsearch.version>5.5.2</elasticsearch.version>
<java.version>1.8</java.version>
</properties>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.elasticsearch.client</groupId>
<artifactId>transport</artifactId>
<version>${elasticsearch.version}</version>
</dependency>
<dependency>
<groupId>org.apache.logging.log4j</groupId>
<artifactId>log4j-core</artifactId>
<version>2.7</version>
</dependency>
</dependencies>
Config.java
import org.elasticsearch.client.transport.TransportClient;
import org.elasticsearch.common.settings.Settings;
import org.elasticsearch.common.transport.InetSocketTransportAddress;
import org.elasticsearch.transport.client.PreBuiltTransportClient;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
@Configuration
public class Config {
@SuppressWarnings("resource")
@Bean
public TransportClient getTransportClient() throws UnknownHostException{
InetSocketTransportAddress node = new InetSocketTransportAddress(
InetAddress.getByName("localhost"),
9300//9300是elastic的transport使用的端口
);
Settings settings = Settings.builder().put("cluster.name","syf").build();
TransportClient client = new PreBuiltTransportClient(settings);
client.addTransportAddress(node);
return client;
}
}
BookController.java
@RestController
@RequestMapping("/book")
public class BookController {
@Autowired
private TransportClient client;
@RequestMapping("/novel/get")
public Object get(String id){
GetResponse result = client.prepareGet("book","novel",id).get();
return result.getSource();
}
@RequestMapping("/novel/add")
public Object add(String title,String price,String date){
try {
XContentBuilder content = XContentFactory.jsonBuilder()
.startObject()
.field("title",title)
.field("price",price)
.field("date",date)
.endObject();
IndexResponse result = client.prepareIndex("book", "novel").setSource(content).get();
return result.getResult();
} catch (Exception e) {
// TODO: handle exception
}
return null;
}
@RequestMapping("/novel/delete")
public Object delete(String id){
DeleteResponse result = client.prepareDelete("book", "novel", id).get();
return result.getResult();
}
@RequestMapping("/novel/update")
public Object update(String id,String title,String price,String date){
UpdateRequest update = new UpdateRequest("book", "novel", id);
try {
XContentBuilder content = XContentFactory.jsonBuilder().startObject();
content.field("title", title).field("price",price).field("date",date);
content.endObject();
update.doc(content);
UpdateResponse result = client.update(update).get();
return result.getResult();
} catch (Exception e) {
// TODO: handle exception
}
return null;
}
@RequestMapping("/novel/query")
public Object query(String title,String price){
BoolQueryBuilder boolQuery = QueryBuilders.boolQuery();
if(title!=null){
boolQuery.must(QueryBuilders.matchQuery("title", title));
}
SearchRequestBuilder search = client.prepareSearch("book").setTypes("novel")
.setSearchType(SearchType.DFS_QUERY_THEN_FETCH)
.setQuery(boolQuery);
List<Map<String, Object>> result = new ArrayList<Map<String,Object>>();
SearchResponse response = search.get();
SearchHits hits = response.getHits();
for (SearchHit hit : hits) {
result.add(hit.getSource());
}
return result;
}
}
springboot默认监听8080，增删改查自己测试，我测试过是可以的
完整代码下载地址：https://gitee.com/shyf2019/springboot_elasticsearch
