论坛 › Python › python测试rabbitmq的消息收发

huiselele 发表于 2018-8-10 09:48:54

python测试rabbitmq的消息收发

#!/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 " Sent %s" %body
　　
connection.close()

查看完整版本: python测试rabbitmq的消息收发