Red Hat Summit 红帽全球峰会支持控制台（Console）开发人员开始试用联系人

272.5. 从 Camel 获取数据

要订阅来自 Camel 路由的数据流，交换应重定向到指定的流，如下代码片段： 

from("timer:clock")
.setBody().header(Exchange.TIMER_COUNTER)
.to("reactive-streams:numbers");
Copy to Clipboard Toggle word wrap

也可以使用 XML DSL 编写路由。

在示例中，未绑定的数字流与名称 编号 相关联。使用 CamelReactiveStreams 实用程序类可以访问该流。 

CamelReactiveStreamsService camel = CamelReactiveStreams.get(context);

// Getting a stream of exchanges
Publisher<Exchange> exchanges = camel.fromStream("numbers");

// Getting a stream of Integers (using Camel standard conversion system)
Publisher<Integer> numbers = camel.fromStream("numbers", Integer.class);
Copy to Clipboard Toggle word wrap

该流可轻松与任何 reactive stream 兼容库一起使用。以下是如何将它与 RxJava 2 搭配使用的示例（尽管任何被动框架可用于处理事件）。 

Flowable.fromPublisher(integers)
    .doOnNext(System.out::println)
    .subscribe();
Copy to Clipboard Toggle word wrap

示例将 Camel 生成的所有数字打印到 System.out 中。

272.5.1. 使用直接 API 从 Camel 获取数据
复制链接

对于短的 Camel 路由，而对于更喜欢使用被动框架的功能结构定义整个处理流的用户（无需使用 Camel DSL），也可以使用 Camel URI 定义流。 

CamelReactiveStreamsService camel = CamelReactiveStreams.get(context);

// Get a stream from all the files in a directory
Publisher<String> files = camel.from("file:folder", String.class);

// Use the stream in RxJava2
Flowable.fromPublisher(files)
    .doOnNext(System.out::println)
    .subscribe();
Copy to Clipboard Toggle word wrap
返回顶部
Red Hat logoGithubredditYoutubeTwitter

学习

尝试、购买和销售

社区

关于红帽文档

通过我们的产品和服务，以及可以信赖的内容，帮助红帽用户创新并实现他们的目标。 了解我们当前的更新.

让开源更具包容性

红帽致力于替换我们的代码、文档和 Web 属性中存在问题的语言。欲了解更多详情，请参阅红帽博客.

關於紅帽

我们提供强化的解决方案，使企业能够更轻松地跨平台和环境（从核心数据中心到网络边缘）工作。

Theme

© 2025 Red Hat