spring-boot 相关问题

Spring Boot可以轻松创建Spring驱动的生产级应用程序和服务，并且可以轻松实现。它采用了Spring平台的观点，以便新用户和现有用户可以快速获得他们需要的位。

Hibernate 将字符串值转换为 Varbinary 并尝试以十六进制十进制插入

我有以下模型类 @ToString @实体 @Builder @EqualsAndHashCode @Table(名称 = "fare_rules") @盖特 @塞特 @AllArgsConstructor @NoArgs构造函数公开课票价规则

java postgresql spring-boot spring-data-jpa hibernate-6.x

回答 1 投票 0

Mockito 测试抛出异常

我对 Spring Boot 相当陌生。我试图测试这个服务类是否抛出 IllegalArgumentException.class 但不知何故没有抛出异常。帮助我得到我所缺少的东西。这我...

spring-boot mockito

回答 1 投票 0

无法为 MSAL entra Angular 集成添加自定义范围，添加时仍使用图形 API

我正在尝试将 MSAL 与 Angular 集成。我可以借助 Graph API 生成访问令牌。但是带有随机数的令牌声称无法在 Spring Boot API 中解析。因此，我决定使用

spring-boot azure microsoft-entra-id msal-angular

回答 1 投票 0

如何在springboot中优雅地重写控制器

我的springboot版本是2.7.0 在maven多模块项目中，我有两个名为A和B的模块，B依赖项A。在模块 A 中，有一个控制器，例如 @Api(tags = "分享 api") 公开

java spring-boot controller

回答 1 投票 0

如何在 Spring Boot 3 中忽略 webflux 中的尾部斜杠？

在 Spring Boot 3 中，它们已发生更改，默认情况下不再忽略尾部斜杠。例如，如果我有一个 GET 资源 /users，并且我导航到 /users/，那么 Spring Boot webflux 会...

java spring-boot spring-webflux

回答 2 投票 0

Spring boot 将 json 子集映射到 pojo

我有一个如下定义的json： { “数据”： [ { “类型”：“主机”， “属性”： { “元素1”：“值1”， ”

spring-boot json-api

回答 1 投票 0

微服务之间的相互调用关系如何设计才能简洁高效？

如何设计各个微服务之间的相互调用关系，才能简洁高效？有没有最佳实践？比如A调用B a的问题如何优化...

java spring-boot microservices spring-cloud

回答 1 投票 0

尝试运行Spring boot 3.2.4应用程序时获取org/springframework/cloud/autoconfigure/ConfigurationPropertiesRebinderAutoConfiguration.class

我正在开发 Spring Boot 3.2.4 应用程序，我已将密文放置在 application.properties 文件中并解密它，我在 pom.xml 文件中添加了下面提到的依赖项，但是当我运行时...

java spring spring-boot spring-mvc encryption

回答 1 投票 0

Spring Cloud Stream Kafka Binder - 在批处理模式下使用 DLQ 时重试不起作用

我使用的是Spring Cloud版本2023.0.1（Spring Cloud Stream版本4.1.1），我以批处理模式编写了一个简单的kafka消费者来模拟错误场景。 @豆消费者我使用的是Spring Cloud Version 2023.0.1（Spring Cloud Stream版本4.1.1），并且我以批处理模式编写了一个简单的kafka消费者来模拟错误场景。 @Bean Consumer<Message<List<String>>> consumer1() { return message -> { final List<String> payload = message.getPayload(); final MessageHeaders messageHeaders = message.getHeaders(); payload.forEach(System.out::println); payload.forEach(p -> { if(p.startsWith("a")) { throw new RuntimeException("Intentional Exception"); } }); System.out.println(messageHeaders); System.out.println("Done"); }; } 我的application.yml文件看起来像这样 spring: cloud: function: definition: consumer1; stream: bindings: consumer1-in-0: destination: topic1 group: consumer1-in-0-v0.1 consumer: batch-mode: true use-native-decoding: true max-attempts: 3 kafka: binder: brokers: - localhost:9092 default: consumer: configuration: max.poll.records: 1000 max.partition.fetch.bytes: 31457280 fetch.max.wait.ms: 200 bindings: consumer1-in-0: consumer: enableDlq: true dlqName: dlq-topic dlqProducerProperties: configuration: value.serializer: org.apache.kafka.common.serialization.StringSerializer key.serializer: org.apache.kafka.common.serialization.StringSerializer configuration: key.deserializer: org.apache.kafka.common.serialization.StringDeserializer value.deserializer: org.apache.kafka.common.serialization.StringDeserializer 我还指定了 ListenerContainerWithDlqAndRetryCustomizer 来自定义重试 @Bean ListenerContainerWithDlqAndRetryCustomizer cust(KafkaTemplate<?, ?> template) { return new ListenerContainerWithDlqAndRetryCustomizer() { @Override public void configure(AbstractMessageListenerContainer<?, ?> container, String destinationName, String group, @Nullable BiFunction<ConsumerRecord<?, ?>, Exception, TopicPartition> dlqDestinationResolver, @Nullable BackOff backOff) { ConsumerRecordRecoverer dlpr = new DeadLetterPublishingRecoverer(template, dlqDestinationResolver); container.setCommonErrorHandler(new DefaultErrorHandler(dlpr, backOff)); } @Override public boolean retryAndDlqInBinding(String destinationName, String group) { return false; } }; } 问题当发生错误时，消息批直接进入DLQ。并且不会尝试重试。但是问题是，可能会出现暂时性错误，导致批处理处理失败，我希望在将批处理发送到 DLQ 之前重试几次。但我无法让它工作。我做错了什么？万一将来有人偶然发现这个问题，我就知道出了什么问题。我必须从 enableDlq 文件中删除 dlqName、dlqProducerProperties 和 application.yml。然后就成功了。在java代码中，我还删除了ListenerContainerWithDlqAndRetryCustomizer并只使用了ListenerContainerCustomizer。代码看起来像这样： @Bean public ListenerContainerCustomizer<AbstractMessageListenerContainer<byte[], byte[]>> customizer(DefaultErrorHandler errorHandler) { return (container, dest, group) -> container.setCommonErrorHandler(errorHandler); } @Bean public DefaultErrorHandler errorHandler(DeadLetterPublishingRecoverer deadLetterPublishingRecoverer) { return new DefaultErrorHandler(deadLetterPublishingRecoverer, new FixedBackOff(0, 4)); } @Bean public DeadLetterPublishingRecoverer publisher(KafkaOperations<?, ?> stringTemplate, KafkaOperations<?, ?> bytesTemplate, KafkaOperations<?, ?> longTemplate) { Map<Class<?>, KafkaOperations<?, ?>> templates = new LinkedHashMap<>(); templates.put(String.class, stringTemplate); templates.put(byte[].class, bytesTemplate); templates.put(Long.class, longTemplate); return new DeadLetterPublishingRecoverer(templates); } @Bean public KafkaTemplate<String, String> stringTemplate(ProducerFactory<String, String> pf) { return new KafkaTemplate<>(pf, Map.of(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, StringSerializer.class, ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class)); } @Bean public KafkaTemplate<String, String> bytesTemplate(ProducerFactory<String, String> pf) { return new KafkaTemplate<>(pf); } @Bean public KafkaTemplate<String, Long> longTemplate(ProducerFactory<String, Long> pf) { return new KafkaTemplate<>(pf, Map.of(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, LongSerializer.class, ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class)); }

spring-boot apache-kafka spring-cloud-stream spring-cloud-stream-binder-kafka

回答 1 投票 0

（尽管至少存在一个 Creator）：没有字符串参数构造函数/工厂方法来从字符串值（'0.97982854'）反序列化

你好吗？我对控制台中出现的 Springbot Java 17 错误有一些疑问，但我无法解决。我正在向一项服务提出一个简单的请求，该请求会返回...

java spring-boot java-17

回答 1 投票 0

如何在应用程序中将 plan_cache_mode 设置为force_custom_plan？

我有一个带有 REST 服务的 Spring Boot 应用程序。我使用 PorstgreSQL 作为 TimescaleDB 的数据库。我正在尝试将 plan_cache_mode 设置为 force_custom_plan 因为我不希望它切换...

postgresql spring-boot hikaricp timescaledb

回答 2 投票 0

根据 Spring Boot 中另一个字段的值设置 POJO 字段值

我有一个简单的 POJO 类 POJO 类{ 私有布尔值已启用，私有字符串字段 } 我有一个接受 POJO 类型的 RequestBody 的控制器，作为更改的一部分，我想包含验证