第四章：消息队列在高并发中的应用

4.1 削峰填谷实现

4.1.1 Kafka 消费者组配置

# consumer.properties
group.id=order-group
auto.offset.reset=earliest
enable.auto.commit=false
max.poll.records=100

4.1.2 消息积压处理

1. 消费者端优化

   	// 批量处理消息
   	while (true) {
   	    ConsumerRecords<String, String> records = consumer.poll(Duration.ofMillis(100));
   	    for (ConsumerRecord<String, String> record : records) {
   	        process(record.value());
   	    }
   	    consumer.commitAsync();
   	}
   

2. 增加消费者实例

   	# 扩容消费者组实例数
   	docker-compose scale consumer=5
   

4.1.3 死信队列设计（RabbitMQ 示例）

// 声明死信队列
QueueBuilder.durable("dlq")
    .withArgument("x-dead-