queue本身的TTL

注意, 这里说的是queue本身的TTL. 不是说里面的消息

声明一个队列的时候, 可以用x-expires指定队列的TTL值. 过期之后, 这个队列就被删掉了.

不管里面是不是还有消息没有消费

#!/usr/bin/env python
# -*- coding: utf-8 -*-
‘‘‘
the queue exists for only 5 seconds, whether there is messages!
‘‘‘
import pika
import sys

def main():
    body = ‘ ‘.join(sys.argv[1:]) or ‘Hello World‘
    connection = pika.BlockingConnection(
        pika.ConnectionParameters(
            host=‘localhost‘))
    channel = connection.channel()
    channel.queue_declare(queue=‘ttlhello‘,arguments={"x-expires":5000}) # ttl 5 second
    channel.basic_publish(exchange=‘‘,
                          routing_key=‘ttlhello‘,
                          body=body,
                          )
    connection.close()

if __name__ == ‘__main__‘:
    main()

跑一下看看效果

# python queueTTL.py ;sleep 1; rabbitmqctl list_queues; sleep 6;rabbitmqctl list_queues
Listing queues ...
ttlhello    1
Listing queues ...

Per-Queue Message TTL

这个也是队列的属性, 而不是消息的. 队列中的所有消息过了TTL就会被删除.

#!/usr/bin/env python
# -*- coding: utf-8 -*-
‘‘‘
the messages in the queue exist for only 5 seconds
‘‘‘
import pika
import sys

def main():
    body = ‘ ‘.join(sys.argv[1:]) or ‘Hello World‘
    connection = pika.BlockingConnection(
        pika.ConnectionParameters(
            host=‘localhost‘))
    channel = connection.channel()
    channel.queue_declare(queue=‘ttlmessagehello‘,arguments={"x-message-ttl":5000}) # ttl 5 second
    channel.basic_publish(exchange=‘‘,
                          routing_key=‘ttlmessagehello‘,
                          body=body,
                          )
    connection.close()

if __name__ == ‘__main__‘:
    main()

跑一下看看效果

# python queueMessageTTL.py; rabbitmqctl list_queues; sleep 6; rabbitmqctl list_queues
Listing queues ...
ttlmessagehello 1
Listing queues ...
ttlmessagehello 0

Per-Message TTL

发送消息的时候, 也可以给每条消息一个TTL的属性.

messageTTLSend.py

#!/usr/bin/env python
# -*- coding: utf-8 -*-
import pika
import sys

def main():
    body = ‘ ‘.join(sys.argv[1:]) or ‘Hello World‘
    connection = pika.BlockingConnection(
        pika.ConnectionParameters(
            host=‘localhost‘))
    channel = connection.channel()
    channel.queue_declare(queue=‘hello‘)
    channel.basic_publish(exchange=‘‘,
                          routing_key=‘hello‘,
                          body=body,
                          properties=pika.BasicProperties(
                              expiration="5000"
                             )

                          )
    connection.close()

if __name__ == ‘__main__‘:
    main()

跑一下看看效果

# python messageTTLSend.py; rabbitmqctl list_queues; sleep 6; rabbitmqctl list_queues;
Listing queues ...
hello   1
Listing queues ...
hello   0

最后, 如per-message ttl 和 per-queue message ttl不一样, 按小的来.