Spring boot使用easy-es操作elasticsearch
在Spring Boot中使用easy-es操作Elasticsearch,首先需要添加easy-es的依赖到项目中。以下是一个基本的例子:
- 添加easy-es依赖到
pom.xml
:
<dependency>
<groupId>cn.easyproject</groupId>
<artifactId>easy-es</artifactId>
<version>4.0.1</version>
</dependency>
- 配置Elasticsearch的连接信息在
application.properties
或application.yml
:
# application.properties
elasticsearch.host=localhost:9200
或者使用YAML格式:
# application.yml
elasticsearch:
host: localhost:9200
- 创建一个EasyEs的配置类:
@Configuration
public class ElasticsearchConfig {
@Value("${elasticsearch.host}")
private String host;
@Bean(name = "client")
public TransportClient transportClient() throws Exception {
// 设置集群名称
Settings esSetting = Settings.builder()
.put("cluster.name", "myClusterName") // 这里填写你的集群名称
.build();
// 配置信息Settings自定义
TransportClient transportClient = new PreBuiltTransportClient(esSetting);
// 连接es
transportClient.addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName(host), 9300));
return transportClient;
}
}
- 使用EasyEs进行操作:
@Service
public class EsService {
@Autowired
@Qualifier("client")
private TransportClient client;
public void index(String indexName, String type, String id, String json) {
IndexResponse response = client.prepareIndex(indexName, type, id).setSource(json).get();
System.out.println(response.getIndex());
}
public String search(String indexName, String type, String id) {
GetResponse response = client.prepareGet(indexName, type, id).get();
return response.getSourceAsString();
}
// 其他操作...
}
以上代码展示了如何在Spring Boot项目中配置和使用EasyEs客户端来进行Elasticsearch的基本操作,比如索引文档、搜索文档等。在实际应用中,你可能需要根据自己的需求进行更复杂的配置和定制。
评论已关闭