AMQP Appender 挂起消息计数

Question

我们正在将审计日志消息发送到 RabbitMQ 集群，由于我们无法影响的原因，该集群有时不可用。

当队列不可用时，日志消息开始在本地累积，我们最终会在客户端出现内存不足的情况。

我们正在使用 AMQP Appender 来提交我们的消息。

有没有一种方法可以让我们查询待处理日志消息的数量并在消息开始累积时发出警报？

Answer 1

嗯，这是不可能的。没有任何钩子可以做到这一点。

不过，您可以考虑将 maxSenderRetries 从默认 30 减少到 1 或 2。之后您将开始丢失日志消息：

int retries = event.incrementRetries();
if (retries < AmqpAppender.this.maxSenderRetries) {
    // Schedule a retry based on the number of times I've tried to re-send this
    AmqpAppender.this.retryTimer.schedule(new TimerTask() {
            @Override
            public void run() {
                AmqpAppender.this.events.add(event);
            }
        }, (long) (Math.pow(retries, Math.log(retries)) * 1000));
}
else {
    addError("Could not send log message " + logEvent.getMessage()
                + " after " + AmqpAppender.this.maxSenderRetries + " retries", e);
}

我们可能不得不公开 queueSize 选项而不是默认选项：

public LinkedBlockingQueue() {
    this(Integer.MAX_VALUE);
}

欢迎就此事提出 JIRA。

AMQP Appender 挂起消息计数

AMQP Appender pending message count

spring

rabbitmq

spring-amqp