watchman

watchman copied to clipboard

看代码的疑惑？

1

在 setupChannel函数中 err = channel.Qos(1, 0, false) 在这里设置的 prefechtCount为1 那么当单条消息未ACK的时候，是无法consumer下一条消息的 因此 receiveMessage 中，获取消息的速度其实还是收到了消费的影响，未能实现真正的高并发消费

zt3862266