#  ————————生产者——————————
import pika

#  创建连接
connection = pika.BlockingConnection(pika.ConnectionParameters(host = 'locahost'))
#  创建频道
channel = connection.channel()
#  创建队列
channel.queue_declare(queue = 'hello')  

channel.basic_publish(exchange='',
routing_key='hello',     #  队列名
body='Hello World!')     #  内容

print("[X]Sent 'Hello World!'")
connection.close()

#  ————————消费者——————————
import pika

connection = pika.BlockingConnection(pika.ConnectionParameters(host = 'locahost'))

channel = connection.channel()

channel.queue_declare(queue = 'hello')

def callback(ch,method,properties,body):
    print("[x]Received %r" % body)
    import time
    time.sleep(3)
    print('ok')
    ch.basic_ack(delivery_tag = method.delivery_tag)         #  告诉队列处理完了
    
channel.basic_consume(callback,
queue = 'hello',
no_ack = True)    

print('[*]Waiting for messages. To exit press CTRL+C')
channel.start_consuming()

#  在创建队列时注明需要持久化保存
channel.queue_declare(queue='hello',durable = True)  

channel/basic_qos(prefetch_count=1)

import pika 

connection = pika.BlockingConnection(pika.ConnectionParameters(host = 'locahost'))
channel = connection.channel()
#  把exchange 类型设置为fanout
channel.exchange_declare(exchange= 'logs',type = 'fanout')

#  给队列随机取名
result = channel.queue_declare(exclusive=True)
queue_name = result.method.queue
#  绑定信息
channel.queue_bind(exchange='logs',queue=queue_name)

print('[*]Waiting for messages. To exit press CTRL+C')
def callback(ch,method,properties,body):
    print("[x] %r" % body)
    
#  生产者——————————（不管是生产者还是消费者都需要设定类型）
channel.basic_publish(exchange='logs',routing_key='',body='内容')
connection.close()

#  消费者——————————(需要取名、绑定信息和定义函数)
channel.basic_consume(callback,queue=queue_name,no_ack=True)
channel.start_consuming()

channel.exchange_declare(exchange= 'logs_direct',type = 'direct')
#  生产者——发送的时候指定关键字
channel.basic_publish(exchange='logs_direct',routing_key='关键字',body='内容')
#  消费者——把队列和关键字绑定起来
channel.queue_bind(exchange='logs_direct',queue_name='队列名',routing_key='关键字')