بناء التدفقات عبر البروتوكولات

مبتدئ

image_pdf

استخدام عقدة RBE :

في هذا المثال، سيتم إضافة عقدة  (report by exception -RBE) و التي تقوم بتمرير البيانات فقط اذا طرأ عليها تغيير . يمكنك تعيينها لفحص حمولة الرسالة (massage payload) و إما عن طريق تجاهلها حتى يطرأ أي تغيير على الرسالة (في حالة RBE ) أو عندما تتغير الرسالة بنسبة معينة (في حالة  deadband ) .

في حالة استخدامRBE ،  تعمل على الأرقام و الجمل . وفي حالة استخدام deadband  فهي تعمل على أرقام فقط و يستخدم في إعداد الـ deadband  نطاق + أو – ، بحث تكون القيمة الواردة يمكن أن تتقلب داخل نطاق معين  قبل أن تنطلق .

سنقوم بإضافة عقدة تغيير (change node ) والتي سيتم توصيلها على مخرج 1 لعقدة التبديل (switch node) . ثم سنقوم بتوصيل عقدة rbe  إلى عقدة التغيير كما هو موضح بالصورة أدناه . تذكر بأن الناتج يتوافق مع  “analyze “ ، وقد تم إضافة عقدة تعليق (comment node) و كتب عليها “analyze=true”  ، لأنها مفيدة عند عمل تدفقات معقدة .

basic-nodes-and-flows

قم بفتح محرر عقدة التغيير (change node)  لتعيين msg.payload إلى msg.payload.value  . وهكذا يحدد المخرج من هذه العقدة إلى القيمة الموجودة في العنصر msg.payload.value من المدخلات الواردة كما في الشكل أدناه .

basic-nodes-and-flows

سنقوم بتوجية الرسالة إذا تم تغيير القيمة بنسبة 20% أو أكثر من ذلك ، فسوف تحتاج إلى النقر نقرا مزدوجا فوق عقدة RBE  و لتجاهل الرسالة مالم تتغير القيمة بأكثر من 20 % .

basic-nodes-and-flows

لإختبار التدفق، قم بنشر deploy  هذا التدفق ومن ثم العودة إلى صفحة HiveMQ  و إرسال سلسلة من الرسائل. أولا ، سوف تحتاج إلى عيين قيمة analayze إلى true  و بالتالي تقوم عقدة التبديل بإرسال الرسالة عبر المخرج الأول. إذا كنت تستخدم الرسالة التي تم تعينها سابقة فإن القيمة (value)  من 6 ، ستفشل في عبور عقدة RBE  . ثم قم بإرسال رسالة ثانية من قيمة 10 ، فإن العقدة RBE  تقييم الفرق ما بين 6 و 10  ، ويرها اكبر من 20 % ، فيقوم بإرسال رسالة إلى عقدة debug  النهائية والتي ستطبع على لوحة الإخراج debug  كما هو موضح بالصورة التالية :

basic-nodes-and-flows

X
تم إضافة المنتج إلى السلة بنجاح