spring-boot相关内容

如何在Spring中聚合数据mongo db嵌套对象并避免PropertyReferenceException?

我正在SpringBoot中创建一个新的端点,它将返回从Mongo数据库中的聚合查询生成的用户的简单统计信息。然而,我得到一个PropertyReferenceException。我已经阅读了有关它的多个堆栈溢出问题,但没有找到解决此问题的问题。 我们有这样的Mongo数据方案: { "_id" : ObjectId("5d795993288c3831c8dffe60"), "us ..
发布时间:2022-05-13 20:55:56 Java开发

我应该如何使用@Configable在SpringBoot中自动将Bean组装成通用对象

我现在需要的是拥有一个普通的抽象类及其子类。这些Bean需要注入到抽象类中。它们只是普通对象,但有一些由IoC管理的Bean来执行操作。我需要把它们序列化为红色。保存它,然后从redis中取出它以进行反序列化,但是当取出时,这些Bean就变成空的。我原本想手动逐一注射,但它们可能会出现嵌套问题。我不能那么做。不递归地配置Bean非常麻烦,所以我找了很多解决方案,我找到了@Configurable注 ..
发布时间:2022-05-09 09:15:12 其他开发

Spring-AOP:@在异常:java.lang.IlLegalArgumentException:引用的错误类型不是批注类型

我是AOP和AspectJ的新手。我正尝试围绕元素类型为TYPE的自定义注释编写一个自定义逻辑。我还想在我的注释下使用这些参数来在环绕方法中编写一个定制逻辑。我收到了下面提到的错误。我试着阅读了多个来源,大多数来源都与使用@annotation有关。我发现很难理解这一点。谁能解释一下,为什么以下@within的方法不适用于一些明显的例子? Annotation(Slf4jTrace.java ..
发布时间:2022-05-08 23:10:03 Java开发

如何将事件发送到PCF中应用程序的所有实例

我无法找到向Pivotal Cloud Foundry中的所有应用程序实例发送/广播消息的方法。我们如何将某些事件通知给所有应用程序实例?如果我们使用HTTP请求,PCF路由器会将其分派给应用程序的单个实例。我们如何解决这个问题? http @florian所说的可能是更安全的选择,但如果您想要快速简单的东西,您可以使用X-CF-APP-INSTANCE头直接向应用程序实例发送推荐答案 ..
发布时间:2022-05-07 11:36:42 Java开发

如何在春靴中按顺序消费卡夫卡话题

我有一个问题,我让一个阿帕奇Kafka消费者在Spring Boot中消费了3个不同的主题。但我需要先使用第一个主题中的所有数据,然后再使用以下主题中的数据,有什么方法可以做到这一点吗?或者你会一直以同样的方式阅读它们吗? @Component public class KafkaTestListener { @KafkaListener(topics = "${message.topic ..
发布时间:2022-05-06 19:10:38 其他开发

每个Http请求有多个Kafka生产者实例

我有一个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 ..
发布时间:2022-05-06 15:55:35 其他开发

Spring Boot-在应用程序.Properties中获取Spring的主机名-Kafka客户端ID

我正在使用Spring-Kafka和Boot进行一个项目,我想在应用程序中获取spring.kafka.Consumer er.Client-ID属性的主机名,以便在服务器端日志中区分我的每个消费者,如果出现问题。 我有办法做到这一点吗?我查看了Spring Boot参考指南和java.lang.System类,但没有找到有用的指针。 推荐答案 有一种方法--将Environme ..
发布时间:2022-05-06 15:39:19 其他开发

如何在启动上下文之前在内存中加载压缩的主题

我使用的是Kafka中的压缩主题,在应用程序启动时将其加载到HashMap中。 然后,我监听消息的普通主题,并使用从压缩的主题构造的HashMap来处理它们。 在开始收听其他主题之前,如何确保压缩的主题已完全阅读且HashMap已完全初始化? (RestController相同) 推荐答案 实现SmartLifecycle,将地图加载到start()中。请确保phase早于任何其他需 ..
发布时间:2022-05-06 14:54:20 其他开发