دلالات مرة واحدة بالضبط

ما هو بالضبط مرة واحدة حقا

• التسليم: سيتم تسليم الرسالة إلى المستهلك مرة واحدة بالضبط.
• المعالجة: سيحدث التأثير الجانبي النهائي (الكتابة إلى قاعدة البيانات، وتغيير الرصيد، وإصدار حدث آخر) مرة واحدة بالضبط، حتى لو كان هناك المزيد من عمليات التسليم أو المحاولات.

في الأنظمة الموزعة، يكون الحديث عن معالجة الدلالات أكثر موثوقية. يكون التسليم مرة واحدة بالضبط صعبًا (النسخ المكررة والمتكررة أمر لا مفر منه)، ولكن يمكن جعل الحالة الناتجة مكافئة لعلاج واحد.

عندما تكون هناك حاجة إلى EOS ومتى لا

• المعاملات والأرصدة النقدية: لا يسمح بالشطب المزدوج.
• محاسبة الرخص/الحصص، عدادات الفواتير.
• مكالمات خارجية لا رجعة فيها (على سبيل المثال، تنشيط المفتاح لمرة واحدة).

• والآثار قابلة للعكس أو للتعويض (ملحمة، عائدات).
• يُسمح باستنساخ النسخ المؤقتة في واجهات المحلات/السجلات.
• من الأرخص توفير حوض أخرق من سحب المعاملات عبر المسار بأكمله.

النموذج: من طرف إلى طرف مقابل القفز بالقفزة

Hop-by-hop EOS: يضمن كل قسم (المصدر → المعالج → المتلقي) أنه سيطبق إجراءاته مرة واحدة بالضبط.
EOS من طرف إلى طرف: تضمن السلسلة بأكملها أنه من «حقيقة» إلى «آثار جانبية»، فإن النتيجة تعادل علاجًا واحدًا.

من الناحية العملية، يتم تحقيق الانتقال من البداية إلى النهاية من خلال مزيج من المعاملات و/أو الخصوصية في كل قفزة.

اللبنات الأساسية

1. العمليات الخفية

تكرار نفس الاستفسار عن مفتاح العملية ينتج نفس النتيجة.

Ключи: 'idempotency _ key '/' event _ id '/' operation _ id'.
التنفيذ: جدول العمليات «المشاهدة» مع TTL ≥ عرض سجل المدخلات.

2. معاملات القراءة والعملية والكتابة

في وحدة عمل ذرية واحدة، يتم تسجيل كل من التأثير الجانبي وتقدم القراءة (التعويضات/الموقف). هذا يقضي على «الأشباح» عند الوقوع بين الخطوات.

3. نسخ/تسلسل

يتم تخزين نسخة/عداد للمجموع ؛ تنطبق التغييرات فقط في حالة تطابق النسخة المتوقعة. تكرار نفس الحدث لا يزيد النسخة → التأثير مرة واحدة.

4. التفريغ

فهرس '(consumer_id، event_id)' أو 'المعرف' الطبيعي للمعاملة.

أنماط التنفيذ

1) سجل المعاملات + حوض المعاملات مع تثبيت التعويض

مثالي لمعالجة التيار.

نقرأ من السجل (الإدخالات المؤكدة فقط).
نجري المعالجة.

• (أ) كتابة التأثير في الحوض (قاعدة البيانات/الجدول)،
• (ب) تثبيت عبارة «يقرأ ليقابل N» (في نفس قاعدة البيانات).
• ارتكب. عند إعادة التشغيل، إما يتم خصم كل شيء (ويتم تغيير التعويض)، أو لا شيء.

الممتلكات: الإعدام المتكرر ليس ضارا ؛ «مرة واحدة بالضبط» في الواقع، حتى لو تمت قراءة الرسالة مرتين.

2) Outbox + المستهلك الخفي

لخدمات منتجي المعاملات.

في إحدى معاملات قاعدة البيانات: قم بتغيير سجل المجال واكتب الحدث إلى صندوق الخروج.
يسلم المكرر الحدث إلى الحافلة بنفس «الحدث _ المعرف».
يطبق المستهلكون الأحداث بشكل خفي (التخلص بواسطة 'event _ id').

الخصائص: يضمن المنتج عدم فقدان أي حقيقة ؛ يضمن المستهلكون تأثيرًا واحدًا بالضبط.

3) EOS في النظم الشبيهة بكافكا/فلينك (من الناحية المفاهيمية)

المنتج اللطيف: يحمي من إرسال التراجعات.
معاملات المنتجين: تلتزم ذريا مجموعة من القيودات في المواضيع + تحول المستهلك ؛ يستخدم القراء عزل «اقرأ _ ملتزم».
يقوم جانب المعالجة بتخزين المتجر الحكومي والتزامه جنبًا إلى جنب مع الصفقة.

الخصائص: إعادة تشغيل المتجر/السحب لا يؤدي إلى تأثير مزدوج ؛ تكرار «غير مرئي» في اتجاه مجرى النهر.

4) «أحواض» فطرية عبر اضطراب/دمج

يأخذ Sink «العملية _ id »/« event _ id' وينفذ» UPSERT... في حالة عدم وجودها.
التأثير الجانبي (على سبيل المثال، الاستحقاق) يتم إجراؤه ذريًا مع الفحص «لم يتم تطبيقه بالفعل».

الخصائص: طريقة EOS رخيصة على الحافة مع التخزين، دون معاملات موزعة.

تفاصيل التنفيذ الرئيسية

هوية المعاملات

يجب أن تكون حتمية للتكرار (لا تولد UUID جديد عند التراجع).
أن يكون له نطاق ثابت (على المستهلك/الوحدة/النظام).

جدول التفريغ

Колонки: 'consumer _ id', 'operation _ id', 'applied _ at',' tl _ expires _ at'.
الفهارس على «(consumer_id، operation_id)».
TTL ≥ أقصى نافذة تكرار (الاحتفاظ بالسجل + التأخيرات المحتملة).

منافسة متفائلة

في نموذج الكتابة، قم بتخزين نسخة الوحدة.
عند تطبيق حدث/أمر، استخدم «نسخة WHERE =: متوقعة» ؛ مكررة لن تزيد النسخة.

اطلب/امر

EOS ليس "بالضبط نفس الترتيب. "ضمان الاتساق من خلال مفتاح الدفعة (جميع الأحداث الإجمالية → دفعة واحدة) و/أو مقارنة" المساواة ".

مكالمات خارجية خفية

بالنسبة للأساليب غير الآمنة (على سبيل المثال، خطوط الويب HTTP لخدمة طرف ثالث)، أضف «Idempotency-Key» واطلب من الشريك دعمها.

الفخاخ المتكررة

EOS في مكان واحد فقط: إذا كان الحوض غبيًا، لكنك تصدر أحداثًا ثانوية دون حماقة، فستحصل على «مرات عديدة بالضبط» في اتجاه مجرى النهر.
يلتزم اثنان: أولاً في قاعدة البيانات، ثم يلتزم التعويض في الوسيط - السقوط بينهما يخلق تأثيرات مكررة.
مراكز السيطرة على الأمراض الخام: تغيير مخطط DB يكسر فراغ المستهلك.
المفاتيح غير المستقرة: «التشغيل _ المعرف» يعتمد على الوقت/العشوائي والتغييرات أثناء إعادة الطرح.

التكاليف والمقايضات

الكمون: المعاملات/القراءات المعزولة → p95/p99 النمو.
التخزين العلوي: جداول تفريغ، متاجر الدولة، سجلات المعاملات.
التعقيد التشغيلي: مهلة المعاملات، إعادة التوازن بين الخيوط، الجلسات العالقة.
التشخيص: المزيد من الحالات («في الكاميت»، «مرئية read_committed,» «تراجعت»).

اختيار نقطة EOS: للمجموعات والآثار الحرجة ؛ تغطي الباقي بالحماقة والتعويض.

اختبار مرة واحدة بالضبط

1. حقن الخطأ: الانخفاض في العملية بين الخطوات «سجل التأثير» و «سجل التعويض».
2. نسخ مكررة: قم بتنزيل نفس الرسالة 2-5 مرات، وتأكد من تأثير واحد.
3. إعادة التشغيل وإعادة التوازن: إيقاف/إعادة تشغيل العمال، والتحقق من عدم وجود معالجة مزدوجة.
4. Flappies الشبكة: مهلة منتصف المعاملات، الالتزام بإعادة المحاولة.
5. اختبارات التحميل: نمو قائمة الانتظار → ما إذا كان هناك تدهور «إلى الأبد في المعاملة».

قوالب صغيرة (زائفة)

حوض فطري مع إصلاح التعويض

pseudo begin tx if not exists(select 1 from dedup where consumer_id=:c and op_id=:id)
then apply_effect(...)    -- upsert / merge / add_one_time_action insert into dedup(c, id, applied_at) values(:c,:id, now)
end if update offsets set pos=:pos where consumer_id=:c commit

أمر مع وحدة نسخة

pseudo begin tx update account set balance = balance +:delta,
version = version + 1 where id=:account_id and version=:expected_version;
if row_count=0 then error CONCURRENT_MODIFICATION commit

السلامة والامتثال

PII/PCI في جداول التفريغ: تخزين الحد الأدنى، واستخدام الرموز بدلاً من البيانات الخام.
مراجعة الحسابات: سجل 'التشغيل _ id'، 'التعقب _ id'، النتيجة (APPLIED/ALREADY_APPLIED).
سياسة التخزين: TTL على جداول التخلص، وأرشفة التعويضات/السجلات.

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

«التسليم الحقيقي مرة واحدة بالضبط»: محاولة لاستبعاد النسخ المزدوجة على مستوى بروتوكول النقل دون تأثير الخصوصية.
المعاملات العالمية الموزعة لكل شيء: XA/2PC من خلال جميع الخدمات هشة وبطيئة.
مزج الآثار الجانبية غير الاختصاصية (على سبيل المثال، البريد الإلكتروني المرسل قبل الالتزام بالتعويض).
الافتقار إلى مفاتيح التشغيل: الاعتماد على «تفرد» الحمولة.

قائمة الإنتاج المرجعية

• لكل تأثير حاسم مفتاح خفي.
• يتم تحديد وضع الإزاحة/القراءة في معاملة واحدة سارية المفعول.
• جداول التفريغ المفهرسة ؛ TTL ≥ الاحتفاظ بالسجل.
• يتم تمكين المنافسة المتفائلة (النسخة/التسلسل) للمجموعات.
• تقرأ المواضيع/المواضيع في نمط «Comp Only» (إذا كانت متاحة).
• توجد اختبارات مكررة ومسقطة في CI/CD.
• لوحات القيادة: حصة التكرار، المعاملات الفاشلة، حجب الوقت، التأخير.
• وثائق المدمج لـ «Idempotency-Key »/retires/timeouts.

التعليمات

هل يمكن توفير EOS بدون معاملات ؟

غالبًا ما يكون نعم - من خلال خصوصية الحوض (المزعج/الدمج) وإصدار المجاميع. تبسط المعاملات الضمانات ولكنها تزيد التكلفة.

هل يحتاج الجميع مرة واحدة بالضبط ؟

لا ، ليس كذلك إنه مكلف. تطبيق نقطة عندما يكون التعويض غير ممكن/مكلف.

كيفية ربط الرسائل/الخطابات الشبكية مع EOS ؟

يوقف الإشعار قبل الالتزام، ويرسل بعد تثبيت الأثر ؛ تخزين 'إشعار _ معرف' وجعل إرسال أبله.

ما هو الأهم - التسليم أو المعالجة ؟

التجهيز. ويمكن تكرار عمليات التسليم ؛ يجب أن تكون الحالة النهائية صحيحة والوحيدة.

النتيجة

مرة واحدة بالضبط تدور حول صحة التأثير، وليس حول عدم وجود نسخ مكررة في الأسلاك. يتم تحقيقه من خلال مزيج من الخصوصية والتثبيت الذري للتأثير والتقدم في القراءة والتقسيم المعقول وانضباط الإصدار. طبق EOS حيث تكون تكلفة الخطأ غير مقبولة، واختبر واقعها مع السقوط وأخذ الاختبارات - لا يوجد إيمان بالنقل.