标签：rabbitmq dmi password queue callback close 2.7 一个 back
这里的环境使用的是Mac OS X系统，所有的配置和使用都是基于Mac OS X 和Python 2.7 以及对应的pika库的。
#brew install rabbitmq#sudo brew services start rabbitmq
#sudo rabbitmqctl add_user admin admin "创建用户（username password）"
#sudo rabbitmqctl set_user_tags admin administrator "配置用户为超级管理员"
#sudo rabbitmqctl set_permissions -p ‘/‘ admin ‘.‘ ‘.‘ ‘.‘ " 配置权限"
#sudo brew services restart rabbitmq #sudo pip install pika# -*- coding:utf-8 -*-
import pika
class RabbitMQ(object):
"""一个简单的RabbitMQ的库，为了学习"""
def __init__(self,host,port=5672,username=None,password=None):
if host == None:
raise Exception("Host is None")
if username != None and password != None:
try:
self.Credentials = pika.PlainCredentials(username,password)
self.ConnectionKeys = pika.ConnectionParameters(host,port,‘/‘,self.Credentials)
except Exception:
raise
else:
self.ConnectionKeys = None
def _connection(self):
try:
if self.ConnectionKeys == None:
self.connection = pika.BlockingConnection()
else:
self.connection = pika.BlockingConnection(self.ConnectionKeys)
except Exception:
raise
def _channel(self):
self.channel = self.connection.channel()
def _callback(channel,method,properties,body):
return body
def connect(self):
self._connection()
self._channel()
def create_queque(slef,flag,durableflag=False):
try:
self.channel.queue_declare(queue=flag,durable=durableflag)
except Exception:
raise
def product(self,flag,content,exchange=‘‘):
try:
self.channel.basic_publish(exchange=‘‘,routing_key=flag,body=content)
except Exception:
raise
def consume(slef,flag,ackflag):
try:
self.channel.basic_consume(self._callback,queue=flag,no_ack=ackflag)
except Exception:
raise
def close(self):
try:
self.connection.close()
except Exception:
raiseRabbitMQ的安装和使用Python连接RabbitMQ
标签：rabbitmq dmi password queue callback close 2.7 一个 back
原文地址：https://www.cnblogs.com/KevinGeorge/p/9072632.html
