Open scue opened 5 years ago
https://linkscue.com/2018/12/08/2018-12-08-aggregate-queue-golang/
Linux内核大概只有100万次每秒的收发网络数据包的能力，如果需要突破这个限制，那么在客户端发送消息的时候，需要将消息按一定的时间进行聚合再上报，那么如何实现一个像以下需求的消息队列呢？ 没有消息时一直阻塞，避免CPU消耗 一旦有消息的时候，只从消息队列里边取最多1秒的数据 或者，一旦有足够消息数量的时候，立即返回
https://linkscue.com/2018/12/08/2018-12-08-aggregate-queue-golang/
Linux内核大概只有100万次每秒的收发网络数据包的能力，如果需要突破这个限制，那么在客户端发送消息的时候，需要将消息按一定的时间进行聚合再上报，那么如何实现一个像以下需求的消息队列呢？ 没有消息时一直阻塞，避免CPU消耗 一旦有消息的时候，只从消息队列里边取最多1秒的数据 或者，一旦有足够消息数量的时候，立即返回