Files
Hui-s-notebook/logseq-java/pages/消息堆积.md
2024-02-02 00:12:49 +08:00

414 B

  • 生产者发送消息的速度超过消费者处理消息的速度,导致队列中的消息堆积
  • 增加更多消费者,提高消费速度
  • 消费者内开启线程池加快消息处理速度
  • 扩大队列容积,提高堆积上限
    • 惰性队列
      • 接收消息存入磁盘而非内存呢
      • 消费者消费时才从磁盘加载到内存
      • 支持百万条消息存储
      • 配置时开启lazy属性