Rabbit MQ消息工具(生产者、消费者封装)。
Project description
使用手册
快速开始
- 生产者
import rabbitplus
producer = rabbitplus.RabbitProducer("docker.kancy.top", "root", "root123")
producer.putQueue("test", "pika.test.queue")
# 注册交换机
producer.registerExchange("pika.test.exchange", 'direct')
# 注册队列
producer.registerQueue("pika.test.queue", durable=True)
# 绑定交换机很队列
producer.bind("pika.test.exchange", "pika.test.queue")
- 消费者
import rabbitplus
def handle_message(data, **kwargs):
print(kwargs)
consumer = rabbitplus.RabbitConsumer("docker.kancy.top", "root", "root123")
consumer.onListener("pika.test.queue", callback=handle_message)
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
rabbitplus-0.0.1.tar.gz
(5.5 kB
view hashes)
Built Distributions
rabbitplus-0.0.1-py3.9.egg
(7.4 kB
view hashes)
Close
Hashes for rabbitplus-0.0.1-py2.py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 56c29bd43370d7c15649861d15497b8b0be015a66f3a17b47c4af815c5e52788 |
|
MD5 | 06795a8c22486120810ba1aea34f04b4 |
|
BLAKE2b-256 | d5277c68ecbb925e22bbd487eae00e2b2c4c696d4e93c381167bc6f316e0b8ff |