Golang实现生产者-消费者的(N:1)模型

1. 目标模型#

• 多个生产者对应一个消费者，即 N:1
• 消费者处理生产者发送过来的消息时是并行处理的，但是有速率限制，最大为5qps
• 消费者处理完了某个生产者的消息后，通知对应的生产者
• 当某个生产者发送的所有消息都收到处理完成的消息后，执行后续逻辑

2. 实现分析#

根据上面的条件，可知：

• 需要开启goroutine来实现并发处理
• 使用带缓存的channel控制并发量
• 使用for-select结构实现挂起等待
• 使用单独的channl实现通知机制
• 使用sync.WaitGroup保证goroutine执行完成

3. 代码实现#

3.1 初始变量#

3.2 生产者#

3.3 消费者#

3.4 主函数#

3.5 运行结果#

根据时间间隔可知，实现了一秒钟最多运行5个go协程