python pika 操作 rabbitmq

首先安装pika
pip install pika

安装rabbitmq的东西 去之前celery的文章里面看

启动rabbitmq
直接上代码

import pika


def send_message():
    connection = pika.BlockingConnection(pika.ConnectionParameters(
        ‘localhost‘))

    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()


def get_message():
    connection = pika.BlockingConnection(pika.ConnectionParameters(
        ‘localhost‘))
    channel = connection.channel()

    channel.queue_declare(queue=‘hello‘)

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

    print ‘ [*] Waiting for messages. To exit press CTRL+C‘

    channel.start_consuming()


def callback(ch, method, properties, body):
    print "Received %r" % (body,)

方法很简单 也很容易懂的