rabbitmq和celery故障解決
待服務(wù)商報(bào)價(jià)
故障排查
需求類型
## 問(wèn)題
rabbitmq容器出現(xiàn)網(wǎng)頁(yè)能打開(kāi),登錄不了. pika客戶端斷開(kāi)連接, 也無(wú)法連接上. 重啟后就好了.
出現(xiàn)次數(shù)2次, 一次本地開(kāi)發(fā)出現(xiàn),沒(méi)注意, 一次服務(wù)器出現(xiàn). 也無(wú)法復(fù)現(xiàn)問(wèn)題.
消息發(fā)送100條左右. 看日志有Restarting crashed queue 'celery' in vhost.
需要復(fù)現(xiàn)這個(gè)問(wèn)題和解決問(wèn)題.
## 架構(gòu)
1.pika做生產(chǎn)者,監(jiān)聽(tīng)mqtt的消息發(fā)送到rabbitmq, 1個(gè)連接
2.docker啟動(dòng)rabbitmq容器,官方命令,映射了本地目錄到容器
3.celery做消費(fèi)者, 1個(gè)工作者,2個(gè)線程, 500個(gè)任務(wù)重啟下線程
celery -A config.celery worker --pool=threads --concurrency=2 -l INFO
## 嘗試
1. 連續(xù)發(fā)送消息1000條沒(méi)出現(xiàn)問(wèn)題
2. 創(chuàng)建1025個(gè)連接沒(méi)出現(xiàn)問(wèn)題. 默認(rèn)是100萬(wàn)個(gè)連接. 并且出問(wèn)題的日志里連接記錄也是1千多個(gè)
進(jìn)行中 2025-03-12發(fā)布
招標(biāo)-按項(xiàng)目付費(fèi)