27得票3回答
消息通道和消息队列本身有什么区别?

消息通道和消息队列本身有什么区别? 它们是不同的东西。队列实际上保存将以FIFO方式处理(推送到监听器)的消息。 通道是传输消息的媒介。 这到底意味着什么?在一本名为“企业集成模式”的书中,它说: 使用消息通道连接应用程序,在其中一个应用程序将信息写入通道,另一个应用程序从通道中读...

24得票3回答
有没有适用于低端设置的RabbitMQ良好替代品?

我已经在几个场景中使用RabbitMQ了,但总觉得应该有更容易设置的东西。尽管它很方便,但很难为只处理几千条消息的解决方案辩护,因为维护RabbitMQ需要大量工作。 有人知道一个安装和维护过程简单的AMQP实现吗? 对于那些不知道的人,RabbitMQ是用Erlang编写的AMQP实现。...

24得票2回答
有没有可以嵌入Java进程中运行的MQ服务器?

我正在研究我们团队应用的排队解决方案。理想情况下,我们希望找到一种既可以配置为轻量级的进程内代理(用于线程间低吞吐量消息),又可以配置为外部代理的解决方案。是否有MQ服务器可以实现这样的功能?大多数似乎需要设置为外部实体。ZeroMQ似乎最接近于进程内解决方案,但它更像是“增强版UDP套接字”...

22得票5回答
队列管理器和消息代理之间的区别

什么是WebSphere消息代理(Message Broker)和队列管理器(Queue Manager)之间的区别?我猜想,队列管理器将消息放入队列中,从队列中取出消息,将消息移动到备用队列等。那么代理的工作是什么? 它是坐落在发布者和队列管理器之间还是消费者和队列管理器之间?

15得票2回答
Akka演员中的消息传递顺序

我对Akka比较新,无法在参考手册中找到答案。 假设我们有远程Actor分布在由3台机器(A、B、C)组成的集群中,其中一台机器上有一个Actor,其他机器有ActorRef指向另外两台机器上的Actor,即:Machine A: A (real actor) -> B (ref) -...

11得票3回答
当使用RabbitMQ时,每个远程方法如何创建一个队列?

暂时假设使用消息队列(如RabbitMQ)实现RPC不是一个可怕的想法,有时候在与遗留系统交互时可能是必要的。 在使用RabbitMQ实现RPC的情况下,客户端将消息发送到代理,代理将消息路由到工作进程,工作进程通过代理将结果返回给客户端。但是,如果工作进程实现了多个远程方法,则需要以某种方...

10得票2回答
最高效的 - 在性能方面 - 用于JVM之间的通信

我有一个Java应用程序,需要在不同进程之间进行通信。这些进程可以在同一JVM或不同JVM上运行,但都在同一台机器上。 我的应用程序需要向另一个进程(同一JVM或不同JVM)提交“消息”,然后忘记它。类似于IBM的“MQ”这样的消息队列,但更简单,并且仅使用内存,而不是使用硬盘进行I/O以提...

9得票5回答
百万级主题的消息队列解决方案

我在思考一个系统,可以通知多个使用者关于一群对象所发生的事件。每个订阅者都应该能够订阅零个或多个对象所发生的事件,多个订阅者应该能够接收到关于单个对象发生的事件的信息。 我认为在这种情况下,某些消息队列系统是适当的,但我不确定如何处理我将拥有数百万个对象的事实 - 为每个对象使用单独的主题听...

8得票1回答
尝试使用PHP连接MQ,即将成功。

最近几天,我一直在尝试解决这个似乎被遗忘的问题,因为两个可用的PECL扩展(SAM和mqseries)都很长时间没有更新了。我已经尝试过这两个扩展,目前看来mqseries似乎可以让我走得更远,因为SAM拒绝连接,即使MQ命令行工具完美运行。我成功地创建了一个与我的队列管理器的连接,在下一步(...

8得票2回答
如何获取WebSphere MQ连接状态以及如何重置连接:

1.) 如何在.net客户端中测试客户端是否连接到服务器(即可以发送和接收数据)?是的,我可以在try块内发送消息并捕获随后的异常,但我希望有一个更优雅的解决方案。 2) 如何打开、关闭和重新打开连接?在尝试解决上述问题时,我发现如果我打开一个连接然后调用connection.Close()...