消息队列

消息队列

RabbitMQ 完全指南

RabbitMQ 是基于 AMQP 协议的消息代理，以灵活的路由能力和低延迟著称。 pika.ConnectionParameters 参数： channel.exchange_declare 参数： channel.queue_declare 参数： channel.basic_publish 参数： pika.BasicProperties 常用字段： channel.basic_consume 参数： 防止某个消费者堆积过多未处理消息： aio_pika.connect_robust 参数： connect_robust 与 connect 的区别

消息队列

Kafka 完全指南

Apache Kafka 是一个分布式流处理平台，以高吞吐量、持久化存储和消息回放著称。 KafkaProducer 参数： producer.send 参数： KafkaConsumer 参数： acks 控制生产者认为消息发送成功所需的 Broker 确认数量： 生产环境金融/订单类消息应使用 acks="all" + retries=3。 注意：auto_offset_reset 只在该 Consumer Group 从未提交过 offset 时生效（新 group 或 offset 已过期被删除）。已有提交记录的情况下，从上次提交的 offset