问题标签 [aggregator]

在 mule 3.x 中创建完全自定义聚合器的推荐方法是什么？通过完全自定义，我的意思是根据我自己的逻辑，不使用相关 ID、消息计数等。

mulesoft 网站上的文档已经过时，说要使用 3.x 中不存在的 AbstractEventAggregator：

http://www.mulesoft.org/documentation/display/MULE3USER/Message+Splitting+and+Aggregatio

深入挖掘，看起来这个类在 3.x 中已重命名为 AbstractAggregator：

http://www.mulesoft.org/docs/site/3.2.0/apidocs/org/mule/routing/AbstractAggregator.html

但是，没有示例说明如何使用它。上面第一个链接中描述的 LoanBroker 示例实际上使用了关联聚合器（在 2.x 示例中，我假设这是文档所指的内容）。

有一次，有一个抽象类具有抽象方法 shouldAggregate 和 doAggregate。这是我想扩展的一类。

我的需求

我希望我们的内部标准产品在发生事情时触发不同的事件。在不同自定义解决方案的全局 asax 中，我想在需要时连接这些事件并做出反应。

现有模块

我一直在寻找 asp.net 的事件聚合器，但我不确定该使用什么。我读过关于 Prism 的文章，但似乎它针对的是 WPF/Silverlight 而不是 asp.net。

然后是这个家伙，他似乎已经将聚合器移植到他自己的版本中，独立于 WPF：http ://weblogs.asp.net/rashid/archive/2009/03/05/use-event-aggregator-to-使您的应用程序更可扩展.aspx

问题

有没有人体验过使用 asp.net 的事件聚合器？这是用于生产用途，所以我不喜欢使用网络上随机人提供的一些家庭编码聚合器:)

先感谢您。

编辑 1： 看起来， NServiceBus 有点矫枉过正。我创建了一个可以解决问题的 EventAggregator 类。

班上：

一个事件类：

在全局 asax 中注册事件处理程序：

引发事件：

编辑2：

这是我对感兴趣的人的单元测试：

编辑 3：

感谢 Steven Robbins 指出聚合器不是线程安全的，我在 Publish 和 Register 方法中添加了锁定。

有没有人使用 Commission Junction 的产品目录搜索 API 来搜索/获取本地交易？（BuyWithMe 和 KGBDeals 将他们的交易发布到 CJ）

那里有一个使用这个 API 的 Yipit 克隆。此克隆无法根据位置正确分类交易。我应该解决这个问题。我看到的问题是：API 的响应不包含位置/城市信息。因此，不能根据城市对交易进行分类。这基本上扼杀了本地交易的目的。

我正在向使用 CJ API 做过类似工作的任何人寻求建议。可能是我错过了一些东西。

我正在使用 Prism 实现一个应用程序。该应用程序有一些分布式组件，它们驻留在各种机器或服务器上。为了与他们交流，我计划使用 Event Aggregator 实现消息传递服务。但在我开始研究之前，我想澄清一下：

1. 事件聚合器可以在分布式环境中使用吗？如果是，那么如何定义将发布或订阅消息的服务器或集线器？

2. 使用 Event Aggregator 对应用程序的性能有何影响？我觉得它可以忽略不计，但我仍然想知道。

3. 事件聚合器方法是否适合企业环境中的未来扩展？

谢谢并恭祝安康，

阿什·夏尔马

我找不到在 ASP.NET Web 表单中实现的事件聚合器的任何示例/演示。几乎所有文章都是针对 Silverlight 的。

你能给我指一些文章吗，最好在 ASP.NET web.forms 中使用实现事件聚合器模式的工作代码。

最简单的例子：ASP.net webform 中的两个用户控件，通过事件聚合器模式相互通信。

编辑

目前我有一个严重基于用户控件的 ASP.NET Web 表单应用程序。容器 aspx 页面可以托管多个需要在它们之间进行通信的用户控件 (ascx)。目前，它是由通过容器页面的事件完成的：

这已经失控了:(

我有一个需要转换的 SQL 查询，但我不知道该怎么做。这就是我想要做的：

但我很难弄清楚如何同时执行 where 子句和max ，这很关键。

如何在同一个查询中同时执行这两项操作？

我已经为使用 php/Mysql 的客户端构建了 RSS、twitter 和其他内容聚合器。它通常涉及一项 cron 作业、一些提要解析和将数据插入数据库以进行存储和稍后重新发布、删除或存档等。没有什么突破性的。

但现在我的任务是为公众构建聚合服务。我想这需要快速扩展，因为每个有权访问该服务的人都可以添加数十个（如果不是数百个）源提要。在几个月内，我们可能会定期解析 1000 个提要，一年内可能会解析 100,000 个提要，如果运气好的话，可能会更多。

我想最终的模型类似于谷歌阅读器所做的。

那么，有什么好的策略呢？多个重叠的 crons、持续运行和阅读提要并连接到 API 以提取内容？我应该计划运行多个 Elastic Cloud 实例还是随着需求的增长而运行？

抱歉，已经有几个关于如何构建聚合器的线程。它们中的大多数在解释构建一个的具体细节方面很有帮助，但我只需要关于已经存在的稳定可靠脚本的建议。

我特别想在我的 Wordpress 网站上添加一个时尚特定的新闻聚合器，专门用于时尚。简单来说，我需要一个可以爬网的脚本，在 Glam、Vogue、Instyle、NYTimes、Fashion 等网站上寻找最新消息，并将它们提供给我拥有的不同类别 - 时尚与风格、美容与化妆，健康与保健等

我只需要来自 stackoverflowers 的一些关于可以执行此操作（或几乎没有自定义）的脚本的建议。万分感谢！祝大家节日快乐。

我正在使用 LAMP 构建一个提要（rss、twitter、其他服务等）聚合器。它与谷歌阅读器非常相似，人们可以根据需要添加任意数量的提要，然后能够一次阅读他们的提要、对其进行排序、查看单个提要或提要组。

我之前已经构建过这种类型的服务，但只是针对一小部分有限的人，其中整个组都可以访问所有聚合的提要项目。所以，这很简单。

然而，这一次，我正在构建一个人们可以订阅的服务，所以我可能（理想情况下）有成千上万的用户和 10 的数千个提要，反过来，还有数百万个提要项。

我对数据库模式（简化）的方法是这样的：

但是，由于用户可以订阅 100 个提要，因此我正在尝试计划出最佳和最优化的方式来查询数据库以获取他们订阅的提要（或子集）的 feed_items。

我需要在 Mule ESB CE 3.2.1 上聚合内存中的许多 csv 入站文件，如有必要对它们进行重新排序。

我怎么能实现这种逻辑？

我尝试使用 message-chunking-aggregator-router，但它在启动时失败，因为 xsd 架构不接受这样的配置：

我还尝试将我的相关 ID 附加到入站消息，然后通过自定义聚合器处理它们，但我发现 Mule 内部使用由以下各项组成的密钥：

内部 id 每次都不同（如果相关序列是正确的）：这样，Mule 不会像我预期的那样只使用相关序列，并且多次处理相同的消息。

最后，我可以重新编写自定义聚合器，但我想使用更统一的技术。

提前致谢，

加布里埃尔

更新

我试过使用 message-chunk-aggregator 但它不符合我的要求，因为它承认重复。

我尝试详细说明我需要涵盖的场景：

1. Mule 投票（在 SFTP 位置上）
2. 检测到文件 1“FIXEDPREFIX_1_of_2.zip”并将其保存在内存中的某处（作为打开的 SFTPStream，没关系）。为分组保留一些相关信息：组、序列、组大小。
3. 再次检测到文件 1“FIXEDPREFIX_1_of_2.zip”，但无法插入，因为会重复
4. 检测到文件 2“FIXEDPREFIX_2_of_2.zip”，并正确添加
5. 表示已达到组大小，Mule 使用正确的消息集路由 MessageCollection

关于第 2 点，我很幸运能够从文件名中获取信息并将它们放入 MuleMessage::correlation* 属性中，以便后续组件可以使用它们。

我做到了，但重复的处理方式相同。

再次感谢

加布里埃尔