python采用pika库使用rabbitmq（二）

Pika是用于Python的RabbitMQ（AMQP-0-9-1）客户端库，官方文档地址：https://pypi.org/project/pika/

工作模式：其中P表示produce，生产者的意思，也可以称为发送者，实例中表现为send.py；C表示consumer，消费者的意思，也可以称为接收者，实例中表现为receive.py；中间红色的表示队列的意思，实例中表现为hello队列。

import pika


credentials = pika.PlainCredentials('admin', 'passwd')
connection = pika.BlockingConnection(pika.ConnectionParameters(
    'ip',credentials=credentials))



channel = connection.channel() #建立了rabbit 协议的通道

# 声明queue,
channel.queue_declare(queue='hello')

# n RabbitMQ a message can never be sent directly to the queue, it always needs to go through an exchange.
channel.basic_publish(exchange='',
                      routing_key='hello',
                      body='Hello World!')
'''
        exchange表示交换器，能精确指定消息应该发送到哪个队列
        routing_key设置为队列的名称
        body就是发送的内容
'''
print(" [x] Sent 'Hello World!'")
connection.close()

可以使用

rabbitmqctl list_queues命令查看队列

import pika
import time

credentials = pika.PlainCredentials('admin', 'passwd')
connection = pika.BlockingConnection(pika.ConnectionParameters(
    'ip',credentials=credentials))

channel = connection.channel()

channel.queue_declare(queue='hello')


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

    print("received msg...start processing....",body)
    time.sleep(20)
    print(" [x] msg process done....",body)


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

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