RabbitMQ Spring AMQP-一段时间后的消息处理
使用Spring AMQP（使用RabbitMQ作为消息代理），我正在准备一个消息，并且我希望我的消息在有时之后被使用。在此之前，它可以在某个队列中等待，比如等待队列，然后移动到我们的主队列，在那里我们有消费者，它正在等待处理来自主队列的消息。
p.s>如果没有rabbitmq_delayed_message_exchange插件也可以。
共有1个答案
如果您不想使用延迟交换插件，您可以将消息发送到带有生存时间的队列（在队列或消息上设置了ttl）。
配置队列以将过期消息路由到死信交换,该死信交换路由到最终队列。
someExchange -> ttlQueueWithDLX -> DLX -> liveQueue
-
在我的Spring启动应用程序中，我有kafka消费者类，每当主题中有可用消息时，它会频繁读取消息。我想限制消费者每隔2小时消费一次消息。就像阅读完一条消息后，消费者将暂停2小时，然后再消费另一条消息。这是我的消费者配置方法：- 然后我创建了这个容器方法，在其中我设置了kafka配置的其余部分 使用此代码分区每2小时重新平衡一次，但它根本没有读取消息。我的kafka消费者方法：-
-
问题内容： 这可能是一个重复的问题，但我没有找到想要的东西。我在UI活动中调用AsyncTask， 在doInBackground中调用需要时间的方法。如果一段时间后没有返回数据，我想中断该线程。以下是我尝试执行此操作的代码。 但这并不能在30秒后停止任务，事实上，这花费了更多时间。我也尝试过，但这也不起作用。 谁能告诉我该怎么做或如何在doInBackground中使用isCancelled（）
-
应用程序有一个JMS队列负责交付审计日志。应用程序将日志发送到JMS队列，该队列由MDB使用。 但是，发送的消息是大 XML 文件，大小从 20 MB 到 100 MB 不等。问题在于 JMS 队列使用消息的时间太长，从而导致内存不足错误。 我应该怎么做才能解决这个问题？
-
问题内容： 在我的组织中，我们有许多Redis工作人员来完成我们的关键任务。通常，一天一次或两次，我们的工人会停止处理队列。 该代码基本上如下所示： 如果看到的话，就代码而言，发生的事情并不多，但是每隔一段时间，队列就会开始建立，并且工作程序不会从队列中弹出任何项目。为设置超时根本没有用，因为我们假设问题出在Redis客户端连接上。 目前，我们已经建立了一些侦听器，这些侦听器会在队列建立时提醒我们
-
更新06/04这里是消费者出厂设置。它是Spring-Kafka-1.3.1。Kafka经纪人合流版 注意：容器工厂已将自动启动设置为false。这是在加载大文件时手动启动/停止使用者。 运行大约1小时后（时间不同），使用者停止使用来自其主题的消息，即使该主题有许多可用消息。Consumer方法中有一个log语句，用于停止在日志中打印。 我们如何设计Spring-Kafka消费者，使其在停止消费的
-
我正在使用NSeriveBus构建一个系统，它应该只在特定的时间段将消息发送给远程处理程序。到目前为止，我设法将所有消息放在一个处理队列上，并从那里检查远程处理程序的可用性，如果处理程序不可用，我就不会通过边界发送消息。要做到这一点，我正在使用 但国家安全局会继续努力。这不像其他侦听器将在几分钟内启动并运行，但它可能有几个小时的停机窗口，因此这并不完全有效。 想知道是否有办法让总线稍后重试消息，或