简单RabbitMQ消费框架
rabbitleap的Python项目详细描述
兔跃
rabbitleap是一个简单的rabbitmq消费框架。它构建在pika之上，pika是一个rabbitmq的python客户端库。
功能
- 自动从连接失败中恢复
- 处理失败的可配置重试策略
- 根据自定义逻辑和不同的消息属性自动将消息路由到处理程序
安装
$ pip install rabbitleap
你好，世界
fromrabbitleap.consumerimportConsumerfromrabbitleap.handlingimportMessageHandlerclassRabbitEatHandler(MessageHandler):defhandle(self):print('rabbit eat: {}'.format(self.envelope.payload.decode('utf-8')))consumer_queue_name='consumer_queue'amqp_url=r'amqp://guest:guest@localhost:5672/%2f'consumer=Consumer(amqp_url=amqp_url,queue_name=consumer_queue_name)# route message of type `rabbit.eat` to RabbitEatHandlerconsumer.add_handler(r'rabbit\.eat',RabbitEatHandler)try:consumer.start()exceptKeyboardInterrupt:consumer.stop()
文件
欢迎加入QQ群-->： 979659372
