问题标签 [poller]

我正在为多用户系统开发电子邮件轮询解决方案。所以用户可以在他们各自的 id 上发送电子邮件，它会被轮询并插入到数据库中。

我正在考虑两种选择：

1. 基于 Perl/Unix 的电子邮件轮询器..
2. 基于 java 的轮询器。

你会推荐什么..（也欢迎其他建议）

我需要在指定的时间间隔内将消息从 Queue1 转发到 Queue2，而不是在消息到达 Queue1 之后。下面是我的配置。

上面的 xml 配置将消息立即从 Queue1 转发到 Queue2，忽略 <int:poller> 配置。我已经尝试了基于间隔和基于 cron 的解决方案，它们似乎工作相似（立即将消息从 Queue1 传递到 Queue2）。这里的“poller”配置有什么问题吗？任何帮助都感激不尽。

设计明智和性能明智，建议使用哪种方法来处理多个 Zeromq 套接字，为什么？

ZeroMQ 使用的 Tornado 的 IOLoop 占用的 CPU 是否比 while 循环中用于处理多个套接字的轮询器占用的 CPU 少？

您好我正在使用backbone.js 开发paly2.0 框架应用程序（使用java）。在我的应用程序中，我需要定期从数据库中获取表数据（用于显示即将发生的事件列表的用例以及是否应从列表中删除越过的旧事件）。我正在获取要显示的数据，但是问题是定期访问数据库。为此，我尝试根据这些链接使用 Backbone.js 轮询集合，http ://kilon.org/blog/2012/02/backbone-poller/ 使用主干.js 轮询概念。但是他们没有从 db 轮询最新的集合。请建议我如何实现这一目标或任何其他替代方案？谢谢你的建议。

我正在尝试从目录中读取文件。如果文件无法处理，它会留在那里以供稍后尝试。

问题是，如果 max-messages-per-poll 设置为 10，那么每次轮询将准确返回 10 条消息，即使只有 1 个文件（即所有 10 条消息都相同）。

我有一个事务轮询器（spring 3.1.2 和 spring-integration 2.2.3）来确保如果事务被异常回滚，消息将被重新传递

这在使用 H2 数据库进行单元测试时工作正常，只要方法抛出异常，消息就会重新传递

但是当我使用我们在生产中使用的 sql-server（ms-sqlserver，如果这很重要，它使用 READ COMMITTED SNAPSHOT 作为隔离级别）时，异常的重新传递不起作用。任何提示为什么会这样？

编辑：

我测试了 TRACE 日志，但找不到可疑的日志消息，最后我让它工作了。我声明了一个单独的数据源（与普通数据库相同的配置）和 transactionManager org.springframework.jdbc.datasource.DataSourceTransactionManager 而不是我正常的 org.springframework.orm.jpa.JpaTransactionManager。

我正在实现一个缓冲区，以执行各种工作。我正在开发一个基于 Spring 的项目。我决定使用 Spring Integration 来实现我的目标。我通过一个 Cafè 示例项目来了解 SI 的工作原理。

为了演示 Spring 集成，我实现了一个表，我在其中动态插入要执行的作业。该表是“网关”。然后我配置了一个路由器和各种通道。

我不完全理解的是必须检查“网关”中是否存在新作业的轮询元素。这个对吗？

如果是这样，我该如何配置轮询器？提前致谢！这里的xml代码：

脸书

我很好奇是否可以在不使用 var 来保持实例的情况下安全地实现自取消轮询器akka.actor.Cancellable

到目前为止，我想出了类似于您在下面的示例中看到的内容。但是，我很好奇是否可以安全地假设在热交换发生之前永远不会发送“tick”消息，即调度轮询器的行：

基本上是一样的：

所以，我认为在某些情况下，会在热插拔有机会发生之前收到第一个滴答声……想法？

我是 Spring Integration 的新手，并且有一个关于将消息的轮询器和事务支持与 max-messages-per-poll 值结合使用的问题。

当使用具有以下配置的轮询器时

文档提到轮询任务每次轮询将产生 10 条消息（或直到收到 null）。

每条消息是否会在其自己的事务边界中运行，即如果一条消息未能到达事务边界的末尾，将仅针对失败的消息进行回滚，还是将所有 10 条消息（属于轮询的一部分）都回滚？

谢谢 RC

提前为菜鸟问题道歉。

一个模块每 N 秒向消息代理发送消息。另一个模块从代理接收消息。消息构建在服务激活器的方法 sendMessage 中。计划是使用入站通道适配器（如答案中所示），但由于某些原因，此解决方案不起作用，我一直收到“在轮询期间未收到任何消息，返回 'false'”。这个配置有什么问题？