semvec/pypi-packages huggingface dataset:
mqplus 0.0.2
MQ消息工具（生产者、消费者封装）。
License: MIT
Requires Python: >=3


### 使用手册

**快速开始**

1) 生产者
```python
import mqplus

producer = mqplus.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")

```

2) 消费者
```python
import mqplus

def handle_message(data, **kwargs):
    print(kwargs)

consumer = mqplus.RabbitConsumer("docker.kancy.top", "root", "root123")
consumer.onListener("pika.test.queue", callback=handle_message)

```
rabbitplus 0.0.1
Rabbit MQ消息工具（生产者、消费者封装）。
License: MIT
Requires Python: >=3


### 使用手册

**快速开始**

1) 生产者
```python
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")

```

2) 消费者
```python
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)

```
kafkaplus 0.0.1
Kafka操作工具。
License: MIT
Requires Python: >=3


### 使用手册

**快速开始**

1）生产者
```python
import kafkaplus

producer = kafkaplus.getProducer("localhost:9092")
# 发送一条消息
producer.send("test_topic", "data-a")

# 同步发送一条消息
producer.sendSync("test_topic", "data-b")

# 批量发送消息
producer.sendBatch("test_topic", "data1", "data2", "data3")
```

2）消费者
```python
import kafkaplus

# 接收消息的回调函数
def callback(data, **kwargs):
    print(data)
    print(kwargs)

consumer = kafkaplus.getConsumer("localhost:9092")
# 监听topic，使用回调函数处理消息
consumer.onListener("test_topic",group="G-test",callback=callback)
```