3 代码实战
- 自定义Con
- Con
- Pro
- 启动Con,查看管控台
- 启动Pro,开始发送消息,Con接收消息
- 实现限流,仅仅处理一条消息,其余的都在等待
- 现在,我们开启ACK应答处理
- 重新启动Con,发现剩余的2条消息也全都发送并接收了!
我们之前是注释掉手工ACK方法,然后启动消费端和生产端,当时Con只打印一条消息,这是因为我们设置了手工签收,并且设置了一次只处理一条消息,当我们没有回送ACK应答时,Broker端就认为Con还没有处理完这条消息,基于这种限流机制就不会给Con发送新的消息了,所以Con那时只打印了一条消息