#測試RabbitMQ消息永久化
#1. 分隊列永久化和信息永久化
#2. 意思為當服務重啟後，隊列和消息還存在，可供客戶端接受
#3. 在服務器查看消息隊列命令./rabbitmqctl list_queues

#send 端

import pika

credentials = pika.PlainCredentials(‘root‘, ‘Password1‘)

connection = pika.BlockingConnection(pika.ConnectionParameters(‘10.3.151.86‘,5672,‘/‘,credentials))

channel = connection.channel()

channel.queue_declare(queue=‘hello3‘,durable=True)   #durable=True 聲明一個隊列永久化（服務重啟後還在）

channel.basic_publish(
    exchange=‘‘,
    routing_key=‘hello3‘,
    body=‘Hello Wfffforld!‘,
    properties=pika.BasicProperties(delivery_mode=2)
)
#properties=pika.BasicProperties(delivery_mode=2)  將消息永久化（服務重啟後還在）

connection.close()

本文出自 “學習旅程” 博客，請務必保留此出處http://mingkang.blog.51cto.com/9678221/1976128

第五章：Python 之 RabbitMQ消息持久化