问题标签 [jms]

我一直致力于金融行业的解决方案。该应用程序的主要功能是能够加载大量输入文件、消化它们、更新持久存储中的状态以及根据请求从持久存储中生成提取。很简单。

输入文件是行业标准格式的 XML 大型（超过数百兆字节）消息，其中包含许多重复条目。持久存储是关系数据库。该引擎已实现为可部署在 J2EE 应用服务器上的基于 POJO（作为主干的 Spring 框架）Java 应用程序。

问题是关于解决方案的可扩展性和性能。如果应用程序按顺序处理来自 XML 的条目，则解决方案的可伸缩性相当差。没有办法让应用程序的多个实例参与单个文件的处理。这就是我为输入 XML 文件中的条目引入并行处理的原因。基本上，这个想法是为池中的工人分派处理单个条目。我决定使用 JMS 进行调度。加载文件的组件读取流并简单地提取单个条目并提供给调度队列。队列的另一端有许多并发消费者。每个人从队列中挑选一条消息并处理该条目，它可以立即用于处理其他条目。这与 Web 容器中的 servlet 非常相似。我发现这种方法特别强大的是，只要队列是共享的，工作人员就可以驻留在部署在远程服务器上的应用程序的不同实例中。不幸的是，所有工作人员都连接到维护持久性存储的同一个数据库，如果数据库服务器的功能不足以处理来自并发工作人员的负载，这可能是一个瓶颈。

您对这种架构有何看法？你有类似的应用程序设计吗？你当时的设计选择是什么？

是否可以创建消息侦听器池或消息驱动 Bean 以并行处理来自 JMS 队列或主题的消息？

我正在使用 JBoss 和 JBoss 的 JMS

我们有一个 Web 应用程序，它可以做各种事情，有时会根据给定的操作向用户发送电子邮件。我想将 http 请求线程与实际发送电子邮件分离，以防 SMTP 服务器或积压出现问题。过去，我为此使用过 JMS，并且对此没有任何问题。然而，目前我们正在做 JMS 的 web 应用程序现在感觉有点过头了（在设置等方面），我想知道还有什么其他的选择。理想情况下，我只是喜欢可以在进程中运行的东西（JVM/Tomcat），但是当卸载 servlet 上下文时，队列中的任何待处理项目都将被交换到磁盘/数据库。我当然可以一起编写涉及内存 Q 的代码，但我希望获得开源项目的好处，所以想知道那里有什么。

如果 JMS 真的是任何人都知道的可以满足我们简单要求的答案的话。谢谢

我正在考虑一种架构，其中我的客户端间歇性地连接到网络。当网络不可用时，我想将在这些客户端上创建的消息存储在 JMS 队列中，并在客户端在网络上时将这些消息转发到中央消息代理。（用户可以控制网络，例如拨入，所以它不是像手机那样的断断续续的连接。）

是否有任何提供此功能的 JMS 实现？

嗨，我有以下代码：

page1.jsp 点击按钮时调用的ajax函数

page2.jsp

如果我在不使用 ajax 的情况下调用 page2.jsp，即从 page1.jsp 使用

消息由订阅者选择并显示。

但不是通过制作ajax ..

我对ajax有基本的了解，所以请指导我缺少什么？

在 Jboss 4 中，当我为部署描述符中未指定的主题部署带有 MDB 的耳朵时，服务器将自动创建该主题（在发布一条警告说该主题不存在之后）。

在 Jboss 5 中，它似乎不再自动创建主题（而是出错）。是否有允许自动创建主题的配置选项？

有人使用过 ActiveMQ 中的消息分组功能吗？

http://activemq.apache.org/message-groups.html

对于我正在从事的项目来说，这将是一个非常有用的功能，但我很好奇这个功能的扩展性和性能如何。在我们的系统中，我们需要将消息分组为大约 3-5 条消息的组，因此我们将在进程运行时不断添加组。在这种情况下，似乎我们最终会在尝试存储所有组时耗尽内存。

我对任何经验/想法/优点/缺点感兴趣。

我最近发现了消息选择器

我的问题是：如何在运行时使选择器动态化？

假设消费者决定他们只想要具有“易碎是假”属性的消息

消费者能否在不重新部署 MDB 的情况下以某种方式更改选择器？

注意：我使用的是 Glassfish v2.1

如果是这样，消息会是什么样的？带有 SOAP 请求或响应的 XML 文档？

这有意义吗？

我有一个问题，我需要为 Windows 上的 Java 服务跨多个不同服务器同步处理多个线程。

在这个应用程序中，我有多个消费者线程从同一个 JMS 队列中提取消息。消息以 3 或 4 组的形式出现，我需要确保每个组中的消息完全按串行方式处理。我需要某种同步机制来确保线程 1 拉出一条消息，然后线程 2 从该组中拉下一条消息，线程 2 在开始处理它的消息之前等待线程 1 完成处理。

关于线程的分布式同步机制有什么建议吗？任何类型的解决方案都是好的（JMS 解决方案、分布式缓存等）

注意：我们使用的 JMS 提供者是 ActiveMQ。