ما .RocketMQ ذلك؟
الطابور النموذج هو الوسيطة الرسائل، عالية الأداء، والموثوقية العالية، وارتفاع في الوقت الحقيقي، والطبيعة الموزعة.
منتج، المستهلك، طوابير يمكن توزيعها،
منتج بدوره يرسل بعض الرسائل طابور، ودعا مجموعة الموضوع الصفوف، إذا فعلت البث المستهلك المستهلك، والمستهلك هو المستهلك من هذا المثال كافة قوائم الانتظار موضوع المقابلة، إذا استهلاك كتلة القيام به، ومتوسط استهلاك تعدد حالات المستهلك هذا الموضوع مجموعة من طوابير المقابلة
لضمان صارم يأمر رسالة
تقديم معلومات غنية طراز السحب
قابلية مستوى كفاءة المشترك
في الوقت الحقيقي أخبار يكتتب آلية
مائة مليون رسالة القدرة تراكم
أقل اعتمادا على
، رسالة مكررة الثانية
في حل أعلاه تسلسل رسالة مشكلة، فإنه يدخل مشكلة جديدة، وهذا هو الرسالة المتكررة. حتى RocketMQ رسالة التكرار هو كيفية حل هذه المشكلة؟ أو "عادل" لا حلها.
ويتكرر هذا السبب الجذري للرسالة: شبكة غير قابلة للوصول. طالما تبادل البيانات عبر الشبكة، لا يمكنك تجنب هذه المشكلة. وبالتالي فإن الحل لهذه المشكلة هو لتجاوز هذه المشكلة. يصبح السؤال بعد ذلك: إذا كان الجانب الاستهلاكي يتلقى رسالتين مختلفة، ما ينبغي القيام به؟
- نهاية مستهلك الخدمة الاحتفاظ رسالة معالجة المنطق idempotent
- تأكد من أن كل رسالة لديها عدد ورسالة فريدة من نوعها المعالجة لضمان نجاح السجل لإعادة تظهر في الجدول نفس الوقت
المادة 1 مفهومة جيدا، وتبقي فقط idempotency، بغض النظر عن عدد الرسائل مكررة، ولكن علاجها أخيرا نفسه. المادة 2 من حيث المبدأ هو استخدام جدول سجل لتسجيل ID تمت بنجاح معالجة الرسالة، إذا وصل حديثا ID الرسالة بالفعل في الجدول السجل، فإنه لم يعد التعامل مع هذه الرسالة.
المادة 1 الحل، فمن الواضح أنه ينبغي تحقيق في النهاية المستهلك، وليس جزءا من وظائف نظام الرسائل التي سيتم تنفيذها. المادة 2 يمكن تنفيذ نظام المراسلة، ونهاية العمل لا يمكن أن يتحقق. رسائل مكررة احتمال في ظل الظروف العادية هو في الواقع صغيرة جدا، إذا ما نفذت عن طريق نظام الرسائل، وسيكون بالتأكيد النظام المتوفرة عالية الرسائل الإنتاجية والنفوذ، لذلك أفضل للتعامل مع الرسائل الخاصة بهم من نهاية أعمال الأسئلة المكررة، وهذا هو السبب RocketMQ لن يحل المشكلة من رسائل مكررة.
RocketMQ لا يضمن أن الرسالة لا يتكرر، إذا لا يحتاج عملك أن تكون رسائل مكررة بدقة، عليك أن تذهب ثقيلة على الجانب التجاري.
، رسالة المعاملة الثالثة
RocketMQ بالإضافة إلى دعم رسالة مشتركة، وتسلسل الرسالة، بالإضافة إلى دعم رسائل المعاملات. أولا، نحن نناقش ما هو ضرورة من رسائل المعاملات ورسائل المعاملات. لدينا نقل السيناريو كمثال لتوضيح المشكلة: التحويلات بوب سميث إلى 100.
في بيئة قائمة بذاتها، وتنفيذ هذه الصفقة، ربما يبدو مثل هذا:
عملية تحويل التخطيطي بيئة قائمة بذاتها
عندما النمو المستخدم إلى حد ما، بوب سميث والمعلومات رصيد الحساب وأنه لم يعد على نفس الخادم، ثم العملية المذكورة أعلاه تصبح هذه:
عملية تحويل بيئة نظام التخطيطي
هذه المرة سوف تجد، هو أيضا نقل رجال الأعمال، في بيئة متفاوت المسافات، في الواقع تستغرق وقتا طويلا تنمو باطراد، والتي من الواضح لم يكن قادرا على قبول. كيفية تجنب هذه المشكلة؟
المعاملات الكبيرة الصفقات الصغيرة + = غير المتزامن
المعاملات الكبيرة كسر في معاملات صغيرة متعددة نفذت بشكل غير متزامن. وذلك أساسا قادرة على تنفيذ المعاملات بكفاءة عبر آلات الأمثل لتكون متسقة مع احد. معاملات نقل يمكن تقسيمها إلى المعاملات صغيرة التاليين:
الصفقات الصغيرة غير متزامن الرسائل +
الرقم تنفيذ الصفقة المحلية (حساب الخصم بوب) وإرسال رسائل غير متزامن في نفس الوقت يجب أن تضمن النجاح أو الفشل في نفس الوقت، وهذا هو، تهمة نجاحا، وإرسال رسالة يجب أن تنجح، إذا فشل هذا الاتهام، لا يمكنك إرسال الرسالة. هذا السؤال هو: هل لتوجيه الاتهام له أو لإرسال رسالة؟
أولا، نظرة على الوضع قبل إرسال الرسالة، تخطيطي كبير على النحو التالي:
الرسائل العملية: أولا لإرسال رسالة
هناك مشكلة: إذا تم إرسال الرسالة بنجاح، لكنه فشل المسؤول، فإن نهاية المستهلك تستهلك الرسالة، ومن ثم إضافة المال إلى حساب سميث.
