首頁(yè) 猿問(wèn) 消息隊(duì)列中的消息是并行執(zhí)行的，消息...

消息隊(duì)列中的消息是并行執(zhí)行的，消息之間有順序依賴(lài)怎么辦？

JavaScript

四季花海 2019-04-16 20:27:55

之前發(fā)的貼子沒(méi)說(shuō)明白，重新發(fā)吧。此例只用于說(shuō)明異步消息并行執(zhí)行時(shí)會(huì)出現(xiàn)的問(wèn)題。這里用評(píng)論微博來(lái)舉例好了。A評(píng)論B后，會(huì)給B發(fā)異步通知，然后A刪除評(píng)論時(shí)，會(huì)異步刪除這個(gè)通知。問(wèn)題：消息隊(duì)列中有兩個(gè)消息：發(fā)通知和刪除通知，由于有并發(fā)（多個(gè)消費(fèi)者），可能先執(zhí)行的是刪除通知，然后再執(zhí)行發(fā)通知

查看完整描述

2 回答

HUH函數(shù)

TA貢獻(xiàn)1836條經(jīng)驗(yàn) 獲得超4個(gè)贊

目前有兩種方案：方案一：當(dāng)刪除評(píng)論時(shí)，檢查一下評(píng)論對(duì)應(yīng)的消息是否存在，如果不存在，那retry(Pythoncelery支持)一次方案二：大部分情況下，只有同一用戶(hù)的異步消息會(huì)產(chǎn)生順序依賴(lài)，所以按用戶(hù)id做hash，保證同一用戶(hù)進(jìn)入同一隊(duì)列，并且每個(gè)隊(duì)列只有一個(gè)消費(fèi)者。不過(guò)，由于每個(gè)隊(duì)列只有一個(gè)消費(fèi)者，隨著用戶(hù)量的增加，就要在broker中創(chuàng)建越來(lái)越多的隊(duì)列，當(dāng)然，我們可以使用多個(gè)broker

反對(duì) 回復(fù) 2019-04-16

叮當(dāng)貓咪

TA貢獻(xiàn)1776條經(jīng)驗(yàn) 獲得超12個(gè)贊

假如是Kafka的多partition/RocketMQ的多messagequeue，如果要求強(qiáng)順序性的，其中一個(gè)方案：可以考慮將發(fā)送的消息帶上時(shí)間戳，在消費(fèi)端把消息添加到一個(gè)分布式的redis有序集合，根據(jù)這個(gè)時(shí)間戳來(lái)排序取出來(lái)，就可以做到消息有序性；另一個(gè)方案是將消息放入一個(gè)partition/messagequeue，因?yàn)閱蝹€(gè)partition/messagequeue是消息有序性的

反對(duì) 回復(fù) 2019-04-16