使用Spring Reactive Data自动配置连接到AWS Keyspace
我正在尝试使用spring-boot-starter-data-cassandra-reactive连接到我的AWS密钥空间，但收到以下错误： Error creating bean with name 'cassandraSession' defined in class path resource [com/pams/framework/windsoncore/configuration
..
spring-webflux相关内容
Spring Functional Web框架给REST端点带来的压力
如果我理解正确的话，使用Akka Streams实现的HTTP终结点通过不读取用于与客户端通信的套接字来对HTTP客户端施加反压力。 使用Spring的功能Web框架实现的HTTP终结点也是如此吗？ 如果不是，我如何通知HTTP客户端放慢速度？ 推荐答案 是的，Spring5及其Web反应模块，implements the reactive streams spec和Rea
..
在反应式编程模型中注册自定义身份验证提供程序
我正在尝试注册我自己的AuthenticationProvider。 我的配置： @EnableWebFluxSecurity class SecurityConfig { @Bean fun customAuthenticationProvider(): CustomAuthenticationProvider { return CustomAuthenticati
..
Spring WebFlux WebClient-如何解决400个错误请求
我是反应式编程的新手，我正在使用Spring WebFlux的WebClient向下面的URL发出POST请求，作为我的Spring Boot应用程序的一部分，以便将现有的测验分配给考生。我无法理解我在构造WebClient请求时做错了什么。 终点 https://www.flexiquiz.com/api/v1/users/{user_id}/quizzes 在我的请求正文中，
..
为什么用WebFlux进行的Spring Boot测试忽略了定制的Jackson模块
我正在编写一个使用Spring Boot 2.0.1和WebFlux路由器函数的应用程序(不是基于注释！)。对于我的一些数据对象，我编写了扩展StdSerializer的定制序列化程序。我在SimpleModule中注册这些组件，并将该模块公开为一个Bean。 当我运行应用程序时，此设置非常出色。Bean被实例化，REST响应使用正确的序列化程序序列化。 现在我想编写一个测试，以验证路
..
将对OutputStream的写入转换为ServerResponse可用的流量(<；DataBuffer&>
我有一个旧库，我必须使用它来检索文件。此旧库不会像您通常期望的读取内容那样在InputStream中返回，但它希望传递给它一个开放的OutputStream，它可以写入。 我必须编写一个Webflow REST服务，将此OutputStream写入org.springframework.web.reactive.function.server.ServerResponse正文。 leg
..
如何在WebClient中使用SPUNG-SECURITY-OAuth2定制OAuth2令牌请求的授权头部？
我正在尝试通过WebClient调用升级到Spring Security 5.5.1。 我发现OAuth2客户端ID和密钥现在是AbstractWebClientReactiveOAuth2AccessTokenResponseClient中的URL编码，但我的令牌提供程序不支持这一点(例如，如果密钥包含+字符，则仅当它作为+而不是%2B发送时才起作用)。 我知道这被视为bug fix from
..
Spring WebFlux-bodyType=org.springframework.web.multipart.MultipartFile不支持应用程序/xml；内容类型
我正在使用spring-webflux，想要上传文件...仅使用spring-web即可正常工作，但当使用webflux时，我不知道出了什么问题。 注意区别……我正在使用： org.springframework.boot spring-boot-starte
..
访问令牌响应：tokenType不能为空
我正在升级我的服务并使用OAuth2实现Web客户端，但我收到异常是“tokenType不能为空”，您能帮我解决这个问题吗？ 例外： Org.springframework.security.oauth2.core.OAuth2AuthorizationException：[INVALID_TOKEN_RESPONSE]尝试检索OAuth 2.0访问令牌响应时出错：提取类型[类org.spr
..
将回调转换为被动发布者(Flux)
我正在使用第三方库注册MessageListener，当某些事件发生时，它们调用已注册的监听器onMessage方法 public interface MessageListener { // third party code, it auto-scans for all MessageListeners and registers them void onMessage(
..
Okhhtp3模拟服务器java.lang.NoClassDefFoundError：okhttp3/internal/concurrent/TaskRunner$RealBackend
维护依赖 com.squareup.okhttp3 mockwebserver 4.9.0 test
..
使用Spring-WebFlux忽略Web
在Spring中-MVC可以从WebSecurityConfigurerAdapter扩展，重写configure(WebSecurity web)，并进行如下思考： @Override public void configure(WebSecurity web) throws Exception { web.ignoring().antMatchers(AUTH_WHITE_LIS
..
Spring WebFlux添加WebFIlter以匹配特定路径
在Spring Boot应用程序的上下文中，我尝试添加一个WebFilter以仅筛选与特定路径匹配的请求。 到目前为止，我有一个过滤器： @Component public class AuthenticationFilter implements WebFilter { @Override public Mono filt
..
如何使用WebFlux WebClient创建带参数的请求？
在后端我有一个带有POST方法的REST控制器： @RequestMapping(value = "/save", method = RequestMethod.POST) public Integer save(@RequestParam String name) { //do save return 0; } 如何使用WebClient和请求参数创建请求？ WebC
..
如何提高WebFlux WebClient的吞吐量？
我想发送一些请求并高频率地接收响应。 我的代码如下： Flux.fromIterable(params) .delayElements(Duration.ofMillis(8)) .subscribe( param -> { webClient
..
如何在Spring Webflow中实例化webClient时设置一次访问令牌？
我尝试在Spring WebFlux中使用带有OAuth2的WebClient。我从URL访问令牌中获取一个令牌，并将其设置到Web客户端。但我不喜欢在其他安全端点的每次调用中获取此访问令牌。意味着我只想在Web客户端实例化期间和访问令牌过期时第一次获取它。 以下是我使用的代码： @Configuration public class OauthEmployeConfig{
..
当文件的内容(Flux；DataBuffer；)包装在另一个对象中时，无法使用WebClient上载文件
Spring Boot：2.5.6，kotlin：1.5.31，kotlinx-coroutines-active：1.5.2 我正在尝试下载一个pdf并立即上传到http://localhost:3000/upload，如下所示： Class Mediator(val dataBuffer: Flux, val url: String) runBlockin
..
如何使用RSocket处理从服务器发送到客户端的消息？
我尝试使用RSocketRequester从服务器向特定客户端发送消息，但我不知道如何在前端处理它。服务器是Spring Webflow，控制器如下： data class Message(val message: String) @Controller class RSocketController { private val log = LoggerFactory.getLo
..
春云合同显式与WEBTESTCLIENT测试模式
我想使用Spring Cloud Contact来生成我的合同并进行验证。我想使用Spring WebFlux和Junit5。这是我的控制器： @RestController @Slf4j public class HelloWorldPortRESTAdapter implements HelloWorldPort { @GetMapping(value = "/hello-wo
..
Spring WebFlux创建无阻塞线程池
我决定在Java上重写我的Web应用程序(以前它是在Python上)。 在我的应用程序中，我使用了无阻塞I/O，我有工作池(Celery+Eventlet线程)，我在那里传递由数百个API调用组成的任务。 现在我正在使用Spring WebFlux，但我无法理解如何创建一个工作人池来将我的任务传递到该工作人池，并在获得结果后进行一些计算。 (我知道创建ThreadPoolTaskExe
..