问题描述
我观察到Reactor一段时间没有响应...
此呼叫之间有时可能需要长达30-40分钟的延迟:
reactor.notify("some.process.apicall",Event.wrap(new SomeObjectHolder()));
和带有注释的方法:
@Selector(value = "some.process.apicall",reactor = "@reactor")
可能是一些配置问题? (或者是否有一些建议使用配置了池大小的自定义执行程序,以防线程问题)
也许Reactor版本与我在项目中使用的Spring-core版本不兼容? (找不到有关版本兼容性的信息...)
<!-- REACTOR VERSION -->
<dependency>
<groupId>org.projectreactor.spring</groupId>
<artifactId>reactor-spring-context</artifactId>
<version>1.1.3.RELEASE</version>
</dependency>
<!-- SPRING-CORE VERSION -->
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-core</artifactId>
<version>5.0.16.RELEASE</version>
</dependency>
这是配置Reactor的方式:
@Configuration
@EnableReactor
@ComponentScan
public class ReactorConfiguration {
@Bean
public Reactor reactor(Environment environment) {
return Reactors.reactor()
.env(environment)
.dispatcher(Environment.THREAD_POOL)
.get();
}
}
解决方法
暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!
如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@)