Python3 通过 kombu 连接 RabbitMQ 的基本用法
#encoding: utf-8#author: walker
#date: 2018-03-09
#summary: 发送方/生产者
import os, sys, time
from kombu import Connection
def Main():
with Connection('amqp://test:test@192.168.0.xx:5672/vhosttest') as conn:
with conn.channel() as channel:
#producer = Producer(channel)
producer = channel.Producer()
while True:
message = time.strftime('%H:%M:%S', time.localtime())
producer.publish(
body=message,
retry=True,
exchange='exchangetest',
routing_key='rkeytest'
)
print('send message: %s' %message)
while True:
# 检查队列，以重新得到消息计数
queue = channel.queue_declare(queue='queuetest', passive=True)
messageCount = queue.message_count
print('messageCount: %d' % messageCount)
if messageCount < 100:
break
time.sleep(1)
if __name__ == '__main__':
Main()
页:
[1]