python第五十七天-- 补上笔记

RabbitMQ队列:

发送端:

#!usr/bin/env python
#-*-coding:utf-8-*-
# Author calmyan 
#python 
#2017/6/26    16:08
#__author__='Administrator'
import pika
connetion =pika.BlockingConnection(
    pika.ConnectionParameters('localhost')#创建连接
)
chann_1=connetion.channel()#生成一个管道

chann_1.queue_declare(queue='hello')#生成对列

chann_1.basic_publish(exchange='',#
                      routing_key='hello',#使用的对列
                      body='发送的内容....'
                      )
print('[xxx]:发送了内容....')
connetion.close()#关闭连接

接收端:

#!usr/bin/env python
#-*-coding:utf-8-*-
# Author calmyan 
#python 
#2017/6/26    18:28
#__author__='Administrator'
import pika
connetion =pika.BlockingConnection(
    pika.ConnectionParameters('localhost')#创建连接
)
chann_1=connetion.channel()#生成一个管道

chann_1.queue_declare(queue='hello')#生成对列

def callback(ch,method,properties,body):
    print(ch,method,properties)#ch 管道内存对象,  method ,队列等 信息
    print('[xxx] 回调函数的内容 %r'%body.decode())

chann_1.basic_consume(#收消息
        callback,#如果收到消息就调用  函数
        queue='hello',#收消息的对列
        no_ack=True#
                      )
print('运行一直收消息, Ctrl+C 退出!')
chann_1.start_consuming()#开始接收消息