微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

Spring Reactor一段时间未响应

如何解决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 举报,一经查实,本站将立刻删除。