send.py

#!/usr/bin/env python   # -*- coding: UTF-8 -*- import pika  import random          credentials = pika.PlainCredentials('root', '123456')  #这里可以连接远程IP，请记得打开远程端口    parameters = pika.ConnectionParameters('139.x.x.x',5672,'/',credentials)    connection = pika.BlockingConnection(parameters)    channel = connection.channel()        #channel.queue_declare(queue='hello')    number = random.randint(1,1000)  body = 'hello world:%s' %number  channel.basic_publish(exchange='',                          routing_key='hello',                          body=body)    print " [x] Sent %s" %body    connection.close()

receice.py

#!/usr/bin/env python   # -*- coding: UTF-8 -*- import pika  import random          credentials = pika.PlainCredentials('root', '123456')  #这里可以连接远程IP，请记得打开远程端口    parameters = pika.ConnectionParameters('139.x.x.x',5672,'/',credentials)    connection = pika.BlockingConnection(parameters)    channel = connection.channel()        #channel.queue_declare(queue='hello')    number = random.randint(1,1000)  body = 'hello world:%s' %number  channel.basic_publish(exchange='',                          routing_key='hello',                          body=body)    print " [x] Sent %s" %body    connection.close()