问题标签 [mq]

为了简单起见，假设我有一个类似聊天的系统——它是一对一的通信（可以在 1 个发送者和 1 个接收者之间）。发送者和接收者。我想使用 MQ 风格（可能是 beanstalk）将消息从一个用户发送到另一个用户。消息非常少，但考虑到 twitter 的用户数量，其中有很多，并且可能经常产生消息。我在 C# 中使用它。

要创建多少个通道/队列？

我的第一个想法是每次通信使用 1 个频道（b/w 2 个用户），但这意味着数百万个频道打开和关闭许多频道。也许有一种方法可以重新使用空闲通道而不是关闭它们。那会是更好的做法吗？

有没有更好的方法来进行这种沟通？

谢谢 ：）

编辑：

由于我没有收到任何回复，我决定在这里发布我未经测试的设计，也许我们可以将其用作首发：

每个接收器客户端都有一个唯一的 ID，因此他们每个人都可以使用他们的 ID 名称打开一个试管。发送者，只要有东西要发送给客户端，它就会打开一个以目标 ID 作为管道名称的管道/队列。发送消息。然后丢弃管。

虽然理论上这似乎可行，但整个关闭和重新打开都很麻烦。

我正在尝试将消息从我的 Java 代码（在我的本地机器中）放入队列中。我收到错误消息：

java.lang.UnsatisfiedLinkError：java.library.path 中没有 mqjbnd05。

这是我的代码：

我的队列管理器是QM_FORD，队列名称是 Q1。侦听器端口为 1414。环境变量设置正确。有人可以指导我吗？

我在 JBoss JMS MQ - jbossmq-destinations-service.xml 中只声明了一个名为 MyQueue1 的队列，但是当我通过 JBoss JMX 控制台查看队列列表时。我看到那里有5个队列。

其他队列是如何创建的？有人告诉我，当我们尝试写入不存在的队列时，队列会自动创建 - 这可能吗？不过，我无法在我的桌面上复制这种行为。

我正在使用 JBoss 4.0.x 请指教...谢谢。

我一直在运行 hello world RabbitMQ 示例，代码如下：

和：

当我运行接收器时，它会监听队列，发送者说它正在发送消息，但似乎没有关闭。然后我运行：

队列肯定正在创建中。

但是，当我运行时：

我得到以下输出

所以由于某种原因rabbitmq服务器阻止了我的连接？有谁知道我需要做什么？谢谢，本

IBM MQ JMS 侦听器环境。MQ 是基于优先级的队列而不是 FIFO。

场景：我收到所有相同优先级的消息。可以说，早上 6.50 和 9.30 收到的消息一直排在队列中，直到晚上。白天收到的许多消息正在得到处理。我认为这是消息光标的问题。当光标在早上 6.50 移动到 NEXT 位置时，同时收到一条消息，直到光标到达队列末尾并返回第一个位置，才会处理此消息。这个说法对吗？

下一个问题，当应用程序重新启动时，是否会将消息光标重置到第一个位置？

此外，当侦听器端口停止一段时间（假设是 10 分钟）并启动时，光标会移回第一个位置吗？

非常感谢任何指针/回复。

问候，阿比

I have a Java application that I want to send data to the Gnome (Activity) Journal. To keep code loosely coupled I'd like to use a MQ between my Java app and the Zeitgeist API (this allows to swap out the destination without changing my app).

So I'm looking for a way to add data to Zeitgeist from a message queue. Is there sample code somewhere?

全部，

我设法使用 IBM 的两个 DLL 从 C# 连接 MQ Websphere 版本 6：

上面的程序集与我的应用程序一起在本地部署。

但是，如果尝试在 GAC 中已安装 MQ Websphere 版本 7 的服务器中尝试，那么我有一个大问题。

基本上上述两个 DLL 都在 GAC 中，但它们与我在版本 7 中使用的非常不同。但是程序集版本是相同的。因此，我的应用程序失败，因为它选择了版本 7 程序集，因为它们具有相同的程序集版本和相同的公钥令牌。

一种解决方案显然是从 GAC 中删除版本 7 DLL。还有其他选择吗？

谢谢 MK

我发现 PERSISTENT 消息的性能比 NON_PERSISTENT 消息慢得多。我发送和接收了non_persistent消息，性能如下。

我发送和接收持久消息，性能如下。

此行为发生在 MQMessage 和 JMSMessage 中。

感谢所有帮助我解决问题的人。

特别感谢 Shashi、T.Rob 和 Pangea。

我有点不明白何时使用 MQ 客户端连接通道。据我了解，当客户端尝试连接MQ服务器时，可以通过server connection channel在应用程序代码中直接定义带有值的通道对象来完成。因此，如果是这样，那我们为什么需要使用这样的客户端连接通道呢？

请帮忙给我详细解释一下。非常感谢

根据 IBM MQ 的信息中心，我们可以备份队列管理器数据以备份和恢复 QMGR。步骤之一是获取 qmgr 数据和日志文件目录的副本。我的问题是数据和日志文件目录的特别含义是什么？我的以下理解正确吗？

另一种是 MQ 具有非持久性和持久性消息类型。至于非持久化，消息是否只存储在内存中？一旦发生什么崩溃，它就无法恢复。Rgt？但是，持久消息可以在该崩溃中幸存下来。但是持久消息通常存储在哪里呢？

请帮帮我。非常感谢