आपका message queue at least once delivery की गारंटी देता है। आप जो consumer लिखेंगे, उसके लिए इसका क्या मतलब है?

मतलब यह कि duplicates सामान्य बात हैं, अपवाद नहीं, इसलिए आपके consumer को idempotent होना ही पड़ेगा। message से एक स्थिर key निकालें, processed keys को उसी ट्रांजैक्शन में लिखें जिसमें असर होता है, और दोहराव को no op मानें। साथ ही out of order delivery की उम्मीद रखें, और यह भी कि काम करने और acknowledge करने के बीच crash होने पर redelivery होगी। सिस्टम्स के आर पार exactly once जैसा कुछ होता नहीं; आपको at least once मिलता है, और उसके साथ idempotent handling करनी होती है।

इसका मतलब है वही message मुझे दो बार मिलेगा, आमतौर पर इसलिए कि consumer ने काम कर लिया और acknowledge करने से पहले मर गया, तो broker ने दोबारा भेज दिया। इसलिए consumer को एक ही input पर दो बार चलने लायक सुरक्षित होना चाहिए। व्यवहार में मैं message से एक स्थिर id लेता हूं, और जब असर लिखता हूं तो उसी डेटाबेस ट्रांजैक्शन में processed id भी लिखता हूं, एक unique constraint के साथ। अगर insert conflict करता है तो मुझे पता चल जाता है कि मैं इसे पहले ही संभाल चुका हूं और मैं काम दोहराए बिना acknowledge कर देता हूं। सबसे अहम बात यह है कि dedupe record और असर एक साथ commit हों; अलग अलग लिखूं तो एक ऐसा झरोखा बचता है जहां duplicate हो सकता है। मैं यह भी मानकर चलता हूं कि ordering की गारंटी नहीं है, इसलिए handlers ऐसे लिखे जाते हैं कि create से पहले update आ जाए तो भी चल जाए, आमतौर पर entity पर key लगाकर और version जांचकर। नाकामी पर मैं exponential backoff और jitter के साथ सीमित retry करता हूं, फिर alert वाली dead letter queue, क्योंकि किसी poison message को चुपचाप हमेशा retry करते रहना ही वह तरीका है जिससे रात भर में queue भर जाती है।