rabbitmqテスト

 ， 。 / 。

# --*-- coding:utf-8 --*--

import pika

import datetime

connection = pika.BlockingConnection(pika.ConnectionParameters(

               'localhost'))

channel = connection.channel()



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



----------------received



# --*-- coding:utf-8 --*--

import pika



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

~                      



---------------send.py