问题标签 [jms-queue]

端到端架构定义如下：

JMS队列->Kakfa集群->spark流->Hbase表

对于整个架构的性能测试，我可以通过 Jmeter 到 JMS 队列之类的工具生成 xmls（将只给出将数据发送到 jms 的响应时间），它通过各种组件流向 Hbase。

我什至可以单独测试每个组件（jms、kafka、spark），（这将为特定块提供响应时间）我想在 jmeter 中准备脚本，该脚本应该将数据注入 JMS 队列并获取数据到达 hbase 的响应时间.（端端基准测试）

这有可能吗？还是我走错了方向？

有什么建议可以实现这一目标吗？建议将不胜感激。

嗨，我正在从 JBoss_6.1.0_final 迁移到 Wildfly 10。

在 JBoss for Queue 名称中，格式类似于

在 MDB 注释中是

现在在wildfly中如下所示。参考链接

带激活属性

在wildfly中，我尝试通过jms/从队列名称和注释中删除它，它在具有相同队列名称的wildfly中工作正常，例如

现在我的问题是，是否JMS/有目的地添加了队列名称。

编写不带前缀的队列名称是一个好习惯jms/

我有一个带有模拟响应测试步骤的 testCase，并且端点正在从 weblogic jms 队列 jms://WLS::-::queue_SouthboundOutboundQueue 中读取。

当来自 weblogic 的消息达到“10000000”字节时，此测试步骤将停止在测试用例运行中消耗该消息。

尝试从这样的 groovy 脚本中读取队列：

阅读大消息时 groovy 抛出的错误

weblogic.jms.common.JMSException：weblogic.messaging.dispatcher.DispatcherException：weblogic.rjvm.PeerGoneException：；嵌套异常是：weblogic.socket.MaxMessageSizeExceededException：传入消息的大小：“10000080”字节超过配置的最大值：“10000000”字节协议：“t3”行错误：22

PS：Weblogic 正在处理大消息，因为我在其中添加了 -Dweblogic.MaxMessageSize=2000000000。还尝试在 soapui 和 hermes sh 和 bat 启动文件上添加此参数，但没有任何效果。

我有一个 Wildfly 10 ear 应用程序（在服务器容器中运行），它需要能够发布到另一个 Wildfly 服务器上托管的远程队列。为此，我将这个 jar 从 wildfly\bin\client 文件夹复制到 ear 的 lib 文件夹中。那工作得很好。

但是现在，在官方打包之后，当我启动 Wildfly 和应用程序时，我收到一条错误消息……关于这个 jar 的清单文件。

设置应用程序以便这个 jar 被各种类加载器找到的最佳方法是什么？
似乎可以将 jar 复制到 ear\lib，但是需要对清单文件进行一些处理吗？什么？
我假设另一个选项是在standalone-full.xml 中指定一些内容，告诉wildfly 类加载器在其类路径中包含wildfly/bin/client 文件夹。你是怎么做到的？第三，我假设文件可以被复制粘贴到已经在 Wildfly 类路径中的文件夹中。
第四个选项，我假设是向我的耳朵添加一些东西，生成 pom.xml，它将这个 jar 添加到 ear/lib....

最好的方法是什么？

我得到的错误是：

在我的应用程序中，我注意到 HornetQ 2.4.1 一直在堆积消息日志文件（有时达到数千个）。我正在通过 JMS 队列使用 HornetQ，而我们正在使用 Wildfly 8.2。通常，当启动服务器实例时，HornetQ 将有 3 个消息日志和一个锁定文件。

消息日志文件的堆积导致重启服务器时出现问题，我们将看到一条日志，其中指出：

HQ221014: 54% loaded

删除文件时，服务器加载得很好。我已经尝试了一些，看起来好像这些文件中的消息已经被处理了，但我不确定为什么它们会随着时间的推移继续堆积。

编辑 1：我发现这个链接表明我们没有确认消息。但是，当我们像这样创建会话时connection.createSession(false,Session.AUTO_ACKNOWLEDGE);。

我会继续寻找解决方案。

我正在尝试将当前的 RabbitMQ 实现移植到 ActiveMQ（出于我无法控制的几个原因）。我正在尝试设计与我们当前的 RabbitMQ 设计相同的数据流。

在我们当前的设计中，我们在 RabbitMQ 中创建一个主题，然后消费者（玩家）创建他们的队列并使用键绑定（使用格式player-[id]-[up/down]）绑定到主题。因此，您最终会得到一个名为 Topic 的主题GamePoints和数千个队列（每个玩家一个）绑定到该主题，其键等于玩家 ID。我们现在可以GamePoints使用 key 为主题生成一条消息，player-1234-up具有该 ID 的玩家将收到该消息。这很好用。这也允许我们创建键绑定，player-1234-*并接收所有发往该玩家的消息。

我是 ActiveMQ 的新手，并试图模仿这种行为。到目前为止，我想出了以下内容：

• 我们创建一个名为GamePoints
• 每个播放器在连接时都会创建一个订阅者，该订阅者带有一个 JMS 选择器playerId=1234
• 当游戏产生消息时，它会将消息发送到GamePoints标题PlayerId值为1234
• 带有 JMS Selector 的订阅者（只要当时处于活动状态）将收到此消息，其他订阅者将不会收到此消息
• 我们还可以使用选择器创建订阅者，例如playerId like '1234-%'

这是一个好的模式吗？我担心这不会扩展，因为在我有数十万订阅者的情况下，它必须为每条消息运行数十万的 JMS 选择器

谢谢您的帮助！

早上好，我目前正在管理队列 jms [wso2] 消息代理。我有一个在队列中发送消息的 java 客户端和一个在每次传递消息时激活的 java ServletContextListener。一切正常。我的老板现在问我是否有可能一旦消息到达队列，它会自动调用服务。我正在阅读类似 [wso2] ESB 消息处理器的内容。我的问题是：

1) 不使用 [wso2] ESB 是否可以做这样的事情？但只有 [wso2] 消息代理。如果你有一些想法。

2）此时 [wso2] ESB 将成为消费者并来自他们的调用？

3）如果有人可以给我一个示例，说明一旦消息 ne [wso2] Message Broker 到达后如何处理 ESB。

提前致谢

抱歉，这对 JMS 专家来说可能听起来很幼稚，但仍然如此。

我有一个要求，即基于 Spring 的应用程序无法同步连接到 SAP 后端（通过其 Web 服务接口），因为 SAP 的响应太慢了。我们正在考虑一个解决方案，其中来自 GUI 的更新将由 Spring 中间件保存在本地数据库中，同时向 JMS 队列发送消息。我们希望每隔几个小时（或每晚）运行一次批处理作业以使用来自 JMS 队列的消息，并根据消息内容查询本地数据库并将结果发送到 SAP web-服务。

这种方法正确吗？我是否需要一个批处理来触发 JMS 消息消费（因为我不想立即消费消息，而是以延迟的方式在预先确定的时间消费）？Spring 有什么方法可以优雅地实现这一点（如 Camel）？感谢你的帮助。

我在 JBoss EAP 6 上，我的任务是将服务器迁移到云端。

我让 JBoss 启动，但随后一些队列失败：

您可以看到通过命令行界面 (CLI) 配置了服务器：

configure.cli 脚本的违规部分是：

我不明白的是：

我们正在从 JBoss EAP 6.4 迁移到 JBoss EAP 6.4，旧的/以前的服务器运行正常。

我从来没有接触过任何类似 JMS 的东西......

问题：

这是什么queue-address="jms.queue.BusinessEventQueue"？这是某种名称吗？

你怎么可能解决这个问题？-> 用名称参数替换？

谢谢

PS：情况有点复杂，因为我不能只更改本地文件。这些文件是从 SVN 存储库中提取的，因此任何尝试都涉及提交......等等。

我在 Eclipse 中使用 Java 代码，它应该从 Jboss EAP 6.4 上的 JMS 队列中连续读取 JMS 消息。但是，当我运行这个程序时，我遇到了异常。我试图做一些故障排除，但我现在卡住了

我使用的代码如下（Jboss的实际IP替换为#.“remote://#.#.#.#:4447”）

我得到了例外：