草庐IT

图文并茂!深入了解RocketMQ的过期删除机制

大家好,我是Leo。今天聊一下RocketMQ的文件过期删除机制本章概括源码定位Broker是RocketMQ的核心,提供了消息的接收,存储,拉取等功能我们可以先从Broker服务入手。从源码可以得知。RocketMQ启用了一个​​BrokerController​​​的​​start​​函数publicstaticvoidmain(String[]args){start(createBrokerController(args));}publicstaticBrokerControllerstart(BrokerControllercontroller){try{controller.star

图文并茂!深入了解RocketMQ的过期删除机制

大家好,我是Leo。今天聊一下RocketMQ的文件过期删除机制本章概括源码定位Broker是RocketMQ的核心,提供了消息的接收,存储,拉取等功能我们可以先从Broker服务入手。从源码可以得知。RocketMQ启用了一个​​BrokerController​​​的​​start​​函数publicstaticvoidmain(String[]args){start(createBrokerController(args));}publicstaticBrokerControllerstart(BrokerControllercontroller){try{controller.star