messaging - Apache Camel 生产者和消费者

Question

我很难理解这个概念。

我正在尝试实现一个端点，它在 tcp 端口上监听专有格式的传入消息，然后转换消息并让 Camel 接管转发和路由。

我是否正确理解生产者负责将消息发送到 Endpoint和 Consumer从那个端点接收它们？

在研究接口(interface)时，我无法弄清楚这些对象之间的消息流，尤其是在消费者部分。 Consumer仅定义 start()和 stop()方法...

在框架实现上设置测试时，Camel调用 createProducer()在端点和 process()在生产者对象上。之后它返回，没有对消费者或与之关联的处理器做任何事情。

有人能指出我正确的方向吗？

Answer 1

重要的是要记住 Endpoint , 由 Component 创建(即端点工厂)，可以坐在 Camel 的任一端Route .如果您将组件放在路由的开头，则必须有 Consumer 的实现。组件的一部分。这完成了将特定输入/请求(如 HTTP 请求)转换为通用的工作 - Camel Exchange - 可以沿着路线行驶。而如果你把组件放在路由的末尾，那么你必须有一个 Producer 的实现。 .生产者完成从路由末端获取交换并将其转换为特定内容(如 JMS 消息)的工作。

我发现 Fuse ESB 文档(通常)比 Apache Camel website 更好。 .来自 Fuse ESB Component page :

Consumer endpoints consume requests. They always appear at the start of a route and they encapsulate the code responsible for receiving incoming requests and dispatching outgoing replies.

Producer endpoints produce requests. They always appears at the end of a route and they encapsulate the code responsible for dispatching outgoing requests and receiving incoming replies.