jjzjj

java - 如何暂时禁用消息监听器

暂时禁用消息监听器的好方法是什么?我要解决的问题是:消息监听器接收到JMS消息我在尝试处理消息时遇到错误。我等待我的系统再次准备就绪以便能够处理消息。在我的系统准备就绪之前,我不想再收到任何消息,所以......我想禁用消息监听器。我的系统已准备好再次处理。处理失败的消息,并确认JMS消息。再次启用消息监听器。现在,我正在使用SunAppServer。我通过在MessageConsumer中将其设置为null来禁用消息监听器,并使用setMessageListener(myOldMessageListener)再次启用它,但在此之后我没有收到任何消息。 最佳

java - 使用 Redis 实现 JMS/AMQP 消息传递模式

当我遇到一些提及(例如this)时出现了这个问题,关于使用诸如ZeroMQ之类的消息传递软件以及Redis,但我一直听说Redis本身使用消息传递系统.那么,如果Redis与其他消息系统一起使用,是否意味着Redis单独用作消息系统时存在一些严重的缺陷?虽然我很清楚使用Redis进行缓存和发布/订阅,但不清楚是否可以使用Redis代替成熟的消息传递系统,例如JMS、AMQP或零MQ。撇开标准合规性不谈,只关注功能/特性,Redis是否支持消息传递系统所需的所有消息传递模式/模型?我所说的消息传递模式是:RPC/请求-回复(一个example使用ActiveMQ/JMS和another使

java - 使用 Redis 实现 JMS/AMQP 消息传递模式

当我遇到一些提及(例如this)时出现了这个问题,关于使用诸如ZeroMQ之类的消息传递软件以及Redis,但我一直听说Redis本身使用消息传递系统.那么,如果Redis与其他消息系统一起使用,是否意味着Redis单独用作消息系统时存在一些严重的缺陷?虽然我很清楚使用Redis进行缓存和发布/订阅,但不清楚是否可以使用Redis代替成熟的消息传递系统,例如JMS、AMQP或零MQ。撇开标准合规性不谈,只关注功能/特性,Redis是否支持消息传递系统所需的所有消息传递模式/模型?我所说的消息传递模式是:RPC/请求-回复(一个example使用ActiveMQ/JMS和another使

node.js - 从 STOMP/AMQP 中选择哪一个?

我使用node.js作为jms主题的客户端。有两种协议(protocol)可用于在主题上建立连接。论文是Stomp和AMQP。我在http://en.wikipedia.org/wiki/Advanced_Message_Queuing_Protocol上阅读了有关它们的简要信息和http://en.wikipedia.org/wiki/Streaming_Text_Oriented_Messaging_Protocol.两者似乎都是线级协议(protocol),即作为八位字节流通过网络发送的数据。我没有找到任何应该首选哪一个的具体原因。如果有人可以阐明它,那将很有帮助。另一点是协议(

node.js - 从 STOMP/AMQP 中选择哪一个?

我使用node.js作为jms主题的客户端。有两种协议(protocol)可用于在主题上建立连接。论文是Stomp和AMQP。我在http://en.wikipedia.org/wiki/Advanced_Message_Queuing_Protocol上阅读了有关它们的简要信息和http://en.wikipedia.org/wiki/Streaming_Text_Oriented_Messaging_Protocol.两者似乎都是线级协议(protocol),即作为八位字节流通过网络发送的数据。我没有找到任何应该首选哪一个的具体原因。如果有人可以阐明它,那将很有帮助。另一点是协议(

java - 模拟或模拟消息队列 (JMS)

有一个消息(文本),我肯定知道它的格式和内容。目前,已经实现了Java中的类,它解析并从文件中读取此消息。在现实世界中,这条消息将来自消息队列。现在我应该在本地PC上模拟、模拟或生成消息队列以进行测试。Java规范(javajms):JMSprovider:AmessagingsystemthatimplementstheJMSspecification.JMSclients:Javaapplicationsthatsendandreceivemessages.Messages:ObjectsthatareusedtocommunicateinformationbetweenJMScl

java - 模拟或模拟消息队列 (JMS)

有一个消息(文本),我肯定知道它的格式和内容。目前,已经实现了Java中的类,它解析并从文件中读取此消息。在现实世界中,这条消息将来自消息队列。现在我应该在本地PC上模拟、模拟或生成消息队列以进行测试。Java规范(javajms):JMSprovider:AmessagingsystemthatimplementstheJMSspecification.JMSclients:Javaapplicationsthatsendandreceivemessages.Messages:ObjectsthatareusedtocommunicateinformationbetweenJMScl

java - 有什么好的基于Java的Master-Slave通信机制?

我正在创建一个Java应用程序,它需要JVM之间的主从通信,可能驻留在同一台物理机器上。在JavaEE应用程序服务器(即JBoss)内将运行一个“主”服务器,该服务器将有“从”客户端连接到它并动态注册自身以进行通信(即主服务器不会知道IP地址/端口)从属所以不能提前配置)。主服务器充当Controller,将工作分配给从服务器,从服务器将定期响应通知,因此会有双向通信。我最初考虑的是基于RPC的系统,其中每一端都是一个服务器,但它可能会变得复杂,所以我更喜欢一种机制,其中有一个开放的套接字并且它们来回通信。我正在寻找一种低延迟的通信机制,其中消息主要是原始类型,因此不需要严格的序列化。

java - 有什么好的基于Java的Master-Slave通信机制?

我正在创建一个Java应用程序,它需要JVM之间的主从通信,可能驻留在同一台物理机器上。在JavaEE应用程序服务器(即JBoss)内将运行一个“主”服务器,该服务器将有“从”客户端连接到它并动态注册自身以进行通信(即主服务器不会知道IP地址/端口)从属所以不能提前配置)。主服务器充当Controller,将工作分配给从服务器,从服务器将定期响应通知,因此会有双向通信。我最初考虑的是基于RPC的系统,其中每一端都是一个服务器,但它可能会变得复杂,所以我更喜欢一种机制,其中有一个开放的套接字并且它们来回通信。我正在寻找一种低延迟的通信机制,其中消息主要是原始类型,因此不需要严格的序列化。

java - 是否有任何 MQ 服务器可以嵌入在 Java 进程中运行?

我正在为我团队的一个应用研究排队解决方案。理想情况下,我们希望既可以配置为轻量级的进程内代理(用于线程之间的低吞吐量消息传递)也可以配置为外部代理。有没有可以做到这一点的MQ服务器?大多数似乎需要设置为外部实体。ZeroMQ似乎最接近进程内解决方案,但它似乎更像是“类固醇上的UDP套接字”,我们需要可靠的交付。 最佳答案 就像我们说的,ActiveMQ比ZeroMQ重一点,但它作为一个嵌入式进程运行得非常好。这里是一个简单的例子,带有Spring和ActiveMQ。将用于测试队列的消息监听器:publicclassTestMessa