spring-boot相关内容
我正在SpringBoot中创建一个新的端点,它将返回从Mongo数据库中的聚合查询生成的用户的简单统计信息。然而,我得到一个PropertyReferenceException。我已经阅读了有关它的多个堆栈溢出问题,但没有找到解决此问题的问题。 我们有这样的Mongo数据方案: { "_id" : ObjectId("5d795993288c3831c8dffe60"), "us
..
我在我的环境中使用以下依赖项: Spring-Boot-starter-Parent-v2.3.5版本 Spring-Boot-starter-data-Cassandra-ame Cassandra-Driver-core(com.datastax.cassandra)-v3.2.0 如何访问我的设置中com.datastax.driver.core.PoolingOptions
..
..
我有这样一个基于方面的日志记录: @Pointcut("@annotation(Loggable)") public void loggableAnnotation() {} @Around("loggableAnnotation()") public Object simpleProcess(ProceedingJoinPoint joinPoint) throws Throwable
..
我有一个关于使用AspectJ和Spring AOP方法拦截的问题。我创建了两个批注:@AJTest和@SAOPTest。 package com.test.company; import org.aspectj.lang.ProceedingJoinPoint; import org.aspectj.lang.annotation.Around; import org.aspectj.l
..
我现在需要的是拥有一个普通的抽象类及其子类。这些Bean需要注入到抽象类中。它们只是普通对象,但有一些由IoC管理的Bean来执行操作。我需要把它们序列化为红色。保存它,然后从redis中取出它以进行反序列化,但是当取出时,这些Bean就变成空的。我原本想手动逐一注射,但它们可能会出现嵌套问题。我不能那么做。不递归地配置Bean非常麻烦,所以我找了很多解决方案,我找到了@Configurable注
..
有没有办法在AspectJ中定义一个切入点来挑选由指定方法直接执行的每个方法? 例如,如果classA中有parentMethod(),则如下所示: public void parentMethod() { classB.methodX(); classC.methodY(); } 我想定义一个切入点,只要执行它调用的方法methodX()和methodY(),就只
..
我是AOP和AspectJ的新手。我正尝试围绕元素类型为TYPE的自定义注释编写一个自定义逻辑。我还想在我的注释下使用这些参数来在环绕方法中编写一个定制逻辑。我收到了下面提到的错误。我试着阅读了多个来源,大多数来源都与使用@annotation有关。我发现很难理解这一点。谁能解释一下,为什么以下@within的方法不适用于一些明显的例子? Annotation(Slf4jTrace.java
..
我无法找到向Pivotal Cloud Foundry中的所有应用程序实例发送/广播消息的方法。我们如何将某些事件通知给所有应用程序实例?如果我们使用HTTP请求,PCF路由器会将其分派给应用程序的单个实例。我们如何解决这个问题? http @florian所说的可能是更安全的选择,但如果您想要快速简单的东西,您可以使用X-CF-APP-INSTANCE头直接向应用程序实例发送推荐答案
..
我尝试将一个应用程序从Spring-boot1迁移到Spring-boot2,但我在Spring-boot2部分遇到了很多困难: 我有这个日志: 上下文初始化期间遇到异常-取消刷新尝试:org.springframework.beans.factory.BeanCreationException:错误创建名为‘org.springframework.boot.autoconfigure
..
我需要使用Spring数据JPA将两列实体类映射为postgres中的json。在阅读了多个堆栈溢出帖子和Baeldung帖子后, How to map a map JSON column to Java Object with JPA https://www.baeldung.com/hibernate-persist-json-object 我进行了如下配置。但是,我面临错误
..
我有一个问题,我让一个阿帕奇Kafka消费者在Spring Boot中消费了3个不同的主题。但我需要先使用第一个主题中的所有数据,然后再使用以下主题中的数据,有什么方法可以做到这一点吗?或者你会一直以同样的方式阅读它们吗? @Component public class KafkaTestListener { @KafkaListener(topics = "${message.topic
..
我有一个REST终结点,可以由多个用户同时调用。该REST终结点调用事务性Kafka生成器。 我的理解是,如果我们使用Transaction,我不能同时使用同一个Kafka Producer实例。 如何高效地为每个HTTP请求创建新的Kafka Producer实例? //Kafka Transaction enabled producerProps.put(ProducerConfi
..
我正在使用Springboot2.3.5.RELEASE和SpringKafka 2.6.3。我正在尝试做一个简单的卡夫卡生产者重试POC,这应该会导致生产者重试时,经纪人关闭或如果有一个异常抛出之前,消息被发送到经纪人。 以下生产者配置用于启用重试的幂等生产者。 // Producer configuration @Bean public Map prod
..
所以我正在将一个微服务从Spring框架迁移到Spring Boot 2.3.10.RELEASE。但当我尝试创建集成测试并启动它时,出现了一个隐晦的错误: Caused by: org.springframework.beans.BeanInstantiationException: Failed to instantiate [org.springframework.kafka.core
..
我正在使用Spring-Kafka和Boot进行一个项目,我想在应用程序中获取spring.kafka.Consumer er.Client-ID属性的主机名,以便在服务器端日志中区分我的每个消费者,如果出现问题。 我有办法做到这一点吗?我查看了Spring Boot参考指南和java.lang.System类,但没有找到有用的指针。 推荐答案 有一种方法--将Environme
..
我使用的是Kafka中的压缩主题,在应用程序启动时将其加载到HashMap中。 然后,我监听消息的普通主题,并使用从压缩的主题构造的HashMap来处理它们。 在开始收听其他主题之前,如何确保压缩的主题已完全阅读且HashMap已完全初始化? (RestController相同) 推荐答案 实现SmartLifecycle,将地图加载到start()中。请确保phase早于任何其他需
..
我正在使用spring-Kafka-2.1.5和spring-boot-2.0.5处理微服务 第一个服务将向Kafka生成一些消息,第二个服务将消费这些消息,而消费时我遇到了问题 Caused by: java.lang.IllegalArgumentException: The class 'com.service1.model.TopicMessage' is not in the
..
有没有可能将声明性TX管理(通过@Transaction)与@KafkaListener注释方法一起使用? 例如,我想使用它来为每个监听器定义单独的发送超时。 我的设置如下: TransactionManager: @Bean @ConditionalOnBean(value = {HibernateTransactionManager.class}) public ChainedKa
..
我有一个新的Spring Boot 2.6.3 Java 11应用程序,它具有Spring Kafka依赖项(使用start.spring.io生成)。 默认使用Kafka 3.0.0。我想将卡夫卡版本改为3.1.0并添加 3.1.0 到属性部分。大多数Kafka库现在在版本3.1.0中都已解决,但不是所有(最重要的是,
..