封装elasticsearch-rest-high-level-client,添加了连接池功能(官方包中没有提供连接池);同时对接spring-boot-starter
author : guzhandong
email : 569199386@qq.com
springboot version : 2.0.2.RELEASE
install project for maven
git pull git@github.com:guzhandong/spring-boot-starter-elasticsearchHighLevelClient.git
cd spring-boot-starter-elasticsearchHighLevelClient
mvn clean install
add dependent property in pom.xml
<dependency>
<groupId>com.guzhandong.springframework.boot</groupId>
<artifactId>spring-boot-starter-elasticsearchRestHighLeavelClient</artifactId>
<version>1.0-SNAPSHOT</version>
</dependency>
add property in application.yml
spring:
es:
hosts: 192.168.100.1,192.168.100.2
create java file
import com.guzhandong.springframework.boot.elasticsearch.client.RestHighLevelClient;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Repository;
import java.io.IOException;
@Repository
public class Test {
@Autowired
private RestHighLevelClient restHighLevelClient;
public void test() throws IOException {
/**
* 同步方法直接使用
*/
restHighLevelClient.ping();
/**
* 异步方法需要释放client
*/
restHighLevelClient.getLowLevelClient();
//异步使用完成后主动释放client
restHighLevelClient.releaseClient();
/**
* 执行多条异步操作,最后释放client 即可
*/
restHighLevelClient.getLowLevelClient();
restHighLevelClient.getLowLevelClient();
restHighLevelClient.getLowLevelClient();
//最后调用释放即可
//因为在异步操作的时候,如果发现当前线程有持有的client 会先释放再重新从资源池中获取一个client 进行调用
restHighLevelClient.releaseClient();
}
}
spring:
es:
hosts: 192.168.100.1:9200,192.168.100.2:9200
pool: