這篇文章將為大家詳細(xì)講解有關(guān)MongoDB為什么會(huì)更新失敗,小編覺得挺實(shí)用的,因此分享給大家做個(gè)參考,希望大家閱讀完這篇文章后可以有所收獲。
創(chuàng)新互聯(lián)致力于互聯(lián)網(wǎng)品牌建設(shè)與網(wǎng)絡(luò)營銷,包括網(wǎng)站設(shè)計(jì)、成都網(wǎng)站制作、SEO優(yōu)化、網(wǎng)絡(luò)推廣、整站優(yōu)化營銷策劃推廣、電子商務(wù)、移動(dòng)互聯(lián)網(wǎng)營銷等。創(chuàng)新互聯(lián)為不同類型的客戶提供良好的互聯(lián)網(wǎng)應(yīng)用定制及解決方案,創(chuàng)新互聯(lián)核心團(tuán)隊(duì)十載專注互聯(lián)網(wǎng)開發(fā),積累了豐富的網(wǎng)站經(jīng)驗(yàn),為廣大企業(yè)客戶提供一站式企業(yè)網(wǎng)站建設(shè)服務(wù),在網(wǎng)站建設(shè)行業(yè)內(nèi)樹立了良好口碑。
現(xiàn)象:
WriteResult res = mongoTemplate.updateFirst(query, updateObj, "ServerToAgentReq_SMS");
獲取res.getN()返回值時(shí),發(fā)現(xiàn)偶爾情況下該返回值為0,表示該更新操作沒有更新到任何數(shù)據(jù)。并且如果是多線程并發(fā)更新,失敗幾率大大提高。
官網(wǎng)表示不能保證更新操作的成功性....
方案:
一次失敗后,另起線程多次重試。
private ThreadPoolExecutor exec = new ThreadPoolExecutor(2, 10, 3, TimeUnit.SECONDS, new ArrayBlockingQueue(10), new ThreadPoolExecutor.CallerRunsPolicy()); 主要代碼: WriteResult res = mongoTemplate.updateFirst(query, updateObj, "ServerToAgentReq_SMS"); //如果更新失敗,進(jìn)入其他線程重試更新 if (res.getN() == 0) { exec.execute(new Runnable() { @Override public void run() { int num = 0; WriteResult res = mongoTemplate.updateFirst(query, updateObj, "ServerToAgentReq_SMS"); while (res.getN() == 0 && num < 100) { res = mongoTemplate.updateFirst(query, updateObj, "ServerToAgentReq_SMS"); num++; try { Thread.sleep(300); } catch (InterruptedException e) { logger.error("響應(yīng)更新失敗{}", e); } } if (res.getN() == 0) { logger.error("響應(yīng)更新失敗!!!gwMsgId:{},masMsgId:{}", gwMsgId, masMsgId); } } });
如此失敗率,大大減少。
關(guān)于mongodb為什么會(huì)更新失敗就分享到這里了,希望以上內(nèi)容可以對大家有一定的幫助,可以學(xué)到更多知識(shí)。如果覺得文章不錯(cuò),可以把它分享出去讓更多的人看到。