python使用rabbitmq实现简单的消息转发

准备：

　　1.下载elang语言的支持环境http://www.erlang.org/download.html （rabbitmq使用它开发的）

　　2.下载rabbitmq软件http://www.rabbitmq.com/releases/rabbitmq-server/（根据自己的系统选择）

　　3.安装elang,rabbitmq,并配置环境变量，我的是windows7，步骤大概如下：

　　　　a.新建变量：ERLANG_HOME=D:Program Fileserl6.1，然后再path中添加%ERLANG_HOME%in;

　　　　b.新建变量：RABBITMQ_SERVER=D:Program Files abbitmq_server-3.3.4，然后再path中添加%RABBITMQ_SERVER%sbin;

　　　　c.运行sbin/rabbitmq-server.bat,启动RabbitMQ服务器效果如下图

　　　　　　

用python操作rabbitmq

　　1.下载pika支持包（pip install pika）

　　2.消息发送接收采用的是生产者消费者模型

生成者方代码Productor.py　

# __author__ = 'STEVEN'
import pika
def b():
    #建立socket
    connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost'))
    #声明一个管道
    piple = connection.channel()
    #创建一个队列
    piple.queue_declare('hello')
    #发送消息
    piple.basic_publish(exchange='',routing_key='hello',body='你好啊')
    print('[x] sent message..hello')
    connection.close()
b()

消费者方代码Consumer.py

# __author__ = 'STEVEN'
import pika
#创建socket链接
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
#创建管道
channel = connection.channel()
#创建队列
channel.queue_declare('hello')
#声明回调函数
def callback(ch,method,properties,body):
    print('[x] recieved message%r'%body.decode())
#如果接受到消息就调用回调函数,准备接受消息
channel.basic_consume(callback,queue='hello',no_ack=True)
print('[*] is waiting for recieve mess press ctrl+c to eixt')
#开始消费消息
channel.start_consuming()