RocketMQListener完整的手动消费者管理

文章目录引言优点使用方法I 应用启动完成后启动消费者application.yml手动管理生命周期，实现自动重连确保在整个应用生命周期中只创建和使用一个 DefaultMQPushConsumer实例【优化版本】II RocketMQ连接健康检查端点-可选III 健康检查 - 可选引言优点不阻塞启动：即使RocketMQ不可用，应用也能正常启动自动重连：后台自动重试连接，直到成功状态可监控：可以通过接口查看消费者状态可手动控制：支持手动重启消费者优雅关闭：应用关闭时自动清理资源使用方法启动应用：应用启动时会自动开始连接RocketMQ自动重试：如果连接失败，会按照配置的重试间隔自动重试状态检查：访问 /rocketmq/status查看消费者状态手动重启：访问 /rocketmq/restart手动重启消费者健康检查：Spring Boot Actuator的 /actuator/health端点会显示RocketMQ状态I 应用启动完成后启动消费者通过ApplicationListenerApplicationReadyEvent在应用启