问题标签 [mq]

For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.

0 投票
1 回答
313 浏览

jms - 通过 JMS API 中的 QueuManager

在 MQ 中,如果您有一个现有队列管理器的实例,请说您的应用程序有权访问的 queuemanager1。您可以通过 queuemanager1 创建一个指向另一个队列管理器 queuemanager2 的队列的队列来发送消息。这样做是因为应用程序可能无法直接访问 queuemanager2,但托管 queumanager1 的 MQ 服务器可以。

代码看起来像这样:

MQQueue destQueue = queuemanager1.accessQueue("queFromAnotherMngr",CMQC.MQOO_OUTPUT | CMQC.MQOO_FAIL_IF_QUIESCING,"queuemanager2", null, null);

我正在重构代码以将 IBM MQ JCA 适配器用于 JBoss AS 6。所以我相信我必须坚持使用 vanilla JMS api(使用 InitialContext JNDI 查找、生产者等)才能让我的连接由 JBoss 管理。

但是,我不知道如何在常规 JMS 中允许接收 MQ 服务器将我的消息转发到另一个队列管理器 (queuemanager2) 的另一个队列。

从我到目前为止的研究来看,有一个对象发送到 MQ,称为消息队列消息描述符 (MQMD),它有一个名为“ReplyToQMgr”和“ReplyToQ”的字段。我想如果我找到一种方法来使用带有 JCA 适配器的 JMS API 更新这些字段,我就有了我的解决方案。有什么想法吗?想法?建议?解决方案?谢谢!

0 投票
2 回答
1236 浏览

messaging - Apache ActiveMQ 服务器到服务器连接

我们公司现在使用 Websphere MQ 来促进与我们的业务合作伙伴的沟通,但我们正在评估迁移到 ActiveMQ。我已经阅读了一些文档和文章,但没有找到我们需要的特定选项 - 服务器到服务器连接。

Apache MQ 有代理网络的概念,但据我了解,它更多的是集群,然后是站点到站点的通信。

我们需要一个本地消息代理(AMQ 服务器)和一个远程消息代理。本地由我们的应用程序使用,远程一个由我们合作伙伴的应用程序使用,我们需要将消息放入的远程队列(在合作伙伴的代理上)数量有限,而且我们这边也有一些队列,我们​​的合作伙伴必须放入消息给。有没有可能用 ApacheMQ 来实现这个工作负载?

如果我有点模糊,请随时提出问题。

0 投票
2 回答
1927 浏览

networking - 使用 ISO8583 消息的消息队列与 TCP

我想要一些关于在传输介质上传输 ISO8583 消息的意见。发送 ISO8583 消息时使用 TCP 与消息队列的优缺点是什么?对于不同的环境,哪种选择会更好?

0 投票
1 回答
3783 浏览

java - 如何在 WebSphere MQ 上跟踪对消息的回复?

我使用 Websphere MQ 作为代理应用程序流中的输入和输出。该流程中还包含 Websphere Transformation Extender Maps。

我想使用 java 在输入队列上发送具有唯一标识符的消息,并在输出队列上接收回复。我应该能够使用该唯一标识符从输出队列中选择消息。

我怎样才能做到这一点?

0 投票
2 回答
722 浏览

java - Glassfish & JMS:为什么发布的消息没有到达订阅者?

我有一个在远程机器(JDK 1.6.0_30)上运行的 Glassfish 3.1.2 服务器。以下代码是在 Java SE 环境中运行的独立客户端,使用 JNDI 查找连接到 JMS。客户端同时是发布者和订阅者。

我创建了 JMS 连接池和主题,如下所示:

我启动了这个客户端的两个实例。消息似乎已传递 - 没有错误 - 但消息没有到达订阅者......

我做错了什么?

任何帮助表示赞赏 - 非常感谢提前!

0 投票
1 回答
301 浏览

ibm-mq - 为什么使用 MQFTE 传输时子文件夹的内容?

嗨,当我尝试使用 MQFTE ftecreatetransfer 命令传输文件夹的内容(该文件夹有几个子文件夹和几个文件)时,不仅文件夹中的几个文件而且子文件夹的内容都被传输到目标。在目标中创建相同的子文件夹并传输内容。有没有办法避免子文件夹中的文件被传输?

0 投票
2 回答
2667 浏览

java - XML & MQ 最佳解决方案

我希望这里有人可以给我一些指导。我正在开发一个使用 IBM MQ 消息代理的项目。该项目将包括以下内容

从 MQ 接收数据
- MQ 将以 xml 格式向我们发送记录
- 我需要获取这些 xml 文件并将它们转换为对象

将数据发送到 MQ
- 我需要将对象转换为 xml 格式
- 我需要将这些 xml 记录发送到 MQ

我会查看一些输入的部分是 xml 部分。我已经对这些解析器进行了一些 JAXP、JAXB、JDOM、XOM 的研究,但作为一名 Web 开发人员,很难判断哪个更适合我的场景。

我希望有这方面经验的人可以提出最佳解决方案。

谢谢

0 投票
1 回答
1050 浏览

ruby - ruby - zeromq 检测到客户端超时,但客户端挂起

我正在尝试编写一个简单的 zmq 系统来替换 http 客户端/服务器。当服务器关闭/不可用时,我的客户端超时,但不会重试或停止。我错过了什么?

zmq_client.rb(修改版 Han Holl 的懒惰海盗客户端 from zeromq guide)

zmq_broker.rb(在 zeromq 指南中找到的 Oleg Sidorov 代码的修改版本)

0 投票
3 回答
2643 浏览

jms - 推荐一个开源消息队列服务

谁能为我推荐一个开源消息队列?像 JMS、gearmand、zeroMq、Amazon SQS。Tt最好满足以下几点(非强制性):

  1. 分布式和可扩展的。
  2. 支持异步消息。
  3. 最好支持发布/订阅
  4. 高可用,最好永不掉线。
  5. 高性能
  6. 最好支持php sdk,以及c/c++开发的mq server。
  7. 便于使用
  8. 该项目处于活动状态。

多谢!

0 投票
3 回答
6715 浏览

activemq - MQTT 与 MQ 设计注意事项

我这里没有具体的查询;只需要一些设计指南。

我在Node.js、MQTT 和 Websockets上看到了这篇文章。我想我们可以使用 Node/Java + ActiveMQ + Websockets 来实现类似的目的。我的问题是如何在 MQ 和 MQTT 之间进行选择?与 ActiveMQ 相比,我可以在中大型项目中安全地使用像mosquitto这样的“开放”服务器吗?

这篇文章有一些见解,看来我应该同时使用 MQ 和 MQTT,因为如果我将来获得轻量级客户端,MQTT 可能会有所帮助。

谢谢 !