springboot(cloud)整合es_不事王侯的博客-程序员宝宝

技术标签: spring boot  es  springboot整合  

引入依赖

org.springframework.boot
spring-boot-starter-data-elasticsearch




com.alibaba
fastjson
1.2.59

yml文件
在这里插入图片描述
这样启动报错,因为健康检查

2020-06-04 13:50:35.041  WARN 14676 --- [nfoReplicator-0] s.b.a.e.ElasticsearchRestHealthIndicator : Elasticsearch health check failed

java.net.ConnectException: Timeout connecting to [localhost/127.0.0.1:9200]
	at org.elasticsearch.client.RestClient$SyncResponseListener.get(RestClient.java:959) ~[elasticsearch-rest-client-6.8.4.jar:6.8.4]
	at org.elasticsearch.client.RestClient.performRequest(RestClient.java:233) ~[elasticsearch-rest-client-6.8.4.jar:6.8.4]
	at org.springframework.boot.actuate.elasticsearch.ElasticsearchRestHealthIndicator.doHealthCheck(ElasticsearchRestHealthIndicator.java:60) ~[spring-boot-actuator-2.2.1.RELEASE.jar:2.2.1.RELEASE]
	at org.springframework.boot.actuate.health.AbstractHealthIndicator.health(AbstractHealthIndicator.java:82) ~[spring-boot-actuator-2.2.1.RELEASE.jar:2.2.1.RELEASE]
	at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193) ~[na:1.8.0_201]
	at java.util.HashMap$ValueSpliterator.forEachRemaining(HashMap.java:1628) ~[na:1.8.0_201]
	at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:481) ~[na:1.8.0_201]
	at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:471) ~[na:1.8.0_201]
	at java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:708) ~[na:1.8.0_201]
	at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234) ~[na:1.8.0_201]
	at java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:499) ~[na:1.8.0_201]
	at org.springframework.cloud.netflix.eureka.EurekaHealthCheckHandler.getStatus(EurekaHealthCheckHandler.java:195) ~[spring-cloud-netflix-eureka-client-2.2.0.RC1.jar:2.2.0.RC1]
	at org.springframework.cloud.netflix.eureka.EurekaHealthCheckHandler.getHealthStatus(EurekaHealthCheckHandler.java:176) ~[spring-cloud-netflix-eureka-client-2.2.0.RC1.jar:2.2.0.RC1]
	at org.springframework.cloud.netflix.eureka.EurekaHealthCheckHandler.getStatus(EurekaHealthCheckHandler.java:170) ~[spring-cloud-netflix-eureka-client-2.2.0.RC1.jar:2.2.0.RC1]
	at com.netflix.discovery.DiscoveryClient.refreshInstanceInfo(DiscoveryClient.java:1406) ~[eureka-client-1.9.13.jar:1.9.13]
	at com.netflix.discovery.InstanceInfoReplicator.run(InstanceInfoReplicator.java:117) ~[eureka-client-1.9.13.jar:1.9.13]
	at com.netflix.discovery.InstanceInfoReplicator$1.run(InstanceInfoReplicator.java:101) ~[eureka-client-1.9.13.jar:1.9.13]
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) ~[na:1.8.0_201]
	at java.util.concurrent.FutureTask.run$$$capture(FutureTask.java:266) ~[na:1.8.0_201]
	at java.util.concurrent.FutureTask.run(FutureTask.java) ~[na:1.8.0_201]
	at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180) ~[na:1.8.0_201]
	at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293) ~[na:1.8.0_201]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[na:1.8.0_201]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[na:1.8.0_201]
	at java.lang.Thread.run(Thread.java:748) ~[na:1.8.0_201]
Caused by: java.net.ConnectException: Timeout connecting to [localhost/127.0.0.1:9200]
	at org.apache.http.nio.pool.RouteSpecificPool.timeout(RouteSpecificPool.java:169) ~[httpcore-nio-4.4.12.jar:4.4.12]
	at org.apache.http.nio.pool.AbstractNIOConnPool.requestTimeout(AbstractNIOConnPool.java:628) ~[httpcore-nio-4.4.12.jar:4.4.12]
	at org.apache.http.nio.pool.AbstractNIOConnPool$InternalSessionRequestCallback.timeout(AbstractNIOConnPool.java:894) ~[httpcore-nio-4.4.12.jar:4.4.12]
	at org.apache.http.impl.nio.reactor.SessionRequestImpl.timeout(SessionRequestImpl.java:184) ~[httpcore-nio-4.4.12.jar:4.4.12]
	at org.apache.http.impl.nio.reactor.DefaultConnectingIOReactor.processTimeouts(DefaultConnectingIOReactor.java:214) ~[httpcore-nio-4.4.12.jar:4.4.12]
	at org.apache.http.impl.nio.reactor.DefaultConnectingIOReactor.processEvents(DefaultConnectingIOReactor.java:158) ~[httpcore-nio-4.4.12.jar:4.4.12]
	at org.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor.execute(AbstractMultiworkerIOReactor.java:351) ~[httpcore-nio-4.4.12.jar:4.4.12]
	at org.apache.http.impl.nio.conn.PoolingNHttpClientConnectionManager.execute(PoolingNHttpClientConnectionManager.java:221) ~[httpasyncclient-4.1.4.jar:4.1.4]
	at org.apache.http.impl.nio.client.CloseableHttpAsyncClientBase$1.run(CloseableHttpAsyncClientBase.java:64) ~[httpasyncclient-4.1.4.jar:4.1.4]
	... 1 common frames omitted

在这里插入图片描述

一.创建一个bean,用于数据增删改查
在这里插入图片描述

二.创建一个类似mapping的类
在这里插入图片描述
三.数据的增删改查
增加:
在这里插入图片描述
删除
在这里插入图片描述
修改:
在这里插入图片描述
查询:高亮还有问题在找,找到后补充

   public Page<UserVo> getShow(String name) {
        QueryStringQueryBuilder img = QueryBuilders.queryStringQuery("\""+name+"\"");
//        MatchQueryBuilder img = QueryBuilders.matchQuery("name", name);
        FieldSortBuilder id = SortBuilders.fieldSort("id").order(SortOrder.ASC);
        HighlightBuilder highlightBuilder = new HighlightBuilder().field("name").preTags("<span style=\"color:red\">").postTags("</span>").requireFieldMatch(false);

//        highlightBuilder.requireFieldMatch(true);     //如果要多个字段高亮,这项要为false

        //下面这两项,如果你要高亮如文字内容等有很多字的字段,必须配置,不然会导致高亮不全,文章内容缺失等
//        highlightBuilder.fragmentSize(800000); //最大高亮分片数
//        highlightBuilder.numOfFragments(0); //从第一个分片获取高亮片段
        Pageable pageable = PageRequest.of(0, 10);
//        NativeSearchQuery nativeSearchQueryBuildel = new NativeSearchQueryBuilder().withQuery(img).withSort(id).withHighlightBuilder(highlightBuilder).withPageable(pageable).build();
        NativeSearchQuery nativeSearchQueryBuildel = new NativeSearchQueryBuilder().withQuery(img).withSort(id).withHighlightFields(new HighlightBuilder.Field("name")).withPageable(pageable).build();
        Page<UserVo> search = userVoAddElasticsearch.search(nativeSearchQueryBuildel);
       log.warn( search.toString());
        return search;
    }
版权声明:本文为博主原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。
本文链接:https://blog.csdn.net/yanchun_cheng/article/details/106544599

智能推荐

eclipse(快捷键)积累中............_Taoey的博客-程序员宝宝_ecplice uid快捷键

多行注释:Ctrl+shift+/ 单行注释:Ctrl+/ 快速格式化代码:Ctrl+shift+f 自动导入一个包:Ctrl+shift+o 放大屏幕:Ctrl+m 删除所选区域:Ctrl+d 移动所选区域 :Alt+上下左右键 展开(合并)代码:Ctrl+/(小键盘)

qt5.9支持linux,科学网—Qt5.9发布了,Qt 5.9长期支持版之性能改善 - 陈德鹏的博文..._weixin_39602637的博客-程序员宝宝

PerformanceImprovements with Qt 5.9 LTSQt5.9长期支持版之性能改善Qt 5.9 LTS improves Qt Quick and QMLperformance significantly, especially with Linux on ARM. We have worked hard toimprove the performance in mult...

VS2005(c#)项目调试问题解决方案集锦 转_aiqixiao2017的博客-程序员宝宝

上一次整了个VS2003的,结果反应甚好,当然能帮助大家在程序调试过程中提高效率不失是一件快乐的事,这次也是根据一个项目开发过程中所碰到的种种问题,俺把他记下来了,同时在网站搜集了一些问题及解决方法,一来做个记录好让自己以后可以有章可查,二来发出来给大家分享.分享技术,分享快乐,一直是俺们网站电子期刊的宗旨.希望大家喜欢:) 废话少说:我们要给大家有用的东西才行,希望以...

Mac 安装 ClickHouse 报错: Mac 10.15.4: Cannot find objcopy_禅与计算机程序设计艺术的博客-程序员宝宝

Solutionrun the command below:$ brew install binutilsUpdating Homebrew...==&gt; Auto-updated Homebrew!Updated 1 tap (homebrew/cask).==&gt; Updated CasksUpdated 2 casks.==&gt; Downloading http...

自动化失败的6种原因_多则惑少则明的博客-程序员宝宝

目录摘要内容1. People don’t understand what to automate (and what not to automate)人们不明白要自动化什么(以及什么不能自动化)2. The team doesn’t have technically skilled people团队没有技术熟练的人员3. There’s low visibility arou...

perl system,exec,readpipe 函数_生于忧患-死于安乐-人生不能虚度---的博客-程序员宝宝_readpipe命令

转载:http://blog.sina.com.cn/s/blog_615770bd0100rzrd.html在Perl脚本中,允许调用系统的命令来进行操作。这就是Perl灵活性的体现,作为一种系统命令的粘合语言,能给程序员带来许多的便利。这样,你就可以最大限度地利用别人的成果,用不着自己使劲造轮子了。在Perl中,可以用system、exec、readpipe这三个命令来调用其他脚本

随便推点

理解devfs、sysfs、udev_Cnfo的博客-程序员宝宝_/dev和/sysfs

linux下有专门的文件系统用来对设备进行管理,devfs和sysfs就是其中两种。  一、devfs  devfs是在2.4内核就出现了,它是用来解决linux中设备管理混乱的问题,你查看一下/dev下的设备文件就知道其中有许多是空的(也就是没有对应的硬件的),但是它们却必须存在,所以这给linux设备管理带来了很多麻烦,为了解决这个问题,linux内核开发人员开发了devfs,

win10网络显示图标异常解决方法_spy159的博客-程序员宝宝_win10电脑可以上网但是图标显示异常

电脑可上网,但图标显示未连接,如下图所示右键点击左下角的开始—运行—regedit,确定,打开注册表编辑器;2、找到注册表键值HKEY_LOCAL_MACHINE\SYSTEM\CurrentControlSet\services\NlaSvc\Parameters\Internet3、双击Internet窗口右侧中的“EnableActiveProbing”,然后将其值更改为0。4、点击确定,然后重启计算机。...

【分布式专题】-- 分布式架构设计_Hepburn Yang的博客-程序员宝宝_分布式专题

重要概念集群:一个厨师炒菜不够人手,来了多个厨师炒菜;分布式: 三个厨师合伙分工做一道菜,洗菜,切菜,炒菜分工着来;节点:洗菜,切菜,可作为单独的节点独立部署;副本机制: 备份的,替身。中间件:在应用层和操作系统之间提供服务 ,能让我们的系统开发人员更方便的处理通信和输入输出,开发人员更关注自己所需要处理的领域。单表数据量大怎么办;垂直分库:单独部署(商品,用户,支付等单独部署...

WMI Provider Host_bobob_的博客-程序员宝宝_wmtray可以禁用吗

从技术上来说,「Windows Management Instrumentation」服务是可以禁用的,但这会影响到 Windows PC 的诸多方面,所以该服务应该让其独自运行。正如 WMI 服务的官方描述所说:如果此服务被终止,多数基于 Windows 的软件将无法正常运行。所以不应该禁用此项服务!  如果你遇到 WMI Provider Host (WmiPrvSE.exe)进程长期高 ...

Centos 性能调优基本策略设定_wzyzzu的博客-程序员宝宝

关于ulimitulimit -a 用来显示当前的各种用户进程限制。Linux对于每个用户,系统限制其最大进程数。为提高性能,可以根据设备资源情况,设置各linux 用户的最大进程数,下面我把某linux用户的最大进程数设为10000个:ulimit -u 10000对于需要做许多 socket 连接并使它们处于打开状态的 Java 应用程序而言,最好通过使用 ulimit -