Python微信订餐小程序课程视频
https://edu.csdn.net/course/detail/36074
Python实战量化交易理财系统
https://edu.csdn.net/course/detail/35475v阅读目录* v基础概念
Elasticsearch 是一个分布式、高扩展、高实时的搜索与数据分析引擎。它能很方便的使大量数据具有搜索、分析和探索的能力。充分利用Elasticsearch的水平伸缩性,能使数据在生产环境变得更有价值。Elasticsearch 的实现原理主要分为以下几个步骤,首先用户将数据提交到Elasticsearch 数据库中,再通过分词控制器去将对应的语句分词,将其权重和分词结果一并存入数据,当用户搜索数据时候,再根据权重将结果排名,打分,再将返回结果呈现给用户。
在上一篇文章linux安装elasticsearch中,已经介绍了在linux安装elasticsearch,这篇文章主要介绍介绍es的一些基础的入门教程、docker安装elasticsearch以及在springboot中整合elasticsearch。
回到顶部## v基础概念
1.0 Node与Cluster
Node:单个Elastic实例称为一个节点(node)
Cluster:一组节点构成一个集群(cluster)
当然,这也正是集群和节点最通俗的解释,这个解释适用于绝大部分,类似elasticsearch这种分布式架构。如之前讲过的《详解Redis Cluster集群》。你可以可以说node就是单个redis实例,这样的实例我们称为一个节点,多个这样的节点组成的集群。正因为如此,我们在设计架构的时候,需要考虑不同环境的不同节点的节点名注意不要重复,避免配置集群遇到尴尬。
1.1 Index
由一个和多个分片组成,通过索引的名字在集群内进行唯一标识。索引是具有某种相似特征的文档的集合,Elastic数据管理的顶层设计就叫做 Index(索引)。类似mysql中的database。
索引也分为名次索引和动词索引。
- 索引(名词):如前所述,一个 索引 类似于传统关系数据库中的一个 数据库 ,是一个存储关系型文档的地方。 索引 (index) 的复数词为 indices 或 indexes 。
- 索引(动词):索引一个文档 就是存储一个文档到一个 索引 (名词)中以便被检索和查询。这非常类似于 SQL 语句中的 INSERT 关键词,除了文档已存在时,新文档会替换旧文档情况之外。
这个也好理解,类似词组"表演",看她的表演,表演的很精彩。这是两个意思。
1.2 Document
Elasticsearch是面向文档的,意味着它存储整个对象或文档。文档是可以被索引的基本信息单元,文档用JSON表示。
例如:存储员工信息,那就是一个员工信息代表一个文档,多个文档组成一个index。类似于关系型数据库中的一条数据通过id在Type内进行唯一标识。
1.3 Type
类别,指索引内部的逻辑分区,通过type的名字在索引内进行唯一标识。在查询时如果没有该值,则表示在整个索引中查询。
例如:在员工表里,可以按照员工籍贯分组(北上、上海、广州),也可以按照员工工种分组(职能、产品、运营)。这种分组可以理解为type。
在7.x版会移除Type。Elasticsearch为何要在7.X版本中去除type
1.4 与关系型数据库对比
Relational DB | Elasticsearch |
---|---|
数据库(database) | 索引 index |
表(tables) | 类型 types |
行(rows) | 文档 documents |
字段(columns) | fields |
1.5 Mapping
定义文档及其包含的字段是如何存储和索引的过程,类似于数据库中的表结构定义,主要作用如下:
- 定义index下的字段名
- 定义字段类型,比如数值型、浮点型、布尔型等
- 定义倒排索引相关的设置,比如是否索引、记录position等
回到顶部## vdocker安装Elasticsearch
在上一篇文章中,已经详细介绍了linux安装elasticsearch,这篇文章讲解的elasticsearch主要围绕docker展开。
2.0 拉取镜像
docker pull docker.io/elasticsearch:版本号
版本号是可选的,默认使用latest
2.1 创建&运行容器
docker run -d --name=es7 \
-p 9200:9200 -p 9300:9300 \
-e "discovery.type=single-node" elasticsearch:7.5.1
注意:若创建es持久化目录,则按下面的命令执行。
mkdir -p /data/elasticsearch
docker cp es7:/usr/share/elasticsearch/data /data/elasticsearch/
docker cp es7:/usr/share/elasticsearch/logs /data/elasticsearch/
docker rm -f es7
docker run -d --name=es7 \
--restart=always \
-p 9200:9200 -p 9300:9300 \
-e "discovery.type=single-node" \
-v /data/elasticsearch/data:/usr/share/elasticsearch/data \
-v /data/elasticsearch/logs:/usr/share/elasticsearch/logs \
elasticsearch:7.5.1
注意:若es起不来,可能是容器没有宿主机挂载的目录的读写权限,那就需要赋予它读写权限: chmod 777 /data/elasticsearch
2.2 验证效果
输入ip + 端口号(9200)验证。
2.3 安装elasticsearch-head
docker pull mobz/elasticsearch-head:5
2.4 创建&运行head容器
docker run -d --name elasticsearch-head -p 9100:9100 mobz/elasticsearch-head:5
2.5 跨域问题
url访问http://toutou.com:9100之后发现无法连接http://toutou.com:9200,需要在es服务端做CORS的配置。
修改docker中es7的elasticsearch.yml文件
[root@localhost data]# docker exec -it es7 /bin/bash
[root@f1358d18c9be elasticsearch]# vi config/elasticsearch.yml
在elasticsearch.yml底部追加如下配置:
http.cors.enabled: true
http.cors.allow-origin: "*"
保存以后退出docker并重启docker实例。
[root@f1358d18c9be elasticsearch]# exit
exit
[root@localhost data]# docker restart es7
es7
2.6 验证elasticsearch-head
2.7 安装中文分词器ik
注意:ik分词器的版本需要和es的版本一致。
docker exec -it es7 /bin/bash
./bin/elasticsearch-plugin install https://github.com/medcl/elasticsearch-analysis-ik/releases/download/v7.5.1/elasticsearch-analysis-ik-7.5.1.zip
-> Downloading https://github.com/medcl/elasticsearch-analysis-ik/releases/download/v7.5.1/elasticsearch-analysis-ik-7.5.1.zip
进入plugins可以看到IK分词器已经安装成功,重启docker实例即可。
回到顶部## vRESTful API
任何语言都可以使用RESTful API通过9200端口(默认端口号)和Elasticsearch进行通信,也可以用web客户端(浏览器Sense插件、postman)访问 Elasticsearch ,甚至直接使用curl命令就可以和Elasticsearch交互。
Elasticsearch为很多语言(Groovy、JavaScript、.NET、 PHP、 Perl、 Python 和 Ruby)提供了官方客户端。详情:Elasticsearch Clients。
3.0 Elasticsearch请求格式:
Elasticsearch请求和我们认识的其它HTTP请求一样,由多个部件组成,具体格式如下:
curl -X<VERB> '<PROTOCOL>://<HOST>:<PORT>/<PATH>?<QUERY\_STRING>' -d '<BODY>'
被 < >
标记的部件释义:
- VERB:HTTP请求方法: GET、POST、PUT、DELETE、HEAD...
GET:标识该操作是用于获取服务端的资源,可以理解为select操作
POST:用于向服务端新增数据,常用于提交表单。可以理解为insert操作
PUT:用于向服务端更新数据,与post的使用很相似。可以理解为update操作
DELETE:标识该操作是:用于删除服务端的资源,可以理解为delete操作
HEAD:只请求页面首部,响应报文中没有实体的主体部分(没有body体)
点击查看几种http方法的区别...
- PROTOCOL:http 或者 https
概念:
HTTP:是互联网上应用最为广泛的一种网络协议,是一个客户端和服务器端请求和应答的标准(TCP),用于从WWW服务器传输超文本到本地浏览器的传输协议,它可以使浏览器更加高效,使网络传输减少。
HTTPS:是以安全为目标的HTTP通道,简单讲是HTTP的安全版,即HTTP下加入SSL层,HTTPS的安全基础是SSL,因此加密的详细内容就需要SSL。
区别:
1.https协议需要到ca申请证书,一般免费证书很少,需要交费。
2.http是超文本传输协议,信息是明文传输,https 则是具有安全性的ssl加密传输协议。
3.http和https使用的是完全不同的连接方式,用的端口也不一样,前者是80,后者是443。
4.http的连接很简单,是无状态的;HTTPS协议是由SSL+HTTP协议构建的可进行加密传输、身份认证的网络协议,比http协议安全。
点击查看http和https的区别
- HOST:Elasticsearch 集群中任意节点的主机名,或者用 localhost 代表本地机器上的节点。
- PORT:服务的端口号,默认是9200。
- PATH:API 的终端路径(例如
_count
将返回集群中文档数量)。Path可能包含多个组件,例如:_cluster/stats
和_nodes/stats/jvm
。 - QUERY_STRING:任意可选的查询字符串参数 (例如
?pretty
将格式化地输出JSON返回值,使其更容易阅读) - BODY:一个 JSON格式的请求体(如果请求需要的话)
3.1 计算集群中文档的数量
命令行格式: curl -XGET http://test.com:9200/_count?pretty
当然,也可以考虑使用其他工具,例如postman。
3.2 集群健康
Elasticsearch的集群监控信息中包含了许多的统计数据,其中最为重要的一项就是集群健康 , 它在 status 字段中展示为green、yellow或者red。
curl http://test.com:9200/_cluster/health
postman请求返回结果如下:
{
"cluster\_name": "my-application",
"status": "green",
"timed\_out": false,
"number\_of\_nodes": 1,//集群节点数
"number\_of\_data\_nodes": 1,//数据节点数量
"active\_primary\_shards": 0,//主分片数量
"active\_shards": 0,//可用的分片数量
"relocating\_shards": 0,//正在重新分配的分片数量,在新加或者减少节点的时候会发生
"initializing\_shards": 0,//正在初始化的分片数量,新建索引或者刚启动会存在,时间很短
"unassigned\_shards": 0,//没有分配的分片,一般就是那些名存实不存的副本分片
"delayed\_unassigned\_shards": 0,
"number\_of\_pending\_tasks": 0,
"number\_of\_in\_flight\_fetch": 0,
"task\_max\_waiting\_in\_queue\_millis": 0,
"active\_shards\_percent\_as\_number": 100
}
3.3 status三种状态值:
- green:所有的主分片和副本分片都正常运行。
- yellow:所有的主分片都正常运行,但不是所有的副本分片都正常运行。
- red:有主分片没能正常运行。
更多参数介绍:
索引级别集群状态,可以细致查看到底是哪个索引引起集群的故障的
curl http://test.com:9200/_cluster/health?level=indices
分片级别集群状态,可以细致查看到底是哪个分片引起的集群故障
curl http://test.com:9200/_cluster/health?level=shards
阻塞查看集群状态,适用于自动化脚本。当状态变为指定状态或者更好就返回继续执行。
curl http://test.com:9200/_cluster/health?wait_for_status=yellow
回到顶部## v操作Elasticsearch
4.1 索引操作
4.1.1 查看索引是否存在
curl -i -XHEAD 'http://toutou.com:9200/city'
若索引存在:
HTTP/1.1 200 OK
content-type: application/json; charset=UTF-8
content-length: 239
若索引不存在:
HTTP/1.1 404 Not Found
content-type: application/json; charset=UTF-8
content-length: 395
4.1.2 创建Index
创建一个非结构化的索引,需要使用PUT请求。例如创建一个名为city的索引。
curl -X PUT '127.0.0.1:9200/city'
返回结果:
{
"acknowledged":true,"
shards\_acknowledged":true,
"index":"city"
}
acknowledged=true表示操作成功。
创建一个结构化的索引:
{
"settings":{
"number\_of\_shards":3,
"number\_of\_replicas":1
},
"mappings":{
"properties":{
"name":{
"type":"text",
"analyzer":"ik\_max\_word",
"search\_analyzer":"ik\_max\_word"
},
"level":{
"type":"integer"
},
"address":{
"type":"text",
"analyzer":"ik\_smart",
"search\_analyzer":"ik\_smart"
},
"createTime":{
"type":"date",
"format":"yyyy-MM-dd HH:mm:ss || yyyy-MM-dd || epoch\_millis"
}
}
}
}
View Code
number_of_shards表示分片个数,number_of_replicas表示备份个数。
注意:在上文中已经介绍了,在在7.x版会移除Type。所以这里不需要再指定type, 相反若指定type了的话会报错。 Root mapping definition has unsupported parameters
建议使用elasticsearch最新版本,若安装的是低于elasticsearch7版本的elasticsearch,可以使用下面的方式创建索引。
{
"settings":{
"number\_of\_shards":3,
"number\_of\_replicas":1
},
"mappings":{
"hotel":{
"properties":{
"level":{
"type":"integer"
},
"address":{
"type":"text",
"analyzer":"ik\_max\_word"
},
"createTime":{
"type":"date",
"format":"yyyy-MM-dd HH:mm:ss || yyyy-MM-dd || epoch\_millis"
}
}
},
"restaurant":{
"properties":{
"type":{
"type":"text",
"analyzer":"ik\_smart"
},
"price":{
"type":"integer"
}
}
}
}
}
View Code
4.1.3 删除Index
$ curl -X DELETE '127.0.0.1:9200/city'
返回结果:
{"acknowledged":true}
4.2 插入数据
4.2.1 插入指定id的数据
在 es 中,插入数据分为指定文档id插入和自动产生文档id插入
指定文档id插入,其中我们指定数据ID为1。
生成id=1的数据。
注意,在在7.x版会移除Type,所以插入数据的url需要加上 _doc
,即: http://toutou.com:9200/city/_doc/1
。具体规则可以看看这里
自动产生文档id插入。
4.3 修改数据
4.4 查询数据
4.4.1 ID查询GET
4.4.2 条件查询POST
查询5星级酒店。
4.5 删除数据
curl -X DELETE 'toutou.com:9200/city/_doc/2'
回到顶部## vSpringBoot整合Elasticsearch
spring-boot-starter-data-elasticsearch调试了很久,尝试的很多方法,始终报错: NoNodeAvailableException[None of the configured nodes are available: [{#transport#-1}{wlOJEdIeQqKrmiBiUuJVzQ}{toutou.com}{192.168.118.137:9300}]]
。看了一些相关介绍和博客,Spring Data Elasticsearch和Elasticsearch还有Spring Boot的版本需要全部一一对应上,才能使用。感觉太麻烦,新项目还好说,线上项目谁有功夫去跟你协调这些版本统一啊,费老劲了。果断弃用了。如果有大佬这块有好上手的兼容办法,还请多多指点。
5.1 添加pom引用
<dependency>
<groupId>org.elasticsearch.clientgroupId>
<artifactId>elasticsearch-rest-high-level-clientartifactId>
dependency>
注意:如果是springboot程序的话, org.elasticsearch.client
引用的版本号 7.5.1
最好注释掉,不然会报下面这个错:
org.springframework.beans.factory.UnsatisfiedDependencyException: Error creating bean with name 'indexController': Unsatisfied dependency expressed through field 'cityEsService'; nested exception is org.springframework.beans.factory.UnsatisfiedDependencyException: Error creating bean with name 'cityEsServiceImpl': Unsatisfied dependency expressed through field 'client'; nested exception is org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'client' defined in class path resource [learn/service/impl/EsConfig.class]: Post-processing of merged bean definition failed; nested exception is java.lang.IllegalStateException: Failed to introspect Class [org.elasticsearch.client.RestHighLevelClient] from ClassLoader [sun.misc.Launcher$AppClassLoader@18b4aac2]
at org.springframework.beans.factory.annotation.AutowiredAnnotationBeanPostProcessor$AutowiredFieldElement.inject(AutowiredAnnotationBeanPostProcessor.java:596)
at org.springframework.beans.factory.annotation.InjectionMetadata.inject(InjectionMetadata.java:90)
at org.springframework.beans.factory.annotation.AutowiredAnnotationBeanPostProcessor.postProcessProperties(AutowiredAnnotationBeanPostProcessor.java:374)
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.populateBean(AbstractAutowireCapableBeanFactory.java:1411)
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:592)
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:515)
at org.springframework.beans.factory.support.AbstractBeanFactory.lambda$doGetBean$0(AbstractBeanFactory.java:320)
at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:222)
at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:318)
at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:199)
at org.springframework.beans.factory.support.DefaultListableBeanFactory.preInstantiateSingletons(DefaultListableBeanFactory.java:845)
at org.springframework.context.support.AbstractApplicationContext.finishBeanFactoryInitialization(AbstractApplicationContext.java:877)
at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:549)
at org.springframework.boot.web.servlet.context.ServletWebServerApplicationContext.refresh(ServletWebServerApplicationContext.java:140)
at org.springframework.boot.SpringApplication.refresh(SpringApplication.java:742)
at org.springframework.boot.SpringApplication.refreshContext(SpringApplication.java:389)
at org.springframework.boot.SpringApplication.run(SpringApplication.java:311)
at org.springframework.boot.SpringApplication.run(SpringApplication.java:1213)
at org.springframework.boot.SpringApplication.run(SpringApplication.java:1202)
at learn.web.Application.main(Application.java:18)
Caused by: org.springframework.beans.factory.UnsatisfiedDependencyException: Error creating bean with name 'cityEsServiceImpl': Unsatisfied dependency expressed through field 'client'; nested exception is org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'client' defined in class path resource [learn/service/impl/EsConfig.class]: Post-processing of merged bean definition failed; nested exception is java.lang.IllegalStateException: Failed to introspect Class [org.elasticsearch.client.RestHighLevelClient] from ClassLoader [sun.misc.Launcher$AppClassLoader@18b4aac2]
at org.springframework.beans.factory.annotation.AutowiredAnnotationBeanPostProcessor$AutowiredFieldElement.inject(AutowiredAnnotationBeanPostProcessor.java:596)
at org.springframework.beans.factory.annotation.InjectionMetadata.inject(InjectionMetadata.java:90)
at org.springframework.beans.factory.annotation.AutowiredAnnotationBeanPostProcessor.postProcessProperties(AutowiredAnnotationBeanPostProcessor.java:374)
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.populateBean(AbstractAutowireCapableBeanFactory.java:1411)
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:592)
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:515)
at org.springframework.beans.factory.support.AbstractBeanFactory.lambda$doGetBean$0(AbstractBeanFactory.java:320)
at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:222)
at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:318)
at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:199)
at org.springframework.beans.factory.config.DependencyDescriptor.resolveCandidate(DependencyDescriptor.java:277)
at org.springframework.beans.factory.support.DefaultListableBeanFactory.doResolveDependency(DefaultListableBeanFactory.java:1251)
at org.springframework.beans.factory.support.DefaultListableBeanFactory.resolveDependency(DefaultListableBeanFactory.java:1171)
at org.springframework.beans.factory.annotation.AutowiredAnnotationBeanPostProcessor$AutowiredFieldElement.inject(AutowiredAnnotationBeanPostProcessor.java:593)
... 19 common frames omitted
Caused by: org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'client' defined in class path resource [learn/service/impl/EsConfig.class]: Post-processing of merged bean definition failed; nested exception is java.lang.IllegalStateException: Failed to introspect Class [org.elasticsearch.client.RestHighLevelClient] from ClassLoader [sun.misc.Launcher$AppClassLoader@18b4aac2]
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:570)
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:515)
at org.springframework.beans.factory.support.AbstractBeanFactory.lambda$doGetBean$0(AbstractBeanFactory.java:320)
at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:222)
at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:318)
at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:199)
at org.springframework.beans.factory.config.DependencyDescriptor.resolveCandidate(DependencyDescriptor.java:277)
at org.springframework.beans.factory.support.DefaultListableBeanFactory.doResolveDependency(DefaultListableBeanFactory.java:1251)
at org.springframework.beans.factory.support.DefaultListableBeanFactory.resolveDependency(DefaultListableBeanFactory.java:1171)
at org.springframework.beans.factory.annotation.AutowiredAnnotationBeanPostProcessor$AutowiredFieldElement.inject(AutowiredAnnotationBeanPostProcessor.java:593)
... 32 common frames omitted
Caused by: java.lang.IllegalStateException: Failed to introspect Class [org.elasticsearch.client.RestHighLevelClient] from ClassLoader [sun.misc.Launcher$AppClassLoader@18b4aac2]
at org.springframework.util.ReflectionUtils.getDeclaredMethods(ReflectionUtils.java:507)
at org.springframework.util.ReflectionUtils.doWithLocalMethods(ReflectionUtils.java:367)
at org.springframework.beans.factory.annotation.InitDestroyAnnotationBeanPostProcessor.buildLifecycleMetadata(InitDestroyAnnotationBeanPostProcessor.java:207)
at org.springframework.beans.factory.annotation.InitDestroyAnnotationBeanPostProcessor.findLifecycleMetadata(InitDestroyAnnotationBeanPostProcessor.java:189)
at org.springframework.beans.factory.annotation.InitDestroyAnnotationBeanPostProcessor.postProcessMergedBeanDefinition(InitDestroyAnnotationBeanPostProcessor.java:128)
at org.springframework.context.annotation.CommonAnnotationBeanPostProcessor.postProcessMergedBeanDefinition(CommonAnnotationBeanPostProcessor.java:297)
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.applyMergedBeanDefinitionPostProcessors(AbstractAutowireCapableBeanFactory.java:1077)
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:567)
... 41 common frames omitted
Caused by: java.lang.NoClassDefFoundError: org/elasticsearch/client/Cancellable
at java.lang.Class.getDeclaredMethods0(Native Method)
at java.lang.Class.privateGetDeclaredMethods(Class.java:2701)
at java.lang.Class.getDeclaredMethods(Class.java:1975)
at org.springframework.util.ReflectionUtils.getDeclaredMethods(ReflectionUtils.java:489)
... 48 common frames omitted
Caused by: java.lang.ClassNotFoundException: org.elasticsearch.client.Cancellable
at java.net.URLClassLoader.findClass(URLClassLoader.java:381)
at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:335)
at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
... 52 common frames omitted
View Code
因为就像上文提到的data与es version冲突似的, org.elasticsearch.client
也有版本之间的兼容性问题,把 org.elasticsearch.client
的版本号去掉由SpringBoot来管理依赖的版本即可。
5.2 添加EsConfig
import com.google.gson.Gson;
import org.apache.http.HttpHost;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestHighLevelClient;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
/**
* @author toutou
* @date by 2021/02
* @des
*/
@Configuration
public class EsConfig {
public Gson gson(){
return new Gson();
}
@Bean
public RestHighLevelClient client(){
RestHighLevelClient client=new RestHighLevelClient(
RestClient.builder(
// 本地demo快速实现效果,host等信息直接写成固定值了。
new HttpHost("toutou.com",9200,"http")
)
);
return client;
}
}
5.3 根据id查询城市酒店信息
5.3.1 添加Service
CityEsService:
import java.util.Map;
/**
* @author toutou
* @date by 2021/02
* @des
*/
public interface CityEsService {
Map getCityById(String id);
}
iceCityEsService
CityEsServiceImpl:
package learn.service.impl;
import learn.service.CityEsService;
import org.elasticsearch.action.get.GetRequest;
import org.elasticsearch.action.get.GetResponse;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestHighLevelClient;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.io.IOException;
import java.util.HashMap;
import java.util.Map;
/**
* @author toutou
* @date by 2021/02
* @des
*/
@Service
public class CityEsServiceImpl implements CityEsService{
@Autowired
private RestHighLevelClient client;
@Override
public Map getCityById(String id){
GetRequest getRequest=new GetRequest("city","\_doc",id);
Map map=new HashMap();
GetResponse response=null;
try{
response= client.get(getRequest, RequestOptions.DEFAULT);
} catch (IOException e) {
e.printStackTrace();
}
if(response.isExists()){
// 本初为了方便演示,将id返回
map.put("id", response.getId());
// 默认不返回id信息,若不需要id信息直接返回getSource结果即可。
map.putAll(response.getSource());
return map;
}else{
throw new RuntimeException("Is not exists.");
}
}
}
5.3.2 添加Controller
/**
* @author toutou
* @date by 2021/2
* @des https://blog.csdn.net/toutou
*/
@Slf4j
@RestController
public class IndexController {
@Autowired
private CityEsService cityEsService;
@GetMapping("es/search")
public Result esSearch(@RequestParam("id") String id) {
return Result.setSuccessResult(cityEsService.getCityById(id));
}
}
5.3.3 效果验证
由于service层和Controller大部分代码都是重复的,下面就只贴service层代码实现了,感兴趣的可以在文章底部的源码中查看更多细节。
5.4 根据id删除城市酒店信息
5.4.1 删除方法实现代码
@Override
public String delCityById(String id){
try {
DeleteRequest request=new DeleteRequest("city","\_doc",id);
DeleteResponse response= client.delete(request,RequestOptions.DEFAULT);
return response.status().name();
} catch (IOException e) {
throw new RuntimeException("删除失败.");
}
}
5.4.2 效果验证
5.5 添加数据
@Override
public String addCityByInfo(String id, String name, Integer level, String address, String createTime){
Map jsonMap = new HashMap<>();
jsonMap.put("name", name);
jsonMap.put("level", level);
jsonMap.put("address", address);
jsonMap.put("createTime", createTime);
// 若不需要创建指定id的数据,则不需要再IndexRequest的构造函数中传入id
// IndexRequest indexRequest = new IndexRequest("city", "\_doc");
IndexRequest indexRequest = new IndexRequest("city", "\_doc", id);
indexRequest.source(jsonMap);
try {
IndexResponse rp = client.index(indexRequest);
return rp.status().name();
} catch (IOException e) {
throw new RuntimeException("添加失败.");
}
}
5.6 修改数据
@Override
public String updateCityByInfo(String id, String name){
UpdateRequest request=new UpdateRequest("city","\_doc", id);
Map jsonMap = new HashMap<>();
jsonMap.put("name", name);
request.doc(jsonMap);
try {
return client.update(request,RequestOptions.DEFAULT).status().name();
} catch (IOException e) {
throw new RuntimeException("修改失败.");
}
}
5.7 复合查询
public List> query(String name, Integer level, Integer index, Integer size){
SearchRequest request = new SearchRequest("city");
BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery();
boolQueryBuilder.must(QueryBuilders.matchQuery("name", name));
boolQueryBuilder.must(QueryBuilders.matchQuery("level", level));
SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
//排序
searchSourceBuilder.sort(SortBuilders.fieldSort("createTime").order(SortOrder.DESC));
//分页
searchSourceBuilder.from(index).size(size).query(boolQueryBuilder);
request.searchType(SearchType.DEFAULT).source(searchSourceBuilder);
List> list = new ArrayList<>();
try {
SearchResponse rp = client.search(request, RequestOptions.DEFAULT);
for (SearchHit item : rp.getHits().getHits()) {
list.add(item.getSourceAsMap());
}
} catch (IOException e) {
throw new RuntimeException("查询失败.");
}
return list;
}
其他参考资料:
回到顶部## v源码地址
https://github.com/toutouge/javademosecond/tree/master/hellospringboot
您可以考虑给头头来个小小的打赏以资鼓励,您的肯定将是我最大的动力。thx.
微信打赏
支付宝打赏
作 者:请叫我头头哥
出 处:https://blog.csdn.net/toutou/
关于作者:专注于基础平台的项目开发。如有问题或建议,请多多赐教!
版权声明:本文版权归作者和博客园共有,欢迎转载,但未经作者同意必须保留此段声明,且在文章页面明显位置给出原文链接。
特此声明:所有评论和私信都会在第一时间回复。也欢迎园子的大大们指正错误,共同进步。或者直接私信我
声援博主:如果您觉得文章对您有帮助,可以点击文章右下角【推荐】一下。您的鼓励是作者坚持原创和持续写作的最大动力!
comment_body_3242240 { display: none }
* 基础概念