使用Apache Camel进行负载平衡

Question

我可以从另一台机器或JVM访问SEDA或VM队列吗？< br >我实际上想借助Camel实现负载平衡，但不想为此引入另一个消息传递框架。我只是想使用一些内置队列将负载从一个生产者分发到不同的消费者。< br >可能吗？如果不是，那么我有什么选择？< br> 另一种方法:(拉动方法)不确定新方法的最佳程度或新方法的优缺点，请帮我分析一下这种方法。< br >消息将被放入主队列，所有工作系统都将监听主队列。假设有100，000条消息被放入主队列，5个工作系统正在监听它。工作系统将逐个处理来自主队列的消息。这种方法有两大好处:

< li >我不需要担心向生产者注册我的工人系统。第六个系统刚刚启动并开始监听主队列。 < li >我不需要担心向免费的用户系统发送消息。当工作系统处理完一条消息后，它会从主队列中拾取另一条消息。< br >请告诉我您对此的想法。

Answer 1

最简单的方法是使用 jms。如果您有 n 个路由侦听同一个 jms 队列，那么它们将自动进行负载平衡。如果一个消失，负载将在剩余的负载上平衡。我建议从 ActiveMQ 开始，因为它非常易于设置并且与 Camel.To 使代理高度可用很好地集成，您可以设置两个独立代理或为每个 Camel 实例设置一个嵌入式代理。

Answer 2

SEDA和VMendpoint分别对主机上下文和JVM有效。为了促进JVM-to-JVM消息传递，您需要使用在线协议组件，例如但不限于Mina、HTTP或JMS。

Answer 3

SEDA和 VM:// 只在同一个JVM上工作。

Java消息传递中的负载平衡通常使用JMS和竞争消费者模式实现。您将消息发送到队列，多个使用者竞相处理它们。

如果代理及其队列成为瓶颈——考虑使用扇出模式和代理网络。