Python操作rabbitmq 实践笔记

 1 import pika
 2 import sys
 3 
 4 username = 'wt'   #指定远程rabbitmq的用户名密码
 5 pwd = '111111'
 6 user_pwd = pika.PlainCredentials(username, pwd)
 7 s_conn = pika.BlockingConnection(pika.ConnectionParameters('192.168.1.240', credentials=user_pwd))#创建连接
 8 chan = s_conn.channel()  #在连接上创建一个频道
 9 
10 chan.queue_declare(queue='hello') #声明一个队列，生产者和消费者都要声明一个相同的队列，用来防止万一某一方挂了，另一方能正常运行
11 chan.basic_publish(exchange='',  #交换机
12                    routing_key='hello',#路由键，写明将消息发往哪个队列，本例是将消息发往队列hello
13                    body='hello world')#生产者要发送的消息
14 print("[生产者] send 'hello world")
15 
16 s_conn.close()#当生产者发送完消息后，可选择关闭连接
17 
18 
19 输出：
20 [生产者] send 'hello world 1 impor