Apache Camel EIP框架有一个支持响应式流的组件。
从文档中可以看出,响应式流组件只能在单个JVM中工作,路由反应式流到/从骆驼。
在一个应用程序中拥有骆驼生产者,在另一个应用程序中拥有骆驼消费者,并通过网络生成和消费反应式流的适当机制是什么?
我想需要一些中间件,在这种情况下哪种中间件最适合?
Apache Camel EIP框架有一个支持响应式流的组件。
从文档中可以看出,响应式流组件只能在单个JVM中工作,路由反应式流到/从骆驼。
在一个应用程序中拥有骆驼生产者,在另一个应用程序中拥有骆驼消费者,并通过网络生成和消费反应式流的适当机制是什么?
我想需要一些中间件,在这种情况下哪种中间件最适合?
RSocket是一个不错的选择http://rsocket.io/
它通过网络扩展了反应式流模型。
Java实现https://github.com/rsocket/rsocket-java在内部使用Project Reactor,因此RX操作符可以自动工作,并且您可以获得反压等功能。
它得到了良好的支持,并最近被Spring Framework采用。