manager/zyplayer-doc
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

增加es文档雏形~

Browse Source
This commit is contained in:
暮光：城中城
2019-07-21 22:41:23 +08:00
parent 25036fb197
commit fb5438e1ec
42 changed files with 13463 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
zyplayer-doc-data/src/main/java/com/zyplayer/doc/data/service/elasticsearch/support/ElasticSearchUtil.java
View File

@@ -42,7 +42,11 @@ public class ElasticSearchUtil {
if (!this.isOpen()) {
return null;
}
String mapKey = esScheme + "_" + hostAndPort;
return this.getEsClient(hostAndPort, esScheme);
}
public RestHighLevelClient getEsClient(String hostPort, String scheme) {
String mapKey = scheme + "_" + hostPort;
RestHighLevelClient restClient = restClientMap.get(mapKey);
if (restClient == null) {
synchronized (createLock) {
@@ -52,9 +56,9 @@ public class ElasticSearchUtil {
// rest请求客户端
// 例：10.16.32.12:9200,10.16.32.12:9201
List<HttpHost> hostPortList = new LinkedList<>();
for (String hostPortStr : hostAndPort.split(",")) {
for (String hostPortStr : hostPort.split(",")) {
String[] splitArr = hostPortStr.split(":");
hostPortList.add(new HttpHost(splitArr[0], Integer.valueOf(splitArr[1]), esScheme));
hostPortList.add(new HttpHost(splitArr[0], Integer.valueOf(splitArr[1]), scheme));
}
restClient = new RestHighLevelClient(RestClient.builder(hostPortList.toArray(new HttpHost[]{})));
restClientMap.put(mapKey, restClient);