当单独进程中的 AMQ 队列填满时，Camel Producer 会阻塞

Question

我有两个使用骆驼的独立 Spring Boot 应用程序 - 我们称它们为 producer 和 consumer。

在producer进程中，骆驼ProducerTemplate向activemq:queue:consumer发送消息

在consumer 进程中，监听该队列。

当我杀死consumer 进程时，我可以在AMQ 控制台中看到队列没有消费者，producer 向队列发送大约1000 条消息，然后阻塞。

如果我清除队列，producer 会解除阻塞并处理大约另外 1000 条消息，然后我们重复。

如果下游队列得到备份，为什么producer 进程会退出？我该如何解决这个问题？

我正在使用Spring Boot 1.5.6、Camel 2.18.0 和Apache activemq 5.11.0.redhat-630187

Answer 1

在我看来，您的代理正在使用生产者流控制，这基本上意味着生产者将被阻止发送超出代理可以处理的消息。为了解决这个问题，您可以启用消息游标，它将消息写入磁盘，从而延迟一个块，直到所有分配的磁盘空间都被填满。

您可以阅读有关生产者流控制here 和消息游标here 的更多信息。