python划水吧 关注:4贴子:17
  • 1回复贴,共1

基于RabbitMQ搭建的流式数据处理系统开发心得

只看楼主收藏回复

消息收发
.
1. 发送消息:basic_publish
2. 消费消息:basic_comsume
.
.
队列创建
.
1. 创建交换机:exchange_declare
2. 创建队列:queue_declare
3. 绑定交换机与队列:queue_bind(exchange, queue)


IP属地:广东1楼2025-11-09 19:17回复
    pika模块中常用的类
    .
    1. Connection(具体是BlockingConnection)
    2. Channel(exchange_declare、queue_declare、queue_bind函数都是它的方法函数)


    IP属地:广东2楼2025-11-09 19:24
    回复