Spring网络流量-连续发射器
所以我有一个简单的方法
Flux<Task> getTaskToProcess();
我想让我的系统不断地流媒体。现在我用老办法做到了
while(!Thread.currentThread().isInterrupted()){
getTaskToProcess().flatMap(....)
}
我很确定这不是反应式方法的最佳方法。如何在项目Reactor中实现连续发射器？
共有1个答案
尝试通量#创建或通量#生成：
Flux<Task> tasks = Flux.create(sink -> {
while(!Thread.currentThread().isInterrupted()) {
sink.next(something);
}
sink.complete();
})
.subscribeOn(Schedulers.newSingle("stdin publisher"))
-
我目前正在使用自定义JWT身份验证进行SpringCloudGateway。身份验证后，我希望使用GlobalFilter将标头中的JWT令牌字符串传递到下游服务： JWT令牌字符串可以通过调用主体来获得。getName（）； 我的问题是：我如何实现
-
当客户端发出请求时，“MonoJust”会打印在第4行，但“test”会在Http响应正文中返回。我知道发布者在订阅之前不会生成数据，那么为什么Http响应包含“test”而不是“MonoJust”？
-
问题内容： 我可以在Java监视程序上创建网络流量吗？该程序必须控制从计算机程序（包括OS模块）到网络驱动程序再返回的所有网络流量。如果是，如何？ 注意： 我不仅要监视流量，还要对其进行控制。我想在Windows NT上实现这样的系统。仅靠Java无法实现它。如何在JNI的帮助下执行它？ 也许是另一个变体。我不熟悉Windows服务，但仍然如此。我将在C 上编写一个程序并将其注册为Windows服
-
问题内容： 我们正在将Selenium与Java API和一些Javascript用户扩展一起使用。我们在应用程序中使用了很多AJAX调用。我们的许多测试都是随机失败的，因为有时AJAX调用的完成速度比其他时间慢，因此页面未完全加载。我们通过等待特定元素或Thread.sleep来解决此问题。我试图找到一种方法来代替等待网络流量完成。这样我们就可以做到这一点： 这样，我们可以摆脱线程hiberna
-
问题内容： 我们正在将Selenium与Java API和一些Javascript用户扩展一起使用。我们在应用程序中使用了很多AJAX调用。我们的许多测试都是随机失败的，因为有时AJAX调用的完成速度比其他时间慢，因此页面未完全加载。我们通过等待特定元素或Thread.sleep来解决此问题。我试图找到一种方法来代替等待网络流量完成。这样我们就可以做到这一点： 这样，我们可以摆脱线程休眠，并在服务
-
我正在编写一个MMO塔防游戏（客户端服务器架构）。由于作弊保护，服务器需要有逻辑。但我有真正的设计问题。假设 10 个人互相进行死斗，每个塔射都需要计算并发送给玩家。当许多塔建成时。（如 10 名玩家 * 10 塔 = 100 塔） 流量非常高。（一个播放器每秒导致多条消息）如何解决这个问题？ 服务器是用Java编写的（Smartfox 2x）客户端是用C#编写的（Unity 3d） 先谢谢你。