问题标签 [mq]

我读了这篇文章

并且仍然不理解主题如何在 MQ 中工作的概念。在 JMS 中，我知道您可以在主题上发布消息，并且为了从该主题接收消息，您首先需要订阅它（在接收阶段使用订阅名称）。

它在 MQ 中是如何工作的？我想写一个简单的场景（如在 JMS 中）：

我尝试在生产环境中创建一个 WebSphere 队列管理器。在此之前，我设法在开发环境中毫无问题地创建队列管理器。

我正在使用这个脚本来创建队列管理器：

crtmqm -u SYSTEM.DEAD.LETTER.QUEUE test1.qm

但它没有响应（没有错误或成功消息）。当我尝试启动队列管理器（strmqm test1.qm）时，它给出

“AMQ8118：WebSphere MQ 队列管理器不存在。”

然后我注意到很多不应该发生的奇怪事情：

1. 我可以多次运行“crtmqm -u SYSTEM.DEAD.LETTER.QUEUE test1.qm”而没有任何错误

2. 我可以输入 crtmqm 并没有得到回应

3. 我可以输入 crtmqm -y （这是不可能的，因为没有 -y 参数）但仍然没有响应

谁能告诉我出了什么问题？

我正在尝试执行以下操作：

创建后台服务 当从 MQTT 代理在 inputQueue 上收到消息时显示弹出窗口

所以我订阅了 mqtt 代理，工作正常。当消息到达时 - 开始显示弹出窗口的意图，但是显示以下错误：

队列每 5 秒检查一次，如果有如下项目，则为弹出窗口发出启动活动

SMSPopup 类如下所示：

我在存储库上使用 Mercurial Queues，并将这些补丁放在补丁存储库中。另一位贡献者克隆了我的补丁队列并进行了自己的更改。我现在想将他们的更改合并到我的本地补丁存储库中。

我正在尝试找到一个很好的工作流程来执行此合并

• 在补丁存储库的历史记录中反映贡献者的变更集
• 在发生冲突时调用用户的合并工具

最初，我只是尝试直接合并补丁。这在非常简单的情况下是可以的，但当很多事情发生变化时就不能很好地工作，因为补丁取决于行号上下文，这似乎不是我应该担心调整自己的事情。总的来说，我发现检查补丁的 3 路差异太复杂了。

有没有更好的办法？

我一直在这个圈子里转了一圈。我正在尝试使用提供的通道表文件连接到分布式队列管理器。如果我在我的服务器上指定环境变量 MQCHLLIB 和 MQCHLTAB，我可以让它工作。但是 IBM 文档声明 .net 配置文件可以覆盖这些变量。

这是我放在 web.config 文件中的内容：

这是正在执行的代码：

queueManagerName 设置为通用队列管理器“*Q101T”。

但是，这不起作用，我收到一个错误返回：2058 MQRC_Q_MGR_NAME_ERROR

除了环境变量和标准 mqclient.ini 应该被 web.config 中的通道节覆盖，我无法找到更多关于如何使其工作的文档。

我在代码中遗漏了什么吗？任何提示将非常感谢。

编辑：我已将 connectionType 更改为 MQC.TRANSPORT_MQSERIES_MANAGED 并且我正在克服我遇到的错误。但是我现在收到一个 I/O 错误返回：

用户代码未处理 System.IO.IOException 消息="发生 I/O 错误。" Source="amqmdnet"
StackTrace：在 IBM.WMQ.MQChannelTable.CreateChannelEntryLists(MQChannelListEntry nameList)

我认为这很可能与https://www-304.ibm.com/support/docview.wss?uid=swg1IC69174有关，所以我现在正在等待中间件人员确认是否是这种情况，并希望为我提供使用新的 .TAB 文件...

Edit2 看起来这不是问题。我运行了一个 MQ 跟踪，但它出错了，因为它找不到 AMQCLCHL.TAB 文件。我不明白为什么它仍在寻找这个文件。它应该使用我的 web.config 中指定的通道表。任何人都知道为什么它没有拾取这些值？

我在带有 MDB 的 MQ 队列上的 JMS 绑定有这个奇怪的问题

消息驱动的 EJB:CrbEventMessageAsynchronousService无法连接到 JMS 目标: queue.contratto.crb.input.publicQueue。错误是：

javax.jms.JMSException::MQJMS1017非本地 MQ 队列对接收或浏览无效>

我检查QueueManager了 mq 队列被定义为本地而不是像异常所说的那样远程。

假设有一个移动应用程序需要对来自服务器的某些数据进行同步请求/查询。该请求将首先到达托管的 JMS 客户端，该客户端将在外部队列（来自合作伙伴）上发布消息/请求。现在这里开始不清楚了。如何以同步方式从合作伙伴那里获得响应。

• 合作伙伴是否应该公开单独的队列供我订阅，然后我阻止移动请求，直到我从该单独的队列中获得响应消息？
• JMS 或专有的 WebSphere MQ 接口是否支持同步消息？
• 通过消息传递实现它的其他方法是什么？

谢谢

我一直在关注Dale Lane 的博客，通过我的 Android 项目访问 Mosquitto，但我卡在了第一步。这是日志的相关部分：

Dale 代码的“connectToBroker()”方法抛出异常：

我在与客户端相同的机器上运行 Mosquitto 代理。我可以通过示例中提供的 IA92 客户端发布/订阅代理。我还可以通过具有相同服务参数的简单 java 项目进行连接。

非常感谢 ！

我应该在 Unix 中编写一个 C 应用程序，这样N子进程将从父进程分叉，我将向这些子进程发送消息，而子进程应该相互发送消息。

但是问题是，我需要将消息发送到特定的目标子进程。即父母将发送给孩子1，孩子1将发送给孩子2，......然后孩子n将发送给1（循环）。

问题是，如果我只创建一个消息队列，任何n孩子都可能使消息出队（因为它们中的任何一个都可能由于内核调度程序而在父进程之后运行），因此消息将在错误的进程中出队！

在我的应用程序中，将有最大值。队列中一次有 1 条消息。我想到的唯一解决方案是创建n不同的消息队列并将消息传递到适当的队列，以便特定的目标进程可以接收它。但我认为我必须有一个更合法的解决方案。

有任何想法吗？

约束：不允许进程之间的管道，我知道mq在这里效率低下。我也会实现它们，两者都是必需的。PS这是一个家庭作业（该死的我是http://canyoudomyhomework.com的创建者），但这不仅仅是一个家庭作业，一个具有挑战性的问题恕我直言。）

我可以通过简化版本的示例来最好地描述我正在寻找的内容。Tornado 的演示之一是一个简单的聊天服务器：

https://github.com/facebook/tornado/blob/master/demos/chat/chatdemo.py

我对MessageMixin这里的课很感兴趣。它保留静态长度的消息积压，当有新消息可用时，它返回消息列表的新片段。或者这就是它看起来要做的事情。我知道我之前在编写一个简单的彗星应用程序时已经实现了类似的东西。

那么有没有人对此进行了概括并添加了一些花哨的东西呢？我对管理许多通信渠道和删除一段时间未使用的渠道的方法特别感兴趣。持久性也可能有用。

这是 MQ 可以做到的吗？