import pika
# 连接到RabbitMQ服务器
credentials = pika.PlainCredentials('xxxxxxxxxxxxxxxxx==',
'xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx')
connection = pika.BlockingConnection(pika.ConnectionParameters(
'rabbitmq-serverless-cn-y1i3ptrzv06.cn-hangzhou.amqp-11.net.mq.amqp.aliyuncs.com', 5672, virtual_host='zhgj', credentials=credentials))
# connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()
queue_name = "test"
channel.basic_publish(exchange='test',
routing_key='test',
body='Hello World!')
channel.queue_declare(queue='test',durable=True,passive=True) # 如果是持久化队列就是True
# 打印连接确认信息
print('Connected to RabbitMQ!')
# 关闭连接
connection.close()