2. ⽤单独的⼀个线程来完成 MQ 消息的推送
3. options.setMaxInflight(1000) 增加 actualInFlight 的值;
题外话
笔者出现这个错误是因为使⽤ EventBus, 之前使⽤单独线程的 Handler 是没有问题的, 调查发现, 使⽤ EventBus 是新建线程运⾏的, ⽽ Handler 是单独⼀个线程.
pending所以当发送⼤量消息的时候, EventBus ⼏乎是同⼀个点发出去, 就会造成这个错误

版权声明：本站内容均来自互联网，仅供演示用，请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系QQ:729038198，我们将在24小时内删除。