问题标签 [broker]

我知道这里可能会有任何 uniPaaS 开发人员，但这里是：

今天我第一次去复制我们在 uniPaaS 1.5 中的系统。

在 uniPaaS 代理中，我添加了/ApplicationPublicName更改 APPNAME应用程序响应的标志。

但是，AppName()应用程序生成的输出仍然是应用程序的原始名称，而不是我指定的 ApplicationPublicName.

我们的系统严重依赖AppName(). 有什么办法可以AppName()返回与 相同的值/ApplicationPublicName？

大家好，我想知道如何开始在 python 中编写一个在 Etrade 中交易股票的界面。我正在尝试制作一个自动交易机器人，但没有公开的 API 可用于 Etrade 的自动交易。提前致谢。^^

我希望构建一个发布/订阅分布式消息传递框架，该框架可以通过代理级别的一些智能来管理大量消息流量。我不知道是否有描述这个的拓扑，但这是我要追求的模型：

示例模型 A

A）有两个正在运行的消息代理（如果可能，最好都在本地主机上，以便于演示）：

• 经纪人-A
• 经纪人-B

B) 每个经纪人将有 2 个听众和 1 个发布者。

示例图

[订阅者 A1，订阅者 A2，发布者 A1] <--> BrokerA <--> BrokerB <--> [发布者 B1，订阅者 B1，订阅者 B2]

• 如果消息-X 发布到代理 A 并且在代理 B 上的侦听器中没有订阅者（通过消息选择器或代理路由规则中的标准），则该消息 X 将永远不会发布到代理 B。

• 否则，代理 A 会将消息发布到代理 B，其中代理 B 的侦听器/订阅者/服务之一根据订阅标准期待该消息。

聚类是正确的方法吗？

起初，我得出的结论是，我需要“代理集群”概念来支持这一点。但是，据我了解，集群的典型使用需要：

• 跨所有代理的消息冗余...或
• 竞争消费者模式

...并且这些都不满足示例模型 A 中的要求。

什么是正确的方法？

我的问题是，有人知道支持我描述的模型的 JMS 实现吗？

我浏览了所有的 stackoverflow 帖子标题以进行搜索：JMS 和 Cluster。我发现这两个内容丰富但看似矛盾的帖子：

1. 说示例模型 A 是/应该被隐式支持： 具有 ActiveMQ 代理网络的 JMS 消费者 “这意味着您选择一个代理，连接到它，然后让代理网络在它们之间进行排序。理论上。”

2. 表示不支持示例模型 A： 集群应用程序服务器中的 JMS 主题订阅者如何接收消息？ “在不同应用服务器上运行的所有 PropertiesSubscriber 实例都会收到该消息。”

任何建议将不胜感激。

非常感谢您阅读我的帖子，

基因

你好stackoverflowers。

在尝试使用 ActiveMQ 启动代理时，我遇到了一个非常严重的错误。似乎出于某种原因，管理上下文试图启动已经注册的东西。堆栈跟踪的顶部显示：

有谁知道会发生什么？

我在通过 xBean 解析的外部 XML 文件配置 ActiveMQ 代理时遇到问题。在这一点上，任何帮助、提示、指示、提示或什至欢呼都会受到赞赏。这是我的问题：

我正在尝试使用外部 .xml 文件来配置代理。我的弹簧包上下文中有以下代码：

这应该与配置文件链接，没有其他问题。这是我的 activemq.xml 文件的样子：

如您所见，这是一个非常标准的。开始我的捆绑包时，出现以下异常：

我已经为所涉及的 namaspaces 尝试了几种配置。使用带有和不带有"amq:"声明 ( <broker>and <amq:broker>) 的代理标记，并为 activemq .xsd 声明指定特定的版本号。不过，似乎没有找到 .xsd 文件。如果我提供 activemq .xsd 文件的版本号，我会得到这个：

我使用的是 xbean-spring 3.7 版，可以在这里找到。我尝试从我的com.springsource.org.apache.activemq-5.3.0.jar捆绑文件中提取 .xsd 文件并将其导出到我的一个捆绑包中的一个包上，但解析器似乎仍然找不到它。我还在 Geronimo Jira上针对该问题发布了一个错误。

任何人都可以阐明这个问题吗？

在此先感谢，
爱德华多。

我正在读一本关于设计模式的书（旧版）“面向模式的软件架构”。在专门介绍 Client-Dispatcher-Server 的章节中，SunRPC 被称为 Client-Dispatcher-Server 体系结构，portmapper 在 Client-Server 协商中充当 Dispatcher。我实际上从未使用过 SunRPC，尽管我或多或少知道它是如何工作的。

我有三个问题：

• SunRPC 作为 Client-Dispatcher-Server 机制有哪些软件限制（在接口和功能方面）？
• 今天有什么类似的更好的系统来实现相同的客户端-调度程序-服务器架构（不管语言）？
• Broker 架构和 Client-Dispatcher-Server 架构之间的内在区别是什么？

我确实意识到问题很多而且很复杂。我考虑过拆分成独立的问题，但这次提交的重点是关于一般架构原则和限制，并以一个具体示例（SunRPC）作为典型案例。出于这些考虑，我先发制人地宣布，我将在有机会时立即提供 100 个代表的赏金，无论我在宽限期内对答案的满意度如何。

关于 ActiveMQ：我有一个场景，我有一个生产者向消费者发送小（大约 10KB）文件。虽然文件很小，但消费者需要大约 10 秒来分析它们并将结果返回给生产者。我进行了很多研究，但仍然找不到以下问题的答案：

1. 如何让代理将文件（完全）存储在队列中？
2. 我应该使用 ObjectMessage（因为文件很小）还是 blob 消息？
3. 因为消费者处理速度很慢，我应该降低他们的 prefetchLimit 还是使用循环调度策略？哪一个更好？
4. 最后，在 ActiveMQ 常见问题解答中，我读到了这个 - “如果消费者收到一条消息并且在关闭之前没有确认它，那么该消息将被重新传递给另一个消费者。”。所以我的问题是，ActiveMQ 是否保证只有 1 个消费者会处理消息（因此对生产者只有 1 个答案）？消费者何时确认消息（在默认的自动确认设置中） - 接收消息并将其存储在会话中，还是 onMessage 处理程序完成时？而且，由于消费者的处理速度如此之慢，我是否应该更改一些“超时限制”，以便经纪人知道在将工作交给另一个消费者之前要等待多少时间（这与我之前的问题有关）？

I'm refering to the 'A Request-Reply Broker' in the Zeromq documentation: http://zguide.zeromq.org/chapter:all

I'm getting the general gist of the app: it acts like an intermediary and routes messages from the client to the server and back again.

What I'm not getting though is how it makes sure the correct response from a server is sent to the correct client which originally made the request. I don't see anything in the code example which makes sure about this.

Now in the example they only send 1 message (hello) and 1 response (world), so even if messages are mixed up it doesn't matter, but I'm guessing that the testclient and server are kept deliberately simple.

Any thoughts are welcome...

我想编写一个修改过的 ActiveMQ 代理，当他侦听特定主题的生产者消息以交替处理它们时（例如使用 HDFS API 而不使用默认持久存储）。你有什么想法从哪里开始吗？

在此先感谢，佩鲁奇

我正处于 .NET 服务的规划阶段，该服务不断处理传入消息，其中涉及各种转换、数据库插入和更新等。作为一个整体，该服务庞大而复杂，但它执行的单个任务很小，简单，定义明确。

出于这个原因，并且为了便于将来扩展，我想将服务拆分为几个较小的服务，这些服务基本上执行部分处理，然后再将其传递给链中的下一个服务。

为了实现这一点，我需要某种中间消息传递系统，它将消息从一个服务传递到另一个服务。我希望以这样一种方式发生这种情况，即如果链中的链接崩溃或短暂脱机，则消息将开始排队并在目的地恢复联机后得到处理。

我一直对这类事情使用消息队列，但最近才知道 SQL Service Broker 似乎做了类似的事情。SQLSB 是这种情况的可行替代方案吗？如果是，我是否会通过使用它而不是标准消息队列来看到任何性能优势？

谢谢