python使用rabbitmq接收_python实现rabbitMQ的消息生产和接收

本示例确保环境有 MySQL redis rabbitmq

如果启动缺少对应Python模块&＃xff0c;请自行安装下

send-rabbitmq.py

!/usr/bin/python

# -*- coding: utf-8 -*-

import os,sys

import MySQLdb

import pika

import random

import redis

#安装模块 pip install pika

#数据库连接

db &＃61; MySQLdb.connect(&＃39;localhsot&＃39;,&＃39;root&＃39;,&＃39;yumg10&＃39;,&＃39;xiaogezi&＃39;,charset&＃61;&＃39;utf8&＃39;)

cursor &＃61; db.cursor()

cursor.execute("select order_no from t_Loan")

#redis连接

#pool&＃61;redis.ConnectionPool(decode_response&＃61;True)

redis&＃61;redis.Redis(host&＃61;&＃39;localhost&＃39;,password&＃61;&＃39;123456&＃39;,port&＃61;6379)

# 新建连接&＃xff0c;rabbitmq安装在本地则hostname为&＃39;localhost&＃39;

hostname &＃61; &＃39;localhsot&＃39;

parameters &＃61; pika.ConnectionParameters(hostname)

connection &＃61; pika.BlockingConnection(parameters)

# 创建通道

channel &＃61; connection.channel()

# 声明一个队列&＃xff0c;生产者和消费者都要声明一个相同的队列&＃xff0c;用来防止万一某一方挂了&＃xff0c;另一方能正>常运行

channel.queue_declare(queue&＃61;&＃39;hello&＃39;)

for i in &＃39;PYTHON AS YOU KNOW&＃39;:

number &＃61; random.randint(1, 1000)

data&＃61;cursor.fetchone()

redis.set(&＃39;data&＃39;,&＃39;a&＃39;)

#print redis.get(&＃39;data&＃39;)

if data is None:

data&＃61;i

else:

data&＃61;data

body &＃61; &＃39;hello world:%s&＃39; % data

# 交换机; 队列名,写明将消息发往哪个队列; 消息内容

# routing_key在使用匿名交换机的时候才需要指定&＃xff0c;表示发送到哪个队列

channel.basic_publish(exchange&＃61;&＃39;&＃39;, routing_key&＃61;&＃39;hello&＃39;, body&＃61;body)

print body

connection.close()

db.close();

receive-rabbitmq.py

#!/usr/bin/env python3

# -*- coding: utf-8 -*-

import pika

hostname &＃61; &＃39;localhost&＃39;

parameters &＃61; pika.ConnectionParameters(hostname)

connection &＃61; pika.BlockingConnection(parameters)

# 创建通道

channel &＃61; connection.channel()

channel.queue_declare(queue&＃61;&＃39;hello&＃39;)

def callback(ch, method, properties, body):

print " [x] Received %r" % (body,)

# 告诉rabbitmq使用callback来接收信息

channel.basic_consume(callback, queue&＃61;&＃39;hello&＃39;, no_ack&＃61;True)

# 开始接收信息&＃xff0c;并进入阻塞状态&＃xff0c;队列里有信息才会调用callback进行处理,按ctrl&＃43;c退出

print &＃39; [*] Waiting for messages. To exit press CTRL&＃43;C&＃39;

channel.start_consuming()

发文不易&＃xff0c;知识沉淀&＃xff0c;记得关注哦