我已经阅读了关于什么设计决策会更有利于Scala的Actor而不是JMS？的问题和答案。
通常，我们使用已经存在多年的消息传递解决方案：使用JMS实现，如WebSphere MQ或Apache ActiveMQ用于点对点通信，或使用Tibco Rendevous进行多播消息传递。
它们非常稳定、可靠，并提供高可用性和性能。然而，与Akka相比，配置和设置似乎要复杂得多。
在哪些用例中应该使用Akka，以及何时和为什么应该使用Akka，而之前成功使用的产品——WebSphere MQ或ActiveMQ呢？为什么我应该考虑在我的未来项目中使用Akka，而不是WebSphere MQ或Tibco RV？
那么，什么情况下应该避免使用Akka呢？它是否提供与其他解决方案相同的高可用性和性能？或者将Akka与其他消息中间件进行比较是一个坏主意吗？
也许在JVM环境中还有另一种消息传递解决方案，除了JMS（点对点）、TibcoRV（多播）和Akka，我应该考虑使用它吗？
Akka在与大量消费者一起使用时比大多数MQ更具扩展性。这是因为对于大多数MQ（JMS、AMQP）客户端，每个队列连接都需要一个线程...因此，许多队列==许多永久运行的线程。虽然这主要是客户端问题，但我认为ActiveMQ Apollo有一个非阻塞调度程序，据称可以解决AMQP的这个问题。RabbitMQ客户端具有允许您组合多个消费者的通道，但仍存在大量消费者可能导致死锁或连接中断的问题，因此通常会添加更多线程以避免此问题。
话虽如此，Akka的远程传输相当新，并且可能仍未提供传统消息队列提供的所有可靠消息保证和QoS（但这正在每天改变）。它通常也是点对点的，但我认为它支持服务器对等，这通常是大多数MQ系统所做的（即单点故障），但也有MQ系统是点对点的（RabbitMQ是服务器对等）。
最后，RabbitMQ和Akka实际上是很好的搭档。您可以使用Akka作为RabbitMQ的包装器，特别是因为RabbitMQ不会帮助您处理消息的消费和本地路由（在单个JVM中）。
何时选择Akka
示例系统：一个交互式实时聊天系统
何时选择MQ
示例系统：一个定时事务批处理系统
基于关注的评论进行编辑
我做了一个假设，即原帖作者关心分布式处理，Akka和消息队列都可以处理。也就是说，我假设他在谈论分布式Akka。 使用Akka进行本地并发与大多数消息队列的比较是不恰当的。我之所以这么说是因为你可以将消息队列模型作为本地并发模型应用（例如主题、队列、交换），Reactor库和simple-react都可以做到这一点。正如您所看到的，分布式编程和并发编程的主题相当广泛，而且每天都在变化，因此我的初衷不是混淆，而是专注于分布式消息处理的特定领域，这是我认为OP关心的问题。在并发方面，人们可能希望将搜索焦点放在“反应式”编程（RFP /流）上，这是一种与演员模型和消息队列模型类似的“新”模型，所有这些模型通常可以结合使用，因为它们都是基于事件的。
我不是消息系统的专家，但您可以将它们与Akka结合在应用程序中，获得最佳效果。以下是一个示例，您可能会发现对于尝试Akka和消息系统非常有用，本例中使用的是ZeroMQ:
并发在Akka中是免费的，所以你可以说它真正解决的是分布式问题。跨机器和核心的分布。Akka内置了用于在网络上发送消息的“位置透明性”。它具有集群和模式相关，可用于扩展单个服务。这使得它成为分布式的非常好的解决方案（例如微服务架构）。
以下是使用Java8的Akka-Camel与ActiveMQ结合使用的示例：
import akka.actor.Props;
import akka.camel.Camel;
import akka.camel.CamelExtension;
import akka.testkit.TestActorRef;
import akka.testkit.TestProbe;
import org.junit.Ignore;
import org.junit.Test;
import akka.camel.javaapi.UntypedProducerActor;
import akka.camel.javaapi.UntypedConsumerActor;
import static com.rogers.totes.TotesTestFixtures.*;
import org.apache.activemq.camel.component.*;
public class MessagingTest {
@Test @Ignore
public void itShouldStoreAMessage() throws Exception{
String amqUrl = "nio://localhost:61616";
Camel camel = (Camel) CamelExtension.apply(system);
camel.context().addComponent("activemq", ActiveMQComponent.activeMQComponent(amqUrl));
TestProbe probe = TestProbe.apply(system);
TestActorRef producer = TestActorRef.create(system, Props.create((Producer.class)));
TestActorRef consumer = TestActorRef.create(system, Props.create((Consumer.class)));
producer.tell("Produce", probe.ref());
Thread.sleep(1000);
}
}
class Producer extends UntypedProducerActor{
@Override
public String getEndpointUri() {
return "activemq:foo.bar";
}
}
class Consumer extends UntypedConsumerActor{
@Override
public String getEndpointUri() {
return "activemq:foo.bar";
}
@Override
public void onReceive(Object message) throws Exception {
System.out.println("GOT A MESSAGE!" + message);
}
}