RocketMQ消費者啟動報錯(防止第二次啟動-線程堵塞 可以正常1v1)


com.alibaba.rocketmq.client.exception.MQClientException: The PushConsumer service state not OK, maybe started once, RUNNING
 
 出現的業務場景:1生產1消費,消費者啟動后沒有關閉然后再次啟動,報錯信息出現
 
解決:全局定義一個變量狀態,boolean flag,如果為true就改變


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM