草庐IT

Spring-Data-Elasticsearch

全部标签

java - Spring Boot JSR-303/349 配置

在我的SpringBoot1.5.1应用程序中,我尝试配置对JSR-303/JSR-349验证的支持。我在我的方法中添加了以下注释@NotNull@Size(min=1):@Service@TransactionalpublicclassDecisionDaoImplextendsBaseDaoimplementsDecisionDao{@OverridepublicDecisioncreate(@NotNull@Size(min=1)Stringname,Stringdescription,Stringurl,StringimageUrl,DecisionparentDecision

java - elasticsearch:将 StreamOutput 转换为 String

我正在覆盖FilterClient这样我就可以看到传入的请求。我想要一些方法来获得ActionRequest的String表示形式ActionRequest让我们写入StreamOuput,这是一个Elasticsearch类型,是OutputStream的子类.这SOpost展示了如何将OutputStream转换为字符串,但由于FilterClientAPI,我不得不使用StreamOuput。如何获得ActionRequest的字符串表示形式,或者至少是一个可读版本,以显示有关请求的有用信息?(调用ActionRequest.toString调用Object.toString,这

java - spring-boot-starter-parent 在 pom 文件中到底做了什么?

我正在开发一个项目,它不是Springboot,而是springmvc。我的意思是我的项目中没有这个类:@SpringBootApplicationpublicclassApplicationextendsSpringBootServletInitializer{publicstaticvoidmain(String[]args){SpringApplication.run(Application.class,args);}我在springmvc的配置文件中有这三个类:@Import(WebSocketConfig.class)@Configuration@EnableWebMvc@C

java - 如何使用分页在 Spring Data JPA 中通过 SELECT 子句的别名对投影进行排序?

我创建了这两个实体来演示我的问题:所有者实体.java:@EntitypublicclassOwnerEntity{@Id@GeneratedValue(strategy=GenerationType.IDENTITY)privateLongid;@Size(min=1)@OneToMany(mappedBy="ownerEntity",cascade=CascadeType.ALL)privateSetchildEntities=newHashSet();}ChildEntity.java:@EntitypublicclassChildEntity{@Id@GeneratedValu

java - Spring 启动: running a multi module project

我有一个基本的SpringBoot应用程序。使用SpringInitializer,嵌入Tomcat,Thymeleaf模板引擎,并打包为可执行JAR文件。是一个带有SpringBoot的多模块项目,该项目将有3个模块。这里是父模块pom.xml4.0.0org.springframework.bootspring-boot-starter-parent1.5.3.RELEASEcom.tdkcloudtdk-cloud0.0.2-SNAPSHOTpomtdk-coretdk-batchtdk-weborg.springframework.bootspring-boot-starter

java - spring-cloud和ribbon能否实现基于DNS的负载均衡?

Cloudfoundry计划添加对映射到多个IP(每个应用程序容器实例一个)的DNSA记录的支持,请参阅docs-proposal.不知道spring-clouddiscovery加上ribbon能不能支持基于DNS的客户端负载均衡。spring-cloudDiscoveryClient好像不做DNS解析,它管理hostnamesribbon负载平衡库通过ListOfServers支持FQDN列表属性(property)。但我无法找到与指定服务器的DNS查找相关的文档:即如果DNSA/AAA记录(从ListOfServers获取)返回多个IP地址,Ribbon是否会在IP地址之间进行负

java - Spring HATEOAS 构建指向分页资源的链接

我有一个带有方法的Controller,它返回PagedResource,它看起来像这样:@RequestMapping(value="search/within",method=RequestMethod.POST)public@ResponseBodyPagedResourceswithin(@RequestBodyGeoJsonBodybody,Pageablepageable,PersistentEntityResourceAssemblerasm){//GETPAGEreturnpagedResourcesAssembler.toResource(page,asm);}现在,

java - 主 spring bean 被配置中的 ImportResource 覆盖

我有一个Spring测试配置类,它应该覆盖xml-config中现有的bean。但我的问题是xmlbean覆盖了我的测试配置中用primary注释的bean。我尝试用不同的名称命名测试bean,但这对我也不起作用。@RunWith(SpringJUnit4ClassRunner.class)@ContextConfiguration(classes={CamelJmsTest.TestConfig.class})publicclassCamelJmsTest{@Configuration@ImportResource("classpath:production-beans-camel-

java - Elasticsearch Java 高级 REST 客户端建立一堆 TCP 连接并且在索引数据后不关闭它们

我有一个每秒运行一次的周期性作业(这是可配置的)。在这项工作中,我首先创建到Elasticsearch服务器的连接:RestHighLevelClientclient=newRestHighLevelClient(RestClient.builder(newHttpHost(address,port,"http")));然后我检查是否存在名为test的特殊索引。如果它不存在,我会先创建它。GetIndexRequestindexRequest=newGetIndexRequest();indexRequest.indices("test");booleantestIndexIsExis

java - 将错误消息从 SSE (Webflux) Spring Boot 应用程序传递到 Angular 7 前端

我的应用程序是一个具有多个端点的SpringBoot应用程序。我们正在尝试使用Webflux添加支持SSE的端点。用例:第1步:前端向POST端点提交请求并获取唯一ID。第2步:前端使用GET端点(启用SSE-Flux)获取处理后的结果Angular使用EventSource对象来使用SSE端点。它需要端点来生成文本/事件流。它对于正面测试用例非常有效。但是当服务抛出运行时异常时,Angular前端无法获取HTTP状态代码和异常详细信息。它只是没有数据的错误。抛出的异常:@ResponseStatus(code=HttpStatus.NOT_FOUND)publicclassReque