使用apache camel观察网络上的反应性流
apache camel eip框架有一个支持反应流的组件。
从我可以从留档说，reactive流组件仅在单个JVM中工作，将反应性流从/路由到camel。
在一个应用程序中有一个骆驼生产者，在另一个应用程序中有一个骆驼消费者，通过网络产生和消费反应性流，什么是合适的机制？
我假设需要某种中间件，哪种中间件适合这种情况？
共有1个答案
RSocket是个不错的选择http://rsocket.io/
它在网络上扩展了反应流模型。
Java实现https://github.com/rsocket/rsocket-java在内部使用项目Reactor，因此RX操作员可以自动工作，并获得背压等。
它得到了很好的支持，最近被Spring框架采用。
-
导览 本小节主要介绍 Apache ShardingSphere 可观察性的相关功能 应用性能监控集成
-
我使用SpringKafka实现了一个消费者，它可以读取某个主题的消息。所有这些消息都由它们处理，并通过RESTAPI导出到另一个系统中。为此，代码使用Spring Webflux项目中的WebClient，从而生成反应式代码： 现在我想知道这种设置是否合理，或者这是否会导致很多问题，因为来自spring kafka的KafkaListener逻辑本身并不是被动的。我想知道是否有必要用KafkaR
-
我发现了这个例子： 但是我不明白为什么我们需要和？和方法是用于什么？
-
问题内容： 回答“ 我如何知道数组内元素的值是否已更改”这一问题时受到启发 ，答案是使用 属性观察 器检查数组是否已被修改。 但是，如何确定属性查看器中集合类型中的已更新元素是什么？例如： 请注意，每次添加，更新或删除操作都已调用该代码，但是我如何才能确切知道受影响的元素是什么？有没有办法通过将数组除以 Property Observer 来实现这一目标？ 我问的是Swift中的所有集合类型，因为
-
问题内容： 这是我第一次使用axios，遇到错误。 使用正确的url和参数，当我检查网络请求时，确实可以从服务器中获得正确的答案，但是当我打开控制台时，我看到它没有调用回调，而是捕获了错误。 错误：网络错误堆栈跟踪：createError @ http：// localhost：3000 / static / js / bundle.js：2188：15 handleError @ http：//
-
我对Observables和RxJs是新手，我想对回报进行调整。如果第一个选择器返回某个值，我希望第二个选择器可以观察到。但是如果第一个选择器没有返回那个特定的值，我想返回false，而不是（false）。我已经走了这么远，但这返回了一个可观察的结果