标签：blog http io ar os sp for strong on
派猴子来的救兵注意, 这里说的是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 ...
这个也是队列的属性, 而不是消息的. 队列中的所有消息过了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
发送消息的时候, 也可以给每条消息一个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不一样, 按小的来.
标签：blog http io ar os sp for strong on
原文地址：http://www.cnblogs.com/morningchilde/p/4127536.html
