#消费者
import pika

# 连接服务器

credentials = pika.PlainCredentials('*****', '***')

connection = pika.BlockingConnection(pika.ConnectionParameters('116.85.14.1**', 56**, '/', credentials))

channel = connection.channel()

# rabbitmq消费端仍然使用此方法创建队列.这样做的意思是:若是没有就创建,和发送端道理一样,目的是为了保证队列一定会有

channel.queue_declare(queue='hello')

# 收到消息后的回调

def callback(ch, method,properties,body):

    print("[x] Received % r"%body)

channel.basic_consume(callback,queue='hello',no_ack=True)

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

channel.start_consuming()