问题标签 [broker]

我已经完全按照Bruce Snyder 的这篇文章建立了一个经纪人网络：

经纪人1：

经纪人 2：

我在代理的配置 XML 的代理标记中都有 AdvisorySupport="false" 并启动了这两个代理。

然后我使用以下命令启动消费者：

最后使用此命令启动生产者：

所有生成的消息然后在端口 61617 上运行的代理上进入挂起状态，而连接在端口 61616 上的消费者永远不会收到消息。

在没有启用咨询支持的情况下，代理网络是否会停止转发消息？我认为这在最近的版本中已修复。（我正在使用 activemq 5.4.2 版本）。

ActiveMQ 静态代理网络是否停止转发消息咨询支持是否已禁用？

更新： 我在使用 AdvisorySupport="false" 和 staticallyIncludedDestinations 时遇到了问题。

我们将 JMS 用于大部分请求-响应，如下所述：http: //activemq.apache.org/how-should-i-implement-request-response-with-jms.html

我们在生产者端使用了一个临时队列，以便能够接收消费者的响应，并且由于 staticallyIncludedDestinations 不能在其中包含这些临时队列名称，因此，当顾问支持被禁用时，所有生产者都无法接收来自客户端的响应。

我得出的结论是，对于我们的场景咨询支持不能关闭，除非有一些我不知道的其他配置技巧。

我的项目一直在尝试使用scrypt实现凭据检查器。我们已经尝试实现我们自己的凭证和检查器对象，但是我们在让 pb 使用它们时遇到了很多麻烦。

Pb 似乎被硬编码为通过网络使用 MD5 哈希，这在我们的实现中绝对行不通；我们没有办法在服务器端以明文形式获取正确的密码，因为我们使用的是 scrypt，所以我们需要一种方法来传输密码以明文形式进行验证。我们已经尝试将twisted.cred.credentials.UsernamePassword 与我们的凭证检查器一起使用，但它似乎并没有进入服务器。（我们仍然得到 _PortalAuthChallenge 代替）

http://twistedmatrix.com/trac/ticket/4398的票证似乎表明需要 PBServerFactory 子类才能支持 pb 中的自定义凭据检查器，但到目前为止，我完全无法弄清楚要覆盖什么为了使它使用不同的 ICredentials 实现。有没有关于如何让 pb 使用不同的凭证类的示例（甚至只是文档）？

我正在尝试和twisted一起玩。我已经尝试使用适当的工厂创建服务器和客户端。这是一个很棒的框架，但只能发送字符串:(我想发送一些列表或数组对象作为开始，也许以后会在客户端内部使用来自服务器的对象。但目前我遇到了一些简单的问题：

1) 在工厂模型中，我使用了诸如“clientConnectionFailed”或“clientConnectionLost”之类的方法，如何使用 PB 获得相同的方法？它们对于防止客户端/服务器问题非常有用。

2) 我还使用了“dataReceived”和“connectionLost”或“connectionMade”等方法，如何使用 PB 获得与这些方法相同的功能？

如您所见，我想首先使用 PB 模型而不是工厂重写我的代码。我看过这些例子，但与工厂的例子不同，我无法理解它们。

在此先感谢您的帮助=)

我正在创建一个嵌入式 activemq 实例，以便通过 JMX 测试创建/删除主题。代码看起来有点像下面。broker.connectorPort 是我尝试设置 JMX 端口，但它不起作用。

使用 activemq.xml 配置时，以下 xml 有效。我不确定如何将其翻译为 brokerURL。

我希望使用 IBM WebSphere Message Broker（可能是 V6）来使用一些 CSV 文件，执行一些验证，然后填充一些 Java 对象以供 Java 应用程序使用。我相信通过使用 FileInputNode 来消费 csv 文件和使用 JavaCompute 节点来处理与 java 相关的东西，大部分都可以实现。但是，我想知道如何将两者联系起来？我认为可能的一种方法是使用 csv 文件，然后创建将由 Java 节点使用的消息。

任何意见，将不胜感激。我对 Message Broker 的了解很少，所以请原谅我的无知。顺便说一句，使用 WebSphere Message Broker 的决定不是我的（公司标准），所以尽管可能有其他（更简单的）方法可以实现这一点，但我还是坚持使用 MQ Broker。

任何建议表示赞赏。

提前致谢。

巴兹

我们有一个中心辐射型网络拓扑，带有带有主题和持久订阅者的 activemq。

在（嵌入式）代理断开连接后，它不会收到在断开连接期间发送的消息，但它会发送本地待处理消息。

示例：代理 A（嵌入式）<---> 中央代理（独立）<---> 代理 B（嵌入式）

在代理 A 断开连接超过 30 秒（openwire 的最大不活动超时）后，它不会从中央代理获取断开连接时已发送的消息。但是，代理 A 发送其所有未决消息，因此代理 B 接收所有这些消息。

中央代理没有定义特定的网络连接器，因为事先不知道哪些代理必须连接。

尝试了几种恢复策略，但似乎都没有奏效。

有什么帮助吗？

请考虑以下场景：

• VNC 客户端尝试连接位于 NAT 后面的 VNC 服务器。

• 我在 java 中编写了一个端口转发器，可以帮助我完成上述任务，并且工作正常。

• 现在我需要以某种方式在此转发器中添加连接代理功能，以便我还可以拦截 VNC 客户端 - 服务器之间的通信，并在转发实用程序中验证 VNC 客户端。

您可能已经猜到，实际上我正在使用从 VNC 客户端收到的密码在我的应用程序中进行某些身份验证。由于 RFB Server 可以在应用层实现，我想这种拦截是可能的...... VNCAuthentication（DES 加密/解密）用于上述所有通信。在转发实用程序中成功验证后，我将让相应客户端继续转发，否则我可以关闭它（停止转发）。

我已经尝试了一些实现，也尝试过自定义 rfb 服务器的 java 实现......但仍然无法到达那里。这需要一些时间，我知道，但需要确认我是否正确思考。

请让我知道上述场景的实施是否模棱两可，不可能或非法，如果可能，请告诉我一些行会...

我们正在使用 AMQ 5.5。

自从我们从 5.3 升级到 5.5 以来，它一直运行良好。但是，今天早上，经纪人突然开始报告一堆不活跃的订阅者，即将它们放在“订阅”文件夹中的“假”文件夹下。并且“订阅”下的“耐用”和“非耐用”文件夹丢失了。经过进一步调查，我们发现标记为假（非活动）的订阅者实际上订阅了相应的订阅。话题和活跃。一些发布者也无法发布消息。

我们尝试查看 activemq.log 和 kahadb.log 文件，但找不到任何东西。最后，我们不得不重新启动代理以使其恢复正常状态。

你以前遇到过这样的情况吗？关于可能导致这种情况发生的任何想法？

先感谢您。哈里

我想将 SqlCacheDependency 与视图和过程一起使用。

我正在使用Linq to Sql。

我当前使用的代码仅在您使用单表时有效：

现在我想为视图（多个表）实现 sqlcachedependency。

我尝试使用此查询

但是这个查询不起作用，因为即使我更改了基础表，缓存也不会变得无效。

我用谷歌搜索了太久，但我找不到适用于视图和过程或多个表的代码。

我正在尝试创建一个由 2 个代理组成的 ActiveMQ 网络。我已经按照相关指南（http://activemq.apache.org/networks-of-brokers.html）中的描述完成了配置

在上面的 XML 配置中，我假设一个网络代理在 host1 中运行，另一个在 host2 中运行。在 host2 上运行的代理将具有相反的值。JMS 无法启动，并且不会在日志文件中产生任何异常，出现的唯一消息是

有没有人设法建立一个由两个或多个 ActiveMQ 代理组成的网络？