问题标签 [webflux]

我知道 Flux 对象上有一个名为“hasElements”的函数。但它的行为有点奇怪！</p>

当flux对象不为空时，第二个return语句可以返回我需要的正确的东西，但是第一个return语句只返回一个空数组，类似于json中的“[]”。我不知道为什么会发生这种情况！我使用相同的数据进行测试。唯一的区别是我在第一种情况下调用了hasElements函数。但是我需要在flux对象为空时返回badRequest。hasElements 函数似乎使我的通量对象为空，尽管我知道它实际上并没有这样做。

我让一些项目使用 RSocket，我参考了那个帖子，我想知道实现代码在哪里将消息发送到其他客户端逻辑。

我的项目链接 我搜索文档，发布......但没有信息:((

我编写了一个示例 WebFlux 应用程序，它只从 redis 读取一些数据并执行小型 cpu 工作（md5 计算），重复几次。

它使用弹簧数据 redis 反应式

连接redis的代码是这样的。

redis 服务器在 localhost 运行

完整代码，你可以在这里找到

https://github.com/mouse500/redperf

这是一个简单的代码

为了测试，我用 Jmeter 调用 API (/wredis) 来进行负载测试

我认为的问题是...

此应用程序未达到最大 TPS，

它在我的本地 PC 上达到大约 40% 的 CPU。

即使它有更多的 CPU 空间，它也不会更努力地工作

为什么它没有充分利用资源？

如果有其他方法连接redis，

（我放了连接代理，用nodejs写的）

它显示出更高的 CPU 和更高的 TPS。

所以我认为这与 Redis 服务器性能无关。

“使用生菜从 WebFlux 应用程序调用 Redis”时出现问题

如何使此示例应用程序显示最大 TPS（CPU 达到 100%）？

我可以尝试什么选项？

所以我正在使用 webflux 并且我有一个过滤器来记录所有请求。记录经过身份验证的请求时，我尝试从 Mono 的请求对象中提取主体我尝试使用 .block 方法获取值，但出现错误“IllegalStateException”我尝试使用 .map 和 doOnNext 但这些不是叫。我如何获得主要价值

有没有办法捕获 500 错误并返回 auth/userservice 响应而不是抛出？

例如。“令牌无效”/“令牌过期” - 用户服务已经提供了正确的响应

在成功的身份验证中，它就像一个魅力。但是如果出现任何问题，我想从我的用户服务中获得响应。

我以前没有与 webclient 合作过……它让我发疯。

编辑：我也尝试在测试之前获得响应，但不成功。我使用了一个 Dto，它应该反映来自我的用户服务的错误响应。

我只是得到一个

预期的回应：（邮递员）

我正在尝试处理 Spring Web Flux。我能够得到@getmapping 来把我的json 参数还给我。在 cassandra 数据库中，我能够使用存储库中的该命令删除一行，但我无法从命令行中删除一行。你们会推荐什么？

我的测试类看起来像：

在我运行它之后，它与

原因：org.springframework.beans.factory.BeanCreationException：创建名称为 'skillGroupRepository' 的 bean 在 RoadmapApplication 上声明的 @EnableR2dbcRepository 中定义的 com.gmail.qwertygoog.roadmap.repository.SkillGroupRepository 时出错：无法解析对 bean 'r2dbcEntityTemplate' 的引用同时设置bean属性'entityOperations'；嵌套异常是 org.springframework.beans.factory.NoSuchBeanDefinitionException: No bean named 'r2dbcEntityTemplate' available

基本上它搜索不同的服务bean的依赖关系并在无法实例化它之后下降。我还尝试添加@SpringExtension，但输出没有任何差异。有什么建议么？

一直在研究 rsocket 和响应式编程，并且经常提到 spring webflux 我想问一下 rsocket 和 spring webflux 之间的区别是什么，或者它们是相同的东西。谢谢

我正在尝试使用 Oauth oidc 背后的外部 API。我正在使用 webclient 来实现 oidc 流。

进行授权调用并显示登录屏幕，成功授权后，使用重定向 uri 代码，它不会触发访问令牌流，而是会进行太多次授权调用。

我对使用 Oauth 的 webclient 很陌生。如果有人可以帮助我解决这个问题，那就太好了。在此先感谢您的帮助。

下面是我的 Springboot 配置和代码

依赖：spring-boot-starter-oauth2-client spring-boot-starter-webflux spring-boot-starter-security spring-boot-starter-web

当我点击 auth 端点时，进行了授权调用，向用户显示了外部提供商的登录屏幕，用户成功通过身份验证，并且在浏览器中看到了带有代码的重定向 uri..但它尝试调用授权调用再次看到太多带有代码的重定向uri，并且在尝试太多后失败。

我的要求是，当服务器上发生某些事件时，它应该将更新推送到客户端。想使用 RSocket 而不是 SSE。
rsocket-js 客户端上配置的响应器会响应服务器请求吗？
如果是，那么应该如何将 rsocket-js 响应器配置为接受特定路由上的消息？那部分请澄清。
不确定我的春季服务是否正确。

我的 Webflux Spring Boot RSocket 服务器代码-

我有一个控制器 -

客户端我正在使用来自 'rsocket-websocket-client' 的 RSocketWebSocketClient；

我的 reactjs 组件-

EchoResponder 取自https://github.com/rsocket/rsocket-js/blob/master/packages/rsocket-examples/src/LeaseClientExample.js。但是响应者没有收到任何消息。任何帮助表示赞赏。