بالضبط مرة واحدة مقابل مرة واحدة على الأقل

1) لماذا حتى مناقشة الدلالات

• على الأكثر مرة واحدة - بدون تكرار، لكن الخسارة ممكنة (نادرًا ما تكون مقبولة).
• مرة واحدة على الأقل - لا تخسر، ولكن التكرارات ممكنة (التخلف عن معظم الوسطاء/قوائم الانتظار).
• مرة واحدة بالضبط - تتم معالجة كل رسالة مرة واحدة بالضبط من حيث التأثير الملاحظ.

الحقيقة الأساسية: في عالم موزع بدون معاملات عالمية واتساق متزامن، لا يمكن تحقيق «نظيف» من طرف إلى طرف مرة واحدة بالضبط. نحن نبني بشكل فعال مرة واحدة بالضبط: نسمح بالتكرار في النقل، لكننا نجعل المعالجة خفية بحيث يكون التأثير الملحوظ «كما لو كان مرة واحدة».

2) نمط الفشل وحيث تحدث نسخ مكررة

• Losses ack/commission (المنتج/السمسار/المستهلك «لم يسمع» تأكيد).
• إعادة انتخاب القادة/النسخ المتماثلة، التعافي بعد انقطاع الشبكة.
• التوقيت/التراجع في أي منطقة (kliyent→broker→konsyumer→sink).

النتيجة: لا يمكنك الاعتماد على «تفرد التسليم» للنقل. إدارة التأثيرات: الكتابة إلى قاعدة البيانات، وخصم الأموال، وإرسال رسالة، وما إلى ذلك.

3) مرة واحدة بالضبط في مقدمي الخدمة وما هو حقًا

3. 1 كافكا

• المنتج اللطيف ('enable. idempotence = true ') - يمنع التكرار من جانب المنتج عند التراجع.
• المعاملات - تنشر الرسائل بشكل ذري على عدة دفعات وتلتزم بتعويضات الاستهلاك (نمط القراءة وعملية الكتابة بدون «ثغرات»).
• ضغط - يخزن القيمة الأخيرة حسب المفتاح.

لكن «نهاية السلسلة» (الحوض: DB/الدفع/البريد) لا تزال تتطلب الخصوصية. خلاف ذلك، فإن ضعف المعالج سيؤدي إلى ضعف التأثير.

3. 2 NATS/Rabbit/SQS

الافتراضي هو مرة واحدة على الأقل مع ack/إعادة التسليم. يتم تحقيق مرة واحدة بالضبط على مستوى التطبيق: المفاتيح، المتجر، المزعج.

الاستنتاج: النقل مرة واحدة بالضبط ≠ تأثير مرة واحدة بالضبط. هذا الأخير يتم في المعالج.

4) كيفية البناء بشكل فعال مرة واحدة على الأقل

4. 1 مفتاح الخصوصية

• الشيكات «شوهدت بالفعل ؟» - Dedup-stor (Redis/DB) مع TTL/Retsch.
• إذا رأيت، يكرر النتيجة المحسوبة مسبقًا أو لا.

lua
-- SET key if not exists; expires in 24h local ok = redis.call("SET", KEYS[1], ARGV[1], "NX", "EX", 86400)
if ok then return "PROCESS" else return "SKIP" end

4. 2 Upsert in base (idempotent cink)

يتم إجراء الإدخالات عبر UPSERT/ON FRABIC مع التحقق من النسخة/المبلغ.

sql
INSERT INTO payments(id, status, amount, updated_at)
VALUES ($1, $2, $3, now())
ON CONFLICT (id) DO UPDATE
SET status = EXCLUDED.status,
updated_at = now()
WHERE payments.status <> EXCLUDED.status;

4. 3 صندوق المعاملات الخارجي/صندوق الوارد

Outbox: تحدث معاملة تجارية وإدخال حدث للنشر في نفس معاملة قاعدة البيانات. يقرأ ناشر الخلفية صندوق الخروج ويرسل إلى الوسيط → لا يوجد تناقض بين الدولة والحدث.
Inbox: للأوامر الواردة، احفظ 'message _ id' والنتيجة قبل التنفيذ ؛ إعادة المعالجة ترى السجل ولا تكرر الآثار الجانبية.

4. 4 التجهيز المتسق للسلسلة (read→process→write)

كافكا: الصفقة «اقرأ التعويض → وكتبت نتائج → الالتزام» في كتلة ذرية واحدة.
بدون معاملات: «أولاً اكتب النتيجة/Inbox، ثم ack» ؛ مع الاصطدام، سترى النسخة المكررة Inbox وتنتهي بعدم وجود عملية.

4. 5 SAGA/تعويضات

عندما يكون الخمول مستحيلًا (قام المزود الخارجي بشطب الأموال)، فإننا نستخدم العمليات التعويضية (استرداد/فراغ) وواجهات برمجة التطبيقات الخارجية الغبية (تعطي "POSt' المتكررة مع نفس" مفتاح الخصوصية "نفس النتيجة).

5) عندما يكفي مرة واحدة على الأقل

تحديث المخابئ/الآراء المجسدة مع ضغط قائم على المفاتيح.
العدادات/المقاييس حيث تكون إعادة الزيادة مقبولة (أو تخزين الدلتا مع النسخة).
الإشعارات حيث الحرف الثانوي ليس حرجًا (من الأفضل وضع مفتاح على أي حال).

القاعدة: إذا لم يغير المزدوج معنى العمل أو يمكننا بسهولة العثور على → مرة واحدة على الأقل + حماية جزئية.

6) الأداء والتكلفة

مرة واحدة بالضبط (حتى «بشكل فعال») تكلف أكثر: السجلات الإضافية (Inbox/Outbox)، وتخزين المفاتيح، والمعاملات، والتشخيص أكثر صعوبة.
مرة واحدة على الأقل أرخص/أبسط، أفضل في الإنتاجية/p99.
تقييم: سعر ضعف × احتمال مضاعفة مقابل تكلفة الحماية.

7) تكوينات العينة والرمز

7. 1 منتج كافكا (idempotence + transfers)

properties enable.idempotence=true acks=all retries=INT_MAX max.in.flight.requests.per.connection=5 transactional.id=orders-writer-1

java producer.initTransactions();
producer.beginTransaction();
producer.send(recordA);
producer.send(recordB);
// также можно atomically commit consumer offsets producer.commitTransaction();

7. 2 وحدة تحكم Inbox (رمز زائف)

pseudo if (inbox.exists(msg.id)) return inbox.result(msg.id)
begin tx if!inbox.insert(msg.id) then return inbox.result(msg.id)
result = handle(msg)
sink.upsert(result)     # идемпотентный синк inbox.set_result(msg.id, result)
commit ack(msg)

7. 3 HTTP Idempotency-Key (APIs الخارجية)

POST /payments
Idempotency-Key: 7f1c-42-...
Body: { "payment_id": "p-123", "amount": 10.00 }

تكرار POST بنفس المفتاح → نفس النتيجة/الحالة.

8) إمكانية الرصد والمقاييس

«duplicate _ traits _ total» - كم مرة تم القبض على مزدوج (وفقًا لـ Inbox/Redis).
«الخصوصية _ الضربة _ المعدل» - نسبة التكرار «المحفوظة» بسبب الخصوصية.
«txn _ abort _ rate» (كافكا/DB) - حصة التراجع.
«outbox _ backlog» - تأخر النشر.
'exactly _ once _ path _ latency {p95, p99}' مقابل 'على الأقل _ مرة واحدة _ المسار _ الكمون' - فوق.
سجلات التدقيق: مجموعة من "رسالة _ معرف"، "idempotency _ key"، "saga _ id'،" محاولة ".

9) كتب اللعب التجريبية (أيام اللعبة)

إرسال إعادة: يعيد المنتج صورته مع مهلة اصطناعية.
الاصطدام بين «الحوض و ack»: تأكد من أن Inbox/Upsert يمنع الضعف.
إعادة التسليم: زيادة إعادة التسليم في السمسرة ؛ فحص التخلص.
فراغ واجهات برمجة التطبيقات الخارجية: تكرار POST بنفس المفتاح هو نفس الإجابة.
تغيير الرصاص/استراحة الشبكة: تحقق من معاملات كافكا/سلوك المستهلكين.

10) الأنماط المضادة

اعتمد على النقل: «لدينا كافكا مرة واحدة بالضبط، لذا يمكنك بدون مفاتيح» - لا.
ack no-op قبل التسجيل: ackled ولكن الحوض انخفض → الخسارة.
عدم وجود تراجعات DLQ/jitter: إعادة لا نهاية لها وعاصفة.
UUIDs العشوائية بدلاً من المفاتيح الطبيعية: لا شيء للتثبيت.
خلط Inbox/Outbox مع جداول الإنتاج الخالية من المؤشرات: الأقفال الساخنة وذيول p99.
المعاملات التجارية بدون واجهة برمجة تطبيقات خفية في مقدمي الخدمات الخارجيين.

11) قائمة الاختيار المرجعية

1. السعر المزدوج (المال/القانوني/UX) مقابل سعر الحماية (الكمون/التعقيد/التكلفة).
2. هل هناك مفتاح حدث/عملية طبيعي ؟ إذا لم يكن الأمر كذلك، فابتكر واحدة مستقرة.
3. الحوض يدعم Upsert/الإصدار ؟ خلاف ذلك - Inbox + التعويض.
4. هل تحتاج إلى معاملات عالمية ؟ إذا لم يكن الأمر كذلك، فقسم إلى SAGA.
5. هل تحتاج إلى إعادة/احتفاظ طويل ؟ كافكا + Outbox. هل تحتاج إلى RPC سريع/زمن انتقال منخفض ؟ NATS + Idempotency-Key.
6. تعدد الحيازات والحصص: عزل المفتاح/الفضاء.
7. إمكانية الملاحظة: أُدرجت مقاييس الخصوصية والمتراكمة.

12) الأسئلة الشائعة

س: هل من الممكن تحقيق «رياضي» مرة واحدة بالضبط من طرف إلى طرف ؟

ج: فقط في سيناريوهات ضيقة مع متجر ومعاملات متسقة واحدة على طول الطريق. وفي الحالة العامة، لا ؛ تستخدم بشكل فعال مرة واحدة بالضبط من خلال الخصوصية.

س: أيهما أسرع ؟

ج: مرة واحدة على الأقل. مرة واحدة بالضبط تضيف المعاملات/ → تخزين المفاتيح فوق p99 والتكلفة.

س: أين تخزن مفاتيح الاختصاص ؟

ج: توقف سريع (Redis) باستخدام TTL، أو جدول Inbox (PK = message _ id). بالنسبة للمدفوعات - أطول (أيام/أسابيع).

س: كيف تختار مفاتيح تسريح TTL ؟

ج: الحد الأدنى = الحد الأقصى لوقت إعادة التسليم + هامش التشغيل (عادة 24-72 ساعة). للتمويل - أكثر.

س: هل أحتاج إلى مفتاح إذا كان لدي ضغط بالمفتاح في كافكا ؟

ج: نعم. سيقلل الضغط من التخزين، لكنه لن يجعل مزامنتك غير قابلة للتخزين.

13) المجاميع

مرة واحدة على الأقل - دلالات النقل الأساسية والموثوقة.
مرة واحدة بالضبط حيث يتم تحقيق تأثير العمل على مستوى المعالج: Idempotency-Key، Inbox/Outbox، Upsert/الإصدارات، SAGA/التعويض.
الخيار هو حل وسط للتكلفة ↔ خطر الازدواجية ↔ سهولة التشغيل. صمم مفاتيح طبيعية، واجعل الكدمات غبية، وأضف إمكانية الملاحظة ولعب أيام اللعبة بانتظام - عندها ستكون خطوط الأنابيب الخاصة بك متوقعة وآمنة حتى في عاصفة من حالات العودة والفشل.