java main方法写一个elasticsearch连接
时间: 2023-03-31 19:04:57 浏览: 68
可以使用以下代码连接 Elasticsearch:
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.client.RestClientBuilder;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.common.settings.Settings;
public class ElasticsearchConnection {
public static void main(String[] args) throws Exception {
// 设置集群名称
Settings settings = Settings.builder().put("cluster.name", "myClusterName").build();
// 创建 RestClientBuilder
RestClientBuilder builder = RestClient.builder(new HttpHost("localhost", 920))
.setHttpClientConfigCallback(httpClientBuilder -> httpClientBuilder.setDefaultCredentialsProvider(credentialsProvider))
.setRequestConfigCallback(requestConfigBuilder -> requestConfigBuilder.setConnectTimeout(500).setSocketTimeout(60000))
.setMaxRetryTimeoutMillis(60000);
// 创建 RestHighLevelClient
RestHighLevelClient client = new RestHighLevelClient(builder);
// 关闭连接
client.close();
}
}