一、集群環(huán)境搭建
1、環(huán)境概覽
ES版本6.3.2，集群名稱esmaster，虛擬機centos7。
ElasticSearch基礎功能和用法：
- MySQL數(shù)據(jù)全量和增量方式向ES搜索引擎同步
- Linux系統(tǒng)Centos7環(huán)境搭建ElasticSearch中間件
- SpringBoot2整合ElasticSearch搜索引擎框架
在真正海量數(shù)據(jù)的業(yè)務場景中，ElasticSearch搜索引擎都是需要集群化管理的，實時搜素幾十億的數(shù)據(jù)十分常見。
2、集群配置
配置文件
vim /opt/elasticsearch-6.3.2/config/elasticsearch.yml
主節(jié)點配置
# 集群主節(jié)點配置
cluster.name: esmaster
node.master: true
# 節(jié)點名稱
node.name: esnode1
# 開發(fā)訪問
network.host: 0.0.0.0
從節(jié)點配置
注意這里兩個從節(jié)點配置，node.name分別配置為esnode2和esnode3即可。
# 集群名稱
cluster.name: esmaster
# 節(jié)點名稱
node.name: esnode2
# 開發(fā)訪問
network.host: 0.0.0.0
# 主節(jié)點IP
discovery.zen.ping.unicast.hosts: ["192.168.72.133"]
內(nèi)存權限
vim /etc/sysctl.conf
# 添加內(nèi)容
vm.max_map_count=262144
# 執(zhí)行
sysctl -p
3、集群啟動
添加esroot用戶，并授權。
/opt/elasticsearch-6.3.2/bin/elasticsearch
單服務查看
ps -aux |grep elasticsearch
集群狀態(tài)查看
http://localhost:9200/_cluster/health?pretty
{
"cluster_name" : "esmaster", # 集群名稱
"status" : "green", # 綠：健康，黃：亞健康，紅：病態(tài)
"timed_out" : false, # 是否超時
"number_of_nodes" : 3, # 節(jié)點個數(shù)
}
二、集群模式測試
1、環(huán)境配置
dev環(huán)境
配置單個節(jié)點，選擇任意單節(jié)點，進行數(shù)據(jù)寫入測試。
spring:
data:
elasticsearch:
# 集群名稱
cluster-name: esmaster
# 單節(jié)點
# cluster-nodes: en-master:9300
# cluster-nodes: en-node01:9300
cluster-nodes: en-node02:9300
test環(huán)境
鏈接集群環(huán)境，進行數(shù)據(jù)讀取測試。
spring:
data:
elasticsearch:
# 集群名稱
cluster-name: esmaster
# 集群節(jié)點
cluster-nodes: en-master:9300,en-node01:9300,en-node02:9300
當然所有的操作都可以基于單節(jié)點或者集群環(huán)境測試。
2、實例對象
基于注解管理數(shù)據(jù)對象實例。
import org.springframework.data.annotation.Id;
import org.springframework.data.elasticsearch.annotations.Document;
@Document(indexName = "usersearchindex",type = "usersearch")
public class UserSearch {
//Id注解Elasticsearch里相應于該列就是主鍵，查詢時可以使用主鍵查詢
@Id
private Long id;
private String userId;
private String userName;
private String sex;
}
3、操作案例
提供一個數(shù)據(jù)查詢操作和數(shù)據(jù)寫入操作。
import com.esearch.cluster.entity.UserSearch;
import org.springframework.stereotype.Service;
import JAVAx.annotation.Resource;
@Service
public class UserSearchServiceImpl implements UserSearchService {
@Resource
private UserSearchRepository userSearchRepository ;
@Override
public String esInsert(Integer num) {
for (int i = 0 ; i < num ; i++){
UserSearch userSearch = new UserSearch() ;
userSearch.setId(System.currentTimeMillis());
userSearch.setUserId("Name"+i);
userSearch.setUserName("ZSan"+i);
userSearch.setSex("Male"+i);
userSearchRepository.save(userSearch) ;
}
return "success" ;
}
@Override
public Iterable<UserSearch> esFindAll (){
return userSearchRepository.findAll() ;
}
}
三、集群控制臺
這里是基于Kibana組件做的集群控制臺。
1、數(shù)據(jù)列表
在discover面板中可以查看列表數(shù)據(jù)，也可以繼續(xù)搜索。
列表查詢
列表搜索
2、開發(fā)工具
在dev_tools面板中可以執(zhí)行ElasticSearch相關命令。
查看集群健康狀態(tài)
GET /_cat/health?v
查詢?nèi)繑?shù)據(jù)
GET _search
{
"query": {
"match_all": {}
}
}
