project-reactor

0热度

1回答

启动是运行弹簧反应堆的先决条件吗？我想在常规的Web应用程序环境中使用弹簧反应堆。我可以看到反应器配置已创建。消费者已注册。通知被调用。事件不会被解雇。什么和如何检查？配置 @Configuration @EnableReactor public class ReactorConfiguration { @Bean Environment env()

0热度

1回答

什么是反应堆中的听众主题？

我有一个简单的监听器模式实现它（压缩形式）看起来是这样的： public class EmailProducer implements Runnable { private List<Consumer<EmailMessage>> listeners = new ArrayList<>(); private IdleManager idleManager; publ

0热度

1回答

项目反应器 - 带故障保护的集成装载UUIDUtils当测试

我与故障安全运行反应堆EventBus的集成测试，当运行到一个NP我想空指针这是因为该类UUIDUtils正在被加载引导类加载器，因此调用getClassLoader（）返回null？ Caused by: java.lang.NullPointerException at reactor.core.support.UUIDUtils.<clinit>(UUIDUtils.java:39) IS

1热度

1回答

弹簧集成xml文件错误出在反应器上StringUtils

我有一个弹簧集成sftp流，我将其作为子上下文加载到我的整个应用程序上下文中。这是基于dynamic ftp SI example。我的整合流程与其中的反应堆或流没有任何关系。它是一个简单的流程，将一个direct channel连接到sftp-outbound-gateway以将文件传输到sftp服务器。我甚至可以运行单元测试和流程工作正常（能够传输文件），但是当我运行一个集成测试加载完整的父应

1热度

1回答

Project Reactor：等待广播公司完成

有一个广播公司，它接受字符串并将它们附加到StringBuilder。我想测试它。我不得不使用Thread#sleep等待，而广播公司完成字符串处理。我想删除sleep。我试过用Control#debug()失败。 public class BroadcasterUnitTest { @Test public void test() { //prepare Envir

0热度

1回答

反应器消费者的多线程

我正在使用reactor在整个应用程序中发布事件，并让不同的消费者响应他们的事件。这是我的反应器构造 @Configuration @EnableReactor public class ReactorConfiguration { static { Environment.initializeIfEmpty().assignErrorJournal();

0热度

1回答

反应器线程池调度程序

我经历了反应堆文档，但我不清楚在任何给定时间如何控制有多少事件正在调度。我想要做的是派遣一堆活动，足以让一些消费者忙碌起来，但是有一些方法知道我现在有足够的消费者在工作，所以我不应该派遣更多的活动。我在想，如果我将调度器设置为使用Threadpool，那么在某些时候它不会再分配任何线程，并可能抛出拒绝异常。这样我可以保持调度事件，直到我收到一个线程拒绝异常。有没有办法做到这一点，或者我是否以不应

0热度

1回答

增加线程数

如何增加线程数量，同时使用线程池我的代码如下， @SpringBootApplication @EnableReactor public class Application implements CommandLineRunner { @Autowired private Reactor reactor @Bean Reactor createRea

1热度

1回答

反应堆，无法加载类“org.slf4j.impl.StaticLoggerBinder”

我已经开始用反应堆玩，但我有我的第一个事件的烦恼：d 继在GitHub上的example，我试着写一个“你好世界”但没有成功... 问题是什么？代码： package reactor; import static reactor.event.selector.Selectors.$; import reactor.core.Environment; import reactor.core

7热度

1回答

多线程执行使用反应堆2.0

我想Reactor 2x集成到现有的Spring 4应用REST请求的执行，其中resources可以相互独立获取过程中提高性能，排序的映射简化我们将作业并行化为多个线程，然后将它们连接到一个缓冲区中。到目前为止，我们这个样本中的非簧环境中工作： //Ordered resources to apply transformations. List<Map<String, Object>