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消费者，使其在停止消费的
-
我们有一个Storm拓扑，其中我们配置了一个喷口和两个螺栓。Spout连续地从DB查询数据，并将其发送到first bolt进行某些处理。第一个bolt进行一些处理并将元组发送给第二个bolt，第二个bolt调用第三方web服务并发送数据。所以，经过一段时间后，最后一个bolt没有得到任何元组，如果我们重新启动拓扑，它工作得很好。这里只有最后一个螺栓有问题。其他喷口和第一螺栓运行良好，我不使用顶进