问题标签 [messagebroker]

我正在使用 AMQ 5.5。我想禁用向 ActiveMQ.DLQ 目标发送死信的选项，并完全丢弃（自动）否则将发送到那里的消息。为此，我将代理配置如下：

但是，我仍然看到消息存储在 DLQ 中。你能告诉我这可能是什么原因吗？我需要修复配置中的任何内容吗？

谢谢

哈里

我正在使用 ZMQ 设计一个发布/订阅架构。我需要最大的可靠性和可扩展性，我有点迷失在所提供的各种可能性中。

目前，我有一组发布者和订阅者，由经纪人链接。代理是一个简单的转发设备，为发布者提供前端，为订阅者提供后端。

我需要处理代理崩溃或断开连接的情况，并提高整体可扩展性。

好的，所以我想添加多个代理，发布者将轮询代理发送消息，订阅者只需订阅所有这些代理。

然后我需要一种方法来检索可能的代理列表，所以我编写了一个名称服务，可以按需提供代理列表。发布者和订阅者询问该服务要连接到哪些代理。

我还写了一种“懒惰的海盗”（即一个接一个地尝试/重试）可靠的名称服务，以防主要名称服务失败。

我开始认为我设计错了，因为代码库的大小和复杂性不断增加。我迷失在 ZMQ 提供的可能性丛林中。

也许基于路由器/经销商的东西可以在这里使用？

任何建议都非常感谢！

是否有任何框架或平台以可靠、灵活和可扩展的方式提供消息交换？我有以下情况：

我有外部设备与我们的系统交换消息。这些设备实际上并不相同，并且多个设备具有自己的特定协议。我正在寻找的是一个中间层平台或框架（Message Broker 或 ESB），它可以作为一种高度灵活的集成解决方案来支持不同的协议，而无需对我们的整个系统进行任何更改。同时，我必须确保整个系统架构的可靠性和可扩展性。

设备将与之交换消息的系统是用 .Net 编写的。然而，我想知道使用该消息交换平台与 Java 或 PHP 系统交互的可能性。

我阅读了有关 Apache 家族的信息，即 ActiveMQ、Camel 和 ServiceMix 以及 Microsoft Biztalk。但我无法决定什么适用于上述情况，因为我从未使用过任何一种，也对此类技术有深入的了解。

我的公司正在考虑从 Solaris 迁移到 Linux，但有人提出了一些关于 WebSphere MQ 和 Message Broker 在 RHEL 上的表现如何的 FUD。也有人担心来自 IBM 的支持。有没有人有在这种环境中使用这些工具的经验？

谢谢。

当我在 Message Broker 中设置 MQMD.Expiry 和 MQM.Report (= MQRO_EXPIRATION_WITH_FULL_DATA) 时，如果消息过期，它们会去哪里？

我应该在 MQInput 节点中捕获它们吗？

如果是这样，我如何区分这些错误和其他错误？

Apache ActiveMQ 和 Apache ActiveMQ Apollo 有什么区别？

Apollo 文档说：“ActiveMQ Apollo 是一个更快、更可靠、更易于维护的消息传递代理，它建立在原始 ActiveMQ 的基础之上。它使用完全不同的线程和消息调度架构来实现这一点。”，但没有 java 示例代码和良好的用户指南。

有人在现场环境中使用 ApacheActiveMQApollo 吗？比原来的 ActiveMQ 性能更好？

我将收到 5 种不同格式的消息。所有消息都将具有相同格式的前 20 个字符。我必须使用字符 10 到 20 找出消息类型。然后应用适当的消息集。我不想让计算节点找出文本，而是想创建一个消息格式来解析 0 到 20 和 5 种其他消息格式来解析其余的？

我打算为学习/练习目的编写一个客户端/服务器纸牌游戏，并打算在客户端和服务器端都使用 Java。将来我会继续使用这个项目来学习，因此会想用 C 和 C++ 等其他语言编写更多的客户端。

我不确定的主要细节是我是否需要将 MOM 与消息代理一起使用，或者我是否可以不使用 MOM。

我最初的想法是我可以处理双方发送/接收消息的失败，如果尝试次数达到最大值，则会提示尝试重新发送消息导致游戏结束。

然而，我不只是拥有游戏客户端和游戏服务器，而是考虑拥有客户端、大厅服务器和游戏服务器。这样我需要消息代理将正确的消息路由到正确的服务器，但是我不确定除此之外是否需要消息代理，因为我不确定我是否真的需要任何设施消息持久性。

我倾向于使用消息代理的 MOM，但如果我不必要地这样做，我会欢迎更多的轻量级解决方案。也就是说，如果我做了什么是合适的跨语言 MOM 使用？我以前看过很多关于 SO 的建议，但我不确定什么最能满足我的需求。

QPID AMQP

我有一个问题正在重新调整网络流量。假设我在 Machine A 上有一个 Publisher 。Qpid 代理正在 Machine B 上运行。我们有两个订阅者机器 C 和机器 D（他们都订阅相同的主题）。现在想象一个拓扑，其中
A-->B-->X-->C | D（发布者A连接到B，订阅者C和D通过中间节点X连接到代理）由A发布的匹配C和D主题的消息将被两者接收。我想知道的是边 b->x 是否会携带消息两次（一次用于 b->x->c，第二次用于 b->x->c）。或者 AMQP/qpid 框架是否足够智能，可以从 B 向 X 发送一次消息，然后向每个单独的订阅者发送副本（因此 b->x 上的网络流量较少）。我的想法是，由于 X 一无所知，并且如果我们为每个订阅者都有私有订阅队列（或者即使共享队列和浏览/复制消息而不是消费），消息将通过 b->x 传输两次

这个问题并不特定于 QPID 。我想知道其他基于代理（RabbitMQ）和无代理消息传递框架（零 MQ，LBM/UMS）的解决方案。我在一篇文章中读到 Zero Mq 试图提供更智能的解决方案http://www.250bpm.com/pubsub#toc4，但这似乎很复杂，因为中间跃点如何知道何时发送多个副本（我不是网络专家，所以我可能会遗漏一些明显的东西，所以任何帮助都将不胜感激）

我一直在使用 qpid，现在我正试图转向减少代理的消息传递系统，但我对 Pub Sub 模式中的网络流量感到非常困惑。我阅读了以下文档： http ://www.250bpm.com/pubsub#toc4 并且真的很困惑订阅转发实际上是如何完成的？

我认为零 mq 必须与底层网络拓扑无关，但似乎并非如此。每个节点如何知道要转发什么和不转发什么（例如：在 eth 网络中，可能有数百万订阅者和发布者，消息树对我来说听起来并不可行。那些甚至不知道零 mq 的存在，他们如何将数据包转发给连接到他们的订阅者，对他们来说这只是一个普通数据包，所以即使是同一个数据包，他们也只会转发多个数据包副本？我不是网络专家所以可能是我遗漏了一些关于消息树的明显内容以及它是如何创建的吗？您能否举一些示例案例，如何创建此分发树以及创建 xpub 和 xsub 套接字的确切节点？

设备（链接中使用的术语）是否类似于代理，在整篇文章中，设备似乎只是任何一般的中间跃点，它对零 mq 套接字（只是一个随机网络跃点）一无所知，如果它确实是经纪人之类的东西，这是否意味着对于 pub sub，消息树中的所有节点都必须满足作为设备的定义，因此它不是一个无故障的设计？

同样在树形图中（来自包含 P、D、C 的链接），我最初假设 C 和 C 是两个订阅者，而 P 是唯一的发布者（D 只是随机跳），但现在似乎我们将 D 作为零 mq 。C 订阅 D 并且 D 订阅 P 吗？或两者都 C 只订阅 P （更通用的是，每个节点是否仅在 中订阅其父节点）。很抱歉这个新手问题，但似乎我在这里遗漏了一些明显的东西，如果有人能提供更多见解，那就太好了。