问题标签 [aggregator]

我有两种类型的消息（A 和 B）到达聚合器。如何聚合第一个到达的 A 和第一个到达的 B？

这个问题来自一个非技术人员。我已经要求一个团队构建一种 RSS 阅读器。从本质上讲，它是一个新闻聚合器。我们最初的想法是直接从特定来源获取新闻：ft.com、reuters.com 和bloomberg.com。

现在，开发团队提出了一种特定的方法（因为它会更容易）......那就是使用 news.google.com 并返回任何结果。现在我知道这有可疑的合法性，我们对这个事实并不那么满意，但是当法律部门正在检查时......我们已经开始使用原型。

现在出现了技术问题......因为该方法实际上是通过news.google.com模拟搜索，一段时间后它返回一个验证码。我怀疑这是因为该方法是使用显示为RSS 的结果进行搜索，而不是直接使用RSS ......但是开发团队说 RSS 是完全相同的东西......并且它也会提供验证码。

我有疑问。如果是这样的话，其他新闻聚合网站是如何完成来自不同来源的提要的汇编的？

供您参考，这里是最终提供验证码的 URL 相同 https://news.google.com/news/feeds?hl=en&gl=sg&as_qdr=a&authuser=0&q=dbs+bank+singapore&bav=on.2， or.r_gc.r_pw.r_cp.,cf.osb&biw=1280&bih=963&um=1&ie=UTF-8&output=rss

我只是想对一列求和并在表格底部显示总数。从查看示例看来，使用聚合器似乎是做到这一点的最佳方式。但是，当我简单地添加

dataView.setAggregators([ new Slick.Data.Aggregators.Sum("value") ], false);

什么都没发生。我已经尝试了几个小时，只是为了让一个基于分组示例的简单聚合器工作，但是分组示例太复杂了，我无法准确说出我需要什么。

编辑：替代修复：对于其他人来说，我最终没有使用聚合器。这些数据以 Javascript 形式提供，这使生活变得更加轻松。可以从那里计算总数。

我正在使用由 jdbc 支持的camel:aggregate，它似乎没有保存 Exchange 属性。例如，如果我配置了以下路由，并且一旦聚合完成并且在执行 camel:to(log) 强制聚合在重新启动时从数据库中检索数据之前就停止执行，那么 camel:to(log) 不会打印属性myProperty

我的聚合存储库是这样配置的：

使用聚合器时如何保存属性？

我使用 SimpleMessageStore ( memory ) 作为 Aggregator 的默认存储，但由于我需要持久存储，我开始使用由 Mysql 5.5 支持的 jdbc 解决方案

但我真的很担心它的性能，因为使用 PerfTest（databene 的 contiperf），内存存储达到 6000 条消息/秒，而使用 mysql（或 redis，或 mongo），我不能达到超过 15-20消息/秒。

我错过了什么吗？我正在使用 spring-integration-jdbc 库中的默认模式。

使用带有集合拆分器/聚合器的请求/回复路由器，我成功地将一组消息异步拆分到其工作人员，然后使用聚合器将结果很好地合并在一起。

现在我想在上面做一个循环（同步），所以我在现有的上面使用 Foreach MP 或另一组拆分聚合（是的，我确实将这些属性保存为调用属性区域并恢复它们背部）。

我可以看到它在第一次迭代中通过聚合器完成，但是请求/回复路由器中的 VM 入站端点永远不会得到任何东西，所以卡住了。我尝试了很多东西，但没有任何帮助。知道为什么吗？

我在 ArrayList AL 下有两个字符串数组 sa: {11, 12, 13} 和 sb: {21, 22, 23}。我想在 AL 上同步循环，对于每个字符串数组，我想异步进行拆分聚合。

很感谢任何形式的帮助。

苏里

大卫，谢谢。
我将记录器放在请求/回复路由器之后，流程没有命中它。我在集合聚合器之后也有一个记录器，它确实命中了它。

这是 XML 配置 ------------

我想问题可能是“MULE_CORRELATION_ID”。我使用标签来处理一批数据。配置如下：

我正在使用 Apache Camel 和 aggretaor EIP 开发一条路线。该路由通过 jms 使用来自数据库的数据，将其聚合并将它们发送到 Web 服务。

聚合器将数据持久保存在 oracle 数据库中。

众所周知，聚合器的同步块是该路由中的瓶颈。

我已经尝试使用多个存储桶（correltionExpression = threadName），但它并没有像想要的那样提高速度......

我每秒至少需要 150 条消息。目前只有70个是可能的:(

有谁知道如何提高速度？也许第二个聚合器？有什么建议吗？

最后一个问题：聚合器是否能够在多个存储桶中并行写入消息，还是因为锁而不能这样？因为代码中的文档说它是（每个相关键的并发聚合可以提高性能），所以我认为代码本身并没有这样做。

提前致谢！！

斯特凡

我已经安装了骆驼（版本 2.10.X），我可以使用 csv 和 xslt 处理器运行许多示例。现在我正在尝试使用 camel aggregator。我改编了骆驼文档中的一个示例，这样当 3 个文件写入input目录时，它们必须被聚合并发送到输出目录。

我的上下文如下：

但是在部署war文件时，应用程序没有启动并出现异常：（localhost_XXXXXX.log

在我的上下文中，这应该是对这个标签的引用：

我究竟做错了什么？

谢谢！

编辑

这是我的pom.xml

我想做一个数字列表的总和聚合。我想使用泛型来做，因为我们将使用不同的聚合函数。

这就是我想要的（更多更少）：

我想Aggregator从所有Aggregator类实现一个接口。

我可以这样做吗？也许有人知道该怎么做，或者更好的方法来做我想做的事。

编辑：这是我尝试过的