问题标签 [broker]

我的示例 JMS 布局在这里有一点问题。

我在两台机器上有两个代理（A，B），它们通过网络连接器链接。这个想法是生产者可以发送到任何代理，消费者可以收听任何代理，并且发送到/接收的主题是全局可用的。

该主题有两个持久的订阅者客户端（每台机器上一个），它们都将处理主题中的所有消息。我希望它是一个持久订阅，以便在必须重新启动进程时进程不会丢失任何工作负载。两个订阅者客户端都配置为具有故障转移代理 url，因此它们首先尝试连接到其 localhost 代理，如果对方不可用。客户端的故障转移似乎可以工作，但我在以下情况下发现了一个问题：

每个代理“A”和“B”都有一个连接的订阅者客户端生产者正在发送到“A”。代理“B”重新启动。“B”的客户端注册连接丢失并切换到“A”。'B' 再次出现，因为它自己已注册为 'A' 的持久订阅者，所以它获得了消息提要。它现在没有活动的持久订阅者（“A”现在有 3 个，包括“B”）并堆积起来，直到达到其连接限制。

我的配置错了吗？这可能是我的意图吗？

干杯，凯

目前我正在为 SQL 代理而苦苦挣扎。一切似乎都配置得很好，但是队列停止工作并填满了未发送的消息。代理和队列已启用。如果我删除队列和服务并重新创建它们，它会工作一段时间，但稍后会再次停止。我在 sql server 日志中没有看到任何重要错误。那么可能导致错误的原因是什么？

谢谢

队列

服务

C＃

我有一个简单的 'echo' PB 客户端和服务器，其中客户端向服务器发送一个对象，服务器将相同的对象回显给客户端：

客户端：

服务器：

aClass 是一个实现 Copyable 的简单类： from twisted.spread import pb

当我运行上面的代码时，我得到这个错误：twisted.spread.jelly.InsecureJelly: Module builtin not allowed (in type builtin .RemoteClass)。

事实上，对象被发送到服务器没有任何问题，因为它在服务器端使用 pb.setUnjellyableForClass(aClass, RemoteClass) 进行保护，但是一旦它返回到客户端，就会引发该错误。

我正在寻找一种方法来获得一种在两个对等方之间发送/接收我的对象的简单方法。

我想为确认设置超时期限，即如果代理在一段时间内没有收到来自消费者的特定消息的确认，那么代理应该将消息重新发送给消费者。是否可以在代理中设置这样的设置？？？

我们已经建立了一个带有两个集线器的集线器和辐条拓扑结构以实现冗余。连接到网络的所有节点都具有到两个集线器的静态网络连接。

如果我们为另一个轮辐产生的特定主题启动消费者，然后删​​除其中一个集线器，有时消费者将停止获取数据。如果关闭集线器 A 导致消费者停止接收数据，则恢复 A 将恢复消费者的提要。降低 B 对饲料没有影响。哪个集线器可能会影响消费者似乎不一致。

我们期望通过代理网络，只要生产者在网络上并且两者都连接到一个或多个集线器，消费者就应该始终获取数据。这个期望是正确的还是我们需要改变我们的拓扑？

每个节点都有一个如下所示的网络连接器：

我已经为真正的小型消息代理（RSMB MQTT）安装了 php SAM 库。我正在尝试连接 Android Push Demo，但出现以下错误

[root@user linux_ia64]# tail -f nohup.out
20120501 120111.226 CWNAN9997I 许可材料 - IBM 的
财产 20120501 120111.226 CWNAN9996I 版权所有 IBM Corp. 2007, 2010 保留所有权利
20120501 120120501 120120501 120111.226 美国政府用户受限使用、95I 复制或披露受限 CWNA与IBM Corp.
20120501 120111.226 CWNAN0053I版本1.2.0，20101年8月18日17：02:09
20120501 120111.226 CWNAN0054I功能包括：桥梁
2012010101011.226 CWNAN99993I作者：iCrian craggs：iCrraggs
： CNNAN0014I MQTT 协议正在启动，正在侦听端口 1883

20120501 120126.609 CNNAN0020W 套接字 4 上的套接字错误，对等地址 ipaddress:34861；结束连接

请任何人帮助解决上述问题。

我的应用程序处理 aTask是抽象基类的各种任务。

任务在持续的基础上被编程到系统中，任务的性质可能会有所不同。

一些任务示例：

• 使用互操作打开单词并插入一些文本。
• 使用 MS DAO 创建一个新的 Access 数据库。
• 使用互操作打开数据库。
• 将文件从 Folder1 复制到 Folder2。
• 打开 IE 并导航到 SomeUrl。

每个任务都有一个唯一的标识符并返回一个布尔结果。

我想开发某种代理架构，可用于将此类任务分派给编译时未知的类。

这里的问题是：什么样的架构最适合这种情况？我应该看一些特定的设计模式吗？

为什么java只能在activemq中提供对故障转移协议的支持而其他语言不能。我的疑问是，在故障转移协议中failover://(tcp://host1:61616,tcp://host2:61616)?randomize=false，客户端也使用内部 url 之一tcp://host1:61616，然后代理如何知道调用是否使用某些故障转移协议，然后代理如何决定它需要复制消息？

我们最近从 ActiveMQ 4.0 迁移到 ActiveMQ 5.6，并注意到代理的响应时间减慢了大约 50-60 秒。我们使用默认的 ActiveMQ 5.6 设置并且没有配置任何参数。客户端使用 Java Impl 存根，应用服务器是 Jboss 5.1.0。我们在 ActiveMQ 中打开了 TRACE 日志记录以检查速度变慢的原因，但无法找到任何重要的东西。队列看起来因为某种原因正在等待，我们可以在日志中看到很多重复的以下行：

我们可以从调度程序中看到上面的行，并怀疑它可能引入了等待，因此尝试使用标志 useScheduleSupport=false。我们还尝试了 persistent=false 标志，但它对时间没有影响。

这是我的 ActiveMQ.xml 文件：

请帮助了解导致响应额外延迟的根本原因。这个额外的响应时间导致我们未能达到我们的生产标准响应时间限制。此外，客户端等待数据超时，因为它们被配置为在达到时间限制后自动关闭连接。

我对activemq非常陌生。我试图使用 activemq 代理来订阅/发布消息。但至于缺乏经验，我不知道该怎么做，或者是否真的有可能做到。我用谷歌搜索了很多，但不幸的是没有适合这种功能的例子。所以我希望这里有人可以对此有所了解。这里的任何人都可以给我一些如何做到这一点的例子吗？或者可能是一些在线文档的链接。我已经尝试过 apache activemq 代理文档。但这没有帮助，或者可能是我没有那么多经验可以从中获得帮助。