网站建立数据库,wordpress后台怎么登陆,东莞微信网站建设动态,狗狗俱乐部网页设计教程文章目录 一、安装 Elasticsearch1.1 启动 Elasticsearch1.2 启动 Kibana 二、客户端代码2.1 导入依赖2.2 配置 application.yaml2.3 定义实体类2.4 连接 Elasticserach2.5 定义 Service 层接口2.6 实现 Service 层功能 三、测试项目3.1 添加数据3.2 搜索数据3.3 更新数据3.4 删… 文章目录 一、安装 Elasticsearch1.1 启动 Elasticsearch1.2 启动 Kibana 二、客户端代码2.1 导入依赖2.2 配置 application.yaml2.3 定义实体类2.4 连接 Elasticserach2.5 定义 Service 层接口2.6 实现 Service 层功能 三、测试项目3.1 添加数据3.2 搜索数据3.3 更新数据3.4 删除数据 参考资料 完整案例代码https://github.com/idealzouhu/java-demos/tree/main/middleware-demos/spring-boot-elasticsearch/elasticsearch-client 一、安装 Elasticsearch
1.1 启动 Elasticsearch
运行以下命令启动 Elasticsearch
$ docker network create elastic$ docker pull docker.elastic.co/elasticsearch/elasticsearch:7.17.26$ docker run --name es01-test ^--net elastic ^-p 127.0.0.1:9200:9200 ^-p 127.0.0.1:9300:9300 ^-e discovery.typesingle-node ^-e xpack.security.enabledtrue ^-e ELASTIC_PASSWORDElastic123456 ^-e KIBANA_PASSWORDKibana123456 ^docker.elastic.co/elasticsearch/elasticsearch:7.17.26其中具体参数的含义如下
-e xpack.security.enabledtrue启用 Elasticsearch 的安全功能。具体细节查看 Set up minimal security for Elasticsearch -e ELASTIC_PASSWORDElastic123456为 elastic 用户设置密码。 elastic 用户拥有超级权限。-e KIBANA_PASSWORDKibana123456为 kibana_system 用户设置密码。kibana_system 用户是一个为 Kibana 服务账户 创建的专用用户。它有足够的权限来与 Elasticsearch 通信但它并没有 elastic 用户的超高权限。
1.2 启动 Kibana
Kibana 主要用来可视化和管理Elasticsearch数据。
运行以下命令启动 Kibana
$ docker pull docker.elastic.co/kibana/kibana:7.17.26$ docker run --name kib01-test ^--net elastic ^-p 127.0.0.1:5601:5601 ^-e ELASTICSEARCH_HOSTShttp://es01-test:9200 ^-e ELASTICSEARCH_USERNAMEelastic ^-e ELASTICSEARCH_PASSWORDElastic123456 ^docker.elastic.co/kibana/kibana:7.17.26其中具体参数的含义如下 ELASTICSEARCH_HOSTShttp://es01-test:9200 指定了 Kibana 应该连接到哪个 Elasticsearch 节点。 ELASTICSEARCH_USERNAMEelastic 指定 Kibana 使用的用户名是 elastic。 ELASTICSEARCH_PASSWORDElastic123456 elastic 用户的密码。 注意我们也可以直接在 HTTP 请求里面设置用户名和参数例如 curl -u elastic:your_elastic_password http://localhost:9200 在启动 Kibana 后访问 Kibana 可视化界面 http://localhost:5601。
二、客户端代码
2.1 导入依赖
创建 Spring Boot 3.0.6 项目导入相关依赖
dependencygroupIdco.elastic.clients/groupIdartifactIdelasticsearch-java/artifactIdversion7.17.26/versionexclusionsexclusiongroupIdorg.elasticsearch.client/groupIdartifactIdelasticsearch-rest-client/artifactId/exclusion/exclusions
/dependencydependencygroupIdorg.elasticsearch.client/groupIdartifactIdelasticsearch-rest-client/artifactIdversion7.17.26/version
/dependencydependencygroupIdcom.fasterxml.jackson.core/groupIdartifactIdjackson-databind/artifactIdversion2.17.0/version
/dependency如果遇到相关依赖冲突可以查看 Installation | Elasticsearch Java API Client 7.17
2.2 配置 application.yaml
spring:application:name: elasticsearch-client# 打印 es 的 http 请求适合在开发调试中使用正式环境请关闭
logging:level:tracer: TRACE2.3 定义实体类
Data
AllArgsConstructor
RequiredArgsConstructor
public class Account {// ES中 ducument 的 _idprivate String id;// 解决ES中字段与实体类字段不一致的问题JsonProperty(account_number)private Long accountNumber;private String address;private Integer age;private Long balance;private String city;private String email;private String employer;private String firstname;private String lastname;private String gender;private String state;
}
2.4 连接 Elasticserach
Configuration
public class ElasticsearchConfig {/*** 创建并返回一个 Elasticsearch 客户端。** p* 使用 RestClientBuilder 构建 RestClient并使用 BasicCredentialsProvider 设置用户名和密码。* a hrefhttps://www.elastic.co/guide/en/elasticsearch/client/java-api-client/7.17/connecting.html官方客户端连接教程/a* a hrefhttps://www.elastic.co/guide/en/elasticsearch/client/java-api-client/7.17/_basic_authentication.html官方基本认证教程/a* /p** return 初始化好的 Elasticsearch 客户端*/Beanpublic ElasticsearchClient esClient() {// 1. 配置认证String userName elastic;String password Elastic123456;final CredentialsProvider credentialsProvider new BasicCredentialsProvider();credentialsProvider.setCredentials(AuthScope.ANY, new UsernamePasswordCredentials(userName, password));// 2. 创建 low-level 客户端使用身份验证RestClient restClient RestClient.builder(new HttpHost(localhost, 9200)) // 指定 Elasticsearch 服务器的主机名和端口号.setHttpClientConfigCallback(httpClientBuilder -httpClientBuilder.setDefaultCredentialsProvider(credentialsProvider)).build();// 3. 创建传输对象使用 Jackson 映射器将 Java 对象转换为 JSON 格式ElasticsearchTransport transport new RestClientTransport(restClient, new JacksonJsonpMapper());// 4. 创建 API 客户端return new ElasticsearchClient(transport);}}
2.5 定义 Service 层接口
public interface AccountElasticsearchService {/*** 将 Account 对象索引到 Elasticsearch 中。** param account 需要索引的账户对象* throws IOException 当 Elasticsearch 请求失败时抛出*/void indexAccount(Account account) throws IOException;/*** 批量将多个 Account 对象索引到 Elasticsearch 中。** param accounts 需要索引的账户对象列表* throws IOException 当 Elasticsearch 请求失败时抛出*/public void indexMultipleAccounts(ListAccount accounts) throws IOException;/*** 根据账户编号搜索账户信息。** param accountNumber 账户编号* return 匹配的账户信息以字符串形式返回* throws IOException 当 Elasticsearch 请求失败时抛出*/String searchAccountByAccountNumber(Long accountNumber) throws IOException;/*** 根据账户 ID 从 Elasticsearch 获取账户信息。** param id 账户 ID* return 对应账户的详细信息* throws IOException 当 Elasticsearch 请求失败时抛出*/String searchAccountById(String id) throws IOException;/*** 根据 firstname 和 age 查询账户。** param firstName 姓名* param age 年龄* throws IOException 当 Elasticsearch 请求失败时抛出*/public void searchByNameAndAge(String firstName, int age) throws IOException;/*** 更新账户信息。** param account 修改后的账户对象* return 返回更新结果信息* throws IOException 当 Elasticsearch 请求失败时抛出*/String updateAccountById(Account account) throws IOException;/*** 根据账户 ID 从 Elasticsearch 中删除账户信息。** param accountId 要删除的账户 ID* return 返回删除结果信息* throws IOException 当 Elasticsearch 请求失败时抛出*/String deleteAccountById(String accountId) throws IOException;}
2.6 实现 Service 层功能
Slf4j
Service
RequiredArgsConstructor
public class AccountElasticsearchServiceImpl implements AccountElasticsearchService {private final ElasticsearchClient esClient;/*** 将 Account 对象索引到 Elasticsearch 中。** param account 需要索引的账户对象* throws IOException 当 Elasticsearch 请求失败时抛出*/Overridepublic void indexAccount(Account account) throws IOException {// 创建索引请求并执行IndexResponse createResponse esClient.index(i - i.index(accounts) // 指定索引名称.id(account.getId()) // 文档 ID, 使用 account.getId() 获取文档的唯一标识.document(account) // 文档内容);log.info(Document indexed with ID:{}, createResponse.id());}/*** 批量将多个 Account 对象索引到 Elasticsearch 中。** param accounts 需要索引的账户对象列表* throws IOException 当 Elasticsearch 请求失败时抛出*/Overridepublic void indexMultipleAccounts(ListAccount accounts) throws IOException {// 创建批量请求构建器BulkRequest.Builder bulkRequest new BulkRequest.Builder();// 循环添加每个账户对象的索引请求for (Account account : accounts) {bulkRequest.operations(op - op.index(idx - idx.index(accounts).id(account.getId()).document(account)));}// 执行批量请求BulkResponse bulkResponse esClient.bulk(bulkRequest.build());// 打印出成功的文档 IDif (bulkResponse.errors()) {log.error(Bulk had errors);for (BulkResponseItem item : bulkResponse.items()) {if (item.error() ! null) {log.error(item.error().reason());}}} else {log.info(Bulk indexing completed successfully);}}/*** 根据账户编号搜索账户信息。** param accountNumber 账户编号* return 匹配的账户信息以字符串形式返回* throws IOException 当 Elasticsearch 请求失败时抛出*/Overridepublic String searchAccountByAccountNumber(Long accountNumber) throws IOException {// 使用 Elasticsearch 客户端进行搜索SearchResponseAccount searchResponse esClient.search(s - s.index(accounts) // 指定索引名称.query(q - q.term(t - t.field(account_number) // 搜索字段.value(v - v.longValue(accountNumber)) // 动态传入搜索值)),Account.class);// 获取总命中数TotalHits totalHits searchResponse.hits().total();boolean isExactResult totalHits.relation() TotalHitsRelation.Eq;if (isExactResult) {log.info(Found exactly totalHits.value() matching account(s).);} else {log.info(Found more than totalHits.value() matching account(s).);}// 构建返回结果StringBuilder resultBuilder new StringBuilder(Search results:\n);for (HitAccount hit : searchResponse.hits().hits()) {Account foundAccount hit.source(); // 获取匹配到的账户信息if (foundAccount ! null) {resultBuilder.append(String.format(Account: %s, Name: %s %s\n,foundAccount.getAccountNumber(),foundAccount.getFirstname(),foundAccount.getLastname()));}}// 返回结果if (resultBuilder.length() 0) {return No matching accounts found for account number: accountNumber;}return resultBuilder.toString();}/*** 根据账户 ID 从 Elasticsearch 获取账户信息。** param id 账户 ID, 也是文档的唯一标识* return 对应账户的详细信息* throws IOException 当 Elasticsearch 请求失败时抛出*/Overridepublic String searchAccountById(String id) throws IOException {// 创建查询请求GetResponseAccount response esClient.get(g - g.index(accounts).id(id),Account.class);// 判断是否找到对应的账户if (response.found()) {// 获取账户信息Account account response.source();// 将账户信息转换为 JSON 字符串并返回ObjectMapper mapper new ObjectMapper();return mapper.writeValueAsString(account);}else {return Account not found;}}/*** 根据 firstname 和 age 查询账户。** param firstName 姓名* param age 年龄* throws IOException 当 Elasticsearch 请求失败时抛出*/Overridepublic void searchByNameAndAge(String firstName, int age) throws IOException {// 创建查询条件Query firstNameQuery MatchQuery.of(m - m.field(firstname).query(firstName))._toQuery();Query ageQuery MatchQuery.of(m - m.field(age).query(age))._toQuery();// 使用 bool 查询将多个条件组合起来BoolQuery boolQuery BoolQuery.of(b - b.must(firstNameQuery).must(ageQuery));// 创建搜索请求SearchRequest searchRequest SearchRequest.of(builder - builder.index(accounts).query(q - q.bool(boolQuery)));// 执行查询SearchResponseAccount searchResponse esClient.search(searchRequest, Account.class);// 打印结果System.out.println(Search results:);for (HitAccount hit : searchResponse.hits().hits()) {System.out.println(Found account: hit.source());}}/*** 根据账户 ID 更新账户信息。** param account 要更新的账户信息* return 返回更新结果信息* throws IOException 当 Elasticsearch 请求失败时抛出*/Overridepublic String updateAccountById(Account account) throws IOException {// 创建更新请求UpdateRequestAccount, Account updateRequest UpdateRequest.of(builder - builder.index(accounts).id(account.getId()).doc(account));// 执行更新操作UpdateResponseAccount updateResponse esClient.update(updateRequest, Account.class);// 根据更新结果构建响应信息return Document updated with result: updateResponse.result();}/*** 根据账户 ID 从 Elasticsearch 中删除账户信息。** param accountId 要删除的账户 ID* return 返回删除结果信息* throws IOException 当 Elasticsearch 请求失败时抛出*/Overridepublic String deleteAccountById(String accountId) throws IOException {// 创建删除请求DeleteRequest deleteRequest DeleteRequest.of(builder - builder.index(accounts) // 指定索引.id(accountId) // 指定文档 ID);// 执行删除操作DeleteResponse deleteResponse esClient.delete(deleteRequest);// 根据删除结果构建响应信息return Document deleted with result: deleteResponse.result();}}三、测试项目
3.1 添加数据
具体测试代码为
SpringBootTest
class AccountElasticsearchServiceImplTest {Autowiredprivate AccountElasticsearchService accountElasticsearchService;Testvoid indexAccount() throws IOException {// 创建测试数据Account account new Account();account.setId(12345);account.setAccountNumber(12345L);account.setEmail(john.doeexample.com);// 调用 indexAccount 方法accountElasticsearchService.indexAccount(account);}
}运行结果为
2024-12-07T13:10:42.68408:00 TRACE 3592 --- [elasticsearch-client] [ main] tracer : curl -iX PUT http://localhost:9200/accounts/_doc/12345 -d {id:12345,email:john.doeexample.com,account_number:12345}
# HTTP/1.1 201 Created
# Location: /accounts/_doc/12345
# X-elastic-product: Elasticsearch
# content-type: application/json; charsetUTF-8
# content-length: 160
#
# {_index:accounts,_type:_doc,_id:12345,_version:1,result:created,_shards:{total:2,successful:1,failed:0},_seq_no:4,_primary_term:1}
2024-12-07T13:10:42.71408:00 INFO 3592 --- [elasticsearch-client] [ main] .e.c.s.i.AccountElasticsearchServiceImpl : Document indexed with ID:123453.2 搜索数据
具体测试代码为
SpringBootTest
class AccountElasticsearchServiceImplTest {Autowiredprivate AccountElasticsearchService accountElasticsearchService;Testvoid searchAccountByAccountNumber() throws IOException {String result accountElasticsearchService.searchAccountByAccountNumber(12345L);System.out.println(result);}}运行结果为
2024-12-07T13:11:14.50808:00 TRACE 34672 --- [elasticsearch-client] [ main] tracer : curl -iX POST http://localhost:9200/accounts/_search?typed_keystrue -d {query:{term:{account_number:{value:12345}}}}
# HTTP/1.1 200 OK
# X-elastic-product: Elasticsearch
# content-type: application/json; charsetUTF-8
# content-length: 303
#
# {took:711,timed_out:false,_shards:{total:1,successful:1,skipped:0,failed:0},hits:{total:{value:1,relation:eq},max_score:1.0,hits:[{_index:accounts,_type:_doc,_id:12345,_score:1.0,_source:{id:12345,email:john.doeexample.com,account_number:12345}}]}}
2024-12-07T13:11:14.71808:00 INFO 34672 --- [elasticsearch-client] [ main] .e.c.s.i.AccountElasticsearchServiceImpl : Found exactly 1 matching account(s).
Search results:
Account: 12345, Name: null null3.3 更新数据
具体测试代码为
SpringBootTest
class AccountElasticsearchServiceImplTest {Autowiredprivate AccountElasticsearchService accountElasticsearchService;Testvoid searchAccountByAccountNumber() throws IOException {String result accountElasticsearchService.searchAccountByAccountNumber(12345L);System.out.println(result);}}运行结果为
2024-12-07T13:12:56.86708:00 TRACE 11832 --- [elasticsearch-client] [ main] tracer : curl -iX POST http://localhost:9200/accounts/_update/12345 -d {doc:{id:12345,email:john.doeexample.com,firstname:John,lastname:Doe,account_number:12345}}
# HTTP/1.1 200 OK
# X-elastic-product: Elasticsearch
# content-type: application/json; charsetUTF-8
# content-length: 160
#
# {_index:accounts,_type:_doc,_id:12345,_version:2,result:updated,_shards:{total:2,successful:1,failed:0},_seq_no:5,_primary_term:1}
Document updated with result: Updated3.4 删除数据
具体测试代码为
SpringBootTest
class AccountElasticsearchServiceImplTest {Autowiredprivate AccountElasticsearchService accountElasticsearchService;Testvoid deleteAccountById() {try {String result accountElasticsearchService.deleteAccountById(12345L);System.out.println(result);} catch (IOException e) {e.printStackTrace();}}}运行结果为
2024-12-07T13:15:10.06408:00 TRACE 13804 --- [elasticsearch-client] [ main] tracer : curl -iX DELETE http://localhost:9200/accounts/_doc/12345
# HTTP/1.1 200 OK
# X-elastic-product: Elasticsearch
# content-type: application/json; charsetUTF-8
# content-length: 160
#
# {_index:accounts,_type:_doc,_id:12345,_version:3,result:deleted,_shards:{total:2,successful:1,failed:0},_seq_no:6,_primary_term:1}
Document deleted with result: Deleted参考资料
Connecting | Elasticsearch Java API Client 7.17
ElasticSearch8 - SpringBoot整合ElasticSearch - 王谷雨 - 博客园 文章转载自： http://www.morning.wphzr.cn.gov.cn.wphzr.cn http://www.morning.mcwrg.cn.gov.cn.mcwrg.cn http://www.morning.wfjrl.cn.gov.cn.wfjrl.cn http://www.morning.xblrq.cn.gov.cn.xblrq.cn http://www.morning.junmap.com.gov.cn.junmap.com http://www.morning.xprzq.cn.gov.cn.xprzq.cn http://www.morning.lmfxq.cn.gov.cn.lmfxq.cn http://www.morning.yrjhr.cn.gov.cn.yrjhr.cn http://www.morning.jfch.cn.gov.cn.jfch.cn http://www.morning.zlrrj.cn.gov.cn.zlrrj.cn http://www.morning.shinezoneserver.com.gov.cn.shinezoneserver.com http://www.morning.rcwbc.cn.gov.cn.rcwbc.cn http://www.morning.nkjxn.cn.gov.cn.nkjxn.cn http://www.morning.swlwf.cn.gov.cn.swlwf.cn http://www.morning.ghxtk.cn.gov.cn.ghxtk.cn http://www.morning.knnhd.cn.gov.cn.knnhd.cn http://www.morning.rhmk.cn.gov.cn.rhmk.cn http://www.morning.rdkt.cn.gov.cn.rdkt.cn http://www.morning.tlzbt.cn.gov.cn.tlzbt.cn http://www.morning.rzmkl.cn.gov.cn.rzmkl.cn http://www.morning.thbkc.cn.gov.cn.thbkc.cn http://www.morning.dytqf.cn.gov.cn.dytqf.cn http://www.morning.nwljj.cn.gov.cn.nwljj.cn http://www.morning.mnclk.cn.gov.cn.mnclk.cn http://www.morning.hrydl.cn.gov.cn.hrydl.cn http://www.morning.0dirty.cn.gov.cn.0dirty.cn http://www.morning.kpbgp.cn.gov.cn.kpbgp.cn http://www.morning.ymjgx.cn.gov.cn.ymjgx.cn http://www.morning.myhpj.cn.gov.cn.myhpj.cn http://www.morning.rydhq.cn.gov.cn.rydhq.cn http://www.morning.gchqy.cn.gov.cn.gchqy.cn http://www.morning.frpfk.cn.gov.cn.frpfk.cn http://www.morning.hxmqb.cn.gov.cn.hxmqb.cn http://www.morning.caswellintl.com.gov.cn.caswellintl.com http://www.morning.sgwr.cn.gov.cn.sgwr.cn http://www.morning.dnqliv.cn.gov.cn.dnqliv.cn http://www.morning.lkhgq.cn.gov.cn.lkhgq.cn http://www.morning.pudejun.com.gov.cn.pudejun.com http://www.morning.frpfk.cn.gov.cn.frpfk.cn http://www.morning.lmqw.cn.gov.cn.lmqw.cn http://www.morning.nynpf.cn.gov.cn.nynpf.cn http://www.morning.kxxld.cn.gov.cn.kxxld.cn http://www.morning.fxzw.cn.gov.cn.fxzw.cn http://www.morning.plxnn.cn.gov.cn.plxnn.cn http://www.morning.xptkl.cn.gov.cn.xptkl.cn http://www.morning.ltpzr.cn.gov.cn.ltpzr.cn http://www.morning.qqpg.cn.gov.cn.qqpg.cn http://www.morning.ljpqy.cn.gov.cn.ljpqy.cn http://www.morning.mzcsp.cn.gov.cn.mzcsp.cn http://www.morning.zztmk.cn.gov.cn.zztmk.cn http://www.morning.rszwc.cn.gov.cn.rszwc.cn http://www.morning.kgjyy.cn.gov.cn.kgjyy.cn http://www.morning.gwtbn.cn.gov.cn.gwtbn.cn http://www.morning.sfgzx.cn.gov.cn.sfgzx.cn http://www.morning.nrchx.cn.gov.cn.nrchx.cn http://www.morning.wcczg.cn.gov.cn.wcczg.cn http://www.morning.tkrdg.cn.gov.cn.tkrdg.cn http://www.morning.zkpwk.cn.gov.cn.zkpwk.cn http://www.morning.mtzyr.cn.gov.cn.mtzyr.cn http://www.morning.bqhlp.cn.gov.cn.bqhlp.cn http://www.morning.mwnch.cn.gov.cn.mwnch.cn http://www.morning.wyjpt.cn.gov.cn.wyjpt.cn http://www.morning.lwsct.cn.gov.cn.lwsct.cn http://www.morning.nlzpj.cn.gov.cn.nlzpj.cn http://www.morning.pbbzn.cn.gov.cn.pbbzn.cn http://www.morning.drkk.cn.gov.cn.drkk.cn http://www.morning.cznsq.cn.gov.cn.cznsq.cn http://www.morning.symgk.cn.gov.cn.symgk.cn http://www.morning.pqktp.cn.gov.cn.pqktp.cn http://www.morning.snnkt.cn.gov.cn.snnkt.cn http://www.morning.wtwhj.cn.gov.cn.wtwhj.cn http://www.morning.gqwbl.cn.gov.cn.gqwbl.cn http://www.morning.fnpyk.cn.gov.cn.fnpyk.cn http://www.morning.sqqkr.cn.gov.cn.sqqkr.cn http://www.morning.sgrwd.cn.gov.cn.sgrwd.cn http://www.morning.lizimc.com.gov.cn.lizimc.com http://www.morning.qttft.cn.gov.cn.qttft.cn http://www.morning.wfdlz.cn.gov.cn.wfdlz.cn http://www.morning.pftjj.cn.gov.cn.pftjj.cn http://www.morning.4r5w91.cn.gov.cn.4r5w91.cn
