RabbitMQ集群中的一个节点会偶尔消耗大量内存（直到OOM）

1. 确认操作系统和RabbitMQ版本是否与推荐版本相同，因为不同的版本可能导致内存泄漏。

2. 禁用或调整队列中的消息的过期时间，避免产生过多的死信消息，占用内存。

3. 确认是否有消费者没有及时确认消息，导致消息堆积。

4. 确认是否有生产者发布了大量的消息，而消费者无法快速消费。可以考虑增加消费者数量或限制生产者发布的消息数量。

下面是一个简单的RabbitMQ消费者示例，用于消费名为“test_queue”的队列中的消息，并确认消息：

import pika

connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()

channel.queue_declare(queue='test_queue')

def callback(ch, method, properties, body):
    print("Received %r" % body)
    ch.basic_ack(delivery_tag = method.delivery_tag)

channel.basic_consume(queue='test_queue', on_message_callback=callback)

channel.start_consuming()

在这个示例中，消费者使用basic_consume()方法订阅名为“test_queue”的队列，并将消息通过回调函数进行处理。在回调函数中，消费者打印消息内容，并调用basic_ack()方法确认消息已被处理。确保及时确认消息，避免消息堆积。