scheduleAtFixedRate(new Runnable() { @Override public void run() { try { samplingInSeconds(); } catch (Throwable ignored) { } } }, 0, 10, TimeUnit.SECONDS); // 省略其他代码 } 原来在创建一个新的 StatsItem 的时候，就会启动一个定时任务，每隔 brokerController.getSendThreadPool Queue().size())); } } else { break; } } else { break; } } catch (Throwable ignored) { } } 可以看出来，抛出这种错误，在 broker 还没有发送“严重”的 pagecache 繁忙， 即消息追加到内存中的最大时延没有超过 1s，通常追加是很快的，绝大部分都会低于 sendResult = producer.send(msg); System.out.printf("%s%n", sendResult); producer.shutdown(); } catch (Throwable e) { e.printStackTrace(); } } } 本文来自『中间件兴趣圈』公众号，仅作技术交流，未授权任何商业行为。 1.14 RocketMQ msgId 与 offsetMsgId