rabbitmq使用示例

inqueue.py

from librabbitmq import Connection

rconf = {
  "host": "localhost",
  "userid": "guest",
  "password": "guest",
  "vhost": "/",
  "exchange": "kong",
  "extype": "direct"
}

connection = Connection(
  host=rconf["host"],
  virtual_host=rconf["vhost"],
  userid=rconf["userid"],
  password=rconf["password"])
channel = connection.channel()
channel.exchange_declare(exchange=rconf["exchange"], type=rconf["extype"])
channel.basic_publich(
  exchange=rconf["exchange"],
  routing_key=routing,
  body=str(body),
  delivery_mode=2) # delivery_mode=2与durable对应

outqueue.py

from librabbitmq import Connection

connection = Connection(
  host=rconf["host"],
  virtual_host=rconf["vhost"],
  userid=rconf["userid"],
  password=rconf["password"])
channel = connection.channel()

channel.exchange_declare(exchange=rconf["exchange"], type=rconf["extype"])
channel.queue_declare(queue="queue_name", durable=True) # durable=True将消息进行持久化
channel.queue_bind(exchange=rconf["exchange"], queue="queue_name",
                   routing_key=routing)
channel.basic_qos(prefetch_count=1)
channel.basic_consume(callback=callback,
                      queue="queue_name") # 若加参数no_ack=True，则若某worker在处理消息时，worker挂掉，则信息会丢失
while True:
  connection.drain_events()
  
def callback(message):
  params = ast.literal_eval(str(message.body))
  print params
  message.ack()