1.服务挂掉

  1. 设置mq的storeUsage为1M,生产者不断发送持久化消息,消费者每隔5秒接收1条消息。
    在达到配置的使用限制后,broker会停止producer。此时生产者阻塞,但消费者可正常连接并消费消息,等消息消费掉一部分,文件删除又腾出空间之后,生产者又可继续发送消息,服务自动恢复正常。activeMQ控制台输出如下:
    1
    2
    3
    4
    5
    jvm 1    |  INFO | Usage(default:store:queue://myQueue:store) percentUsage=99%, usage=1054753, limit=1048576,
    percentUsageMinDelta=1%;Parent:Usage(default:store) percentUsage=100%, usage=1054753, limit=1048576, percentUs
    ageMinDelta=1%: Persistent store is Full, 100% of 1048576. Stopping producer (ID:QINCD125-D-11620-155298730527
    6-1:1:1:1) to prevent flooding queue://myQueue. See http://activemq.apache.org/producer-flow-control.html for
    more info (blocking for: 32s)

第一次是2s,第二次是32s,后面每次增加30s。