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()
时间: 2024-11-08 09:35:36