Spring Reactor一段时间未响应

问题描述

我观察到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 (将#修改为@)