| 12345678910 |
- # 先启动消费者：
- python consumer_priority.py
- # 再启动生产者，按不同优先级丢消息： (在测试中, 这样发送是不行的, 因为消息没有积压, 数据量不够, 但是是正常现象, 在正常生产环境中, 这个是对的)
- python producer_priority.py 1 "low"
- python producer_priority.py 9 "urgent"
- python producer_priority.py 5 "medium"
- # 为了测试, 使用批量发送
- python batch_priority.py
|
