首先，我只想让你知道我是 Camel 的新手，最近我掌握了它的主要概念。
我正在尝试使用 Apache-Camel 和 ActiveMQ 作为代理并使用 jms-component 作为使用故障转移构造的负载均衡器的客户端来创建一个基本的工作示例。所有这些都是仅使用 Java DSL 完成的（如果可能的话）。
该示例由 4 个主要应用程序组成，分别称为 MyApp-A、MyApp-B、MyApp-C 和 MyApp-D。在正常情况下，MyApp-A 从我的计算机中读取文件，然后将其转换为消息。然后它将该消息发送到 MyApp-B，MyApp-B 将其发送到 MyApp-C。
但是，有一个失败的场景。在这种情况下，MyApp-A 无法将消息发送到 MyApp-B。然后它将消息发送到 MyApp-D，MyApp-D 又将消息发送到 MyApp-C。
Bellow 是我的 MyApp-A 代码
public class MyApp-A {
public static void main(String args[]) throws Exception {
// create CamelContext
CamelContext context = new DefaultCamelContext();
// connect to embedded ActiveMQ JMS broker
ConnectionFactory connectionFactory =
new ActiveMQConnectionFactory("vm://localhost");
context.addComponent("jms",
JmsComponent.jmsComponentAutoAcknowledge(connectionFactory));
// add our route to the CamelContext
context.addRoutes(new RouteBuilder() {
@Override
public void configure() {
from("file:data/inbox?noop=true")loadbalancer().failover().to("MyApp-B:incomingOrders").to("MyApp-D:incomingOrders").end();
}
});
// start the route and let it do its work
context.start();
Thread.sleep(10000);
// stop the CamelContext
context.stop();
}
}
我考虑过使用camel-ftp，但它不起作用，因为MyApp-C 不知道MyApp-B 死了，也不知道它必须从MyApp-D 获取。
现在我有几个问题和疑问：
- 如何从 MyApp-A 向不同应用程序的 MyApp-B 发送消息（在本例中为文件）？我应该
.to(String)在 Java DSL 的方法中实际放入什么？ - 我如何实际编码 MyApp-B？如何让它接收来自 A 的消息（这是一个不同的应用程序，可能在不同的机器上）并将其发送到 MyApp-C（我假设如果我知道如何从 MyApp-A 发送到 MyApp-B，我会知道如何从 MyApp-B 发送到 MyApp-C）？
- MyApp-A 将如何检测 MyApp-B 失败？
- 我应该使用哪个骆驼组件？
如果您能就我的代码以及如何解决问题提供任何反馈，我将不胜感激。