تجميع أرنب MQ على CentOS 7

• المتطلبات الأساسية
• تكوين جدار الحماية
• قم بتثبيت أرنب مقدمين
• تكوين DNS
• قم بتجميع العقد
• إنشاء سياسة توفر عالية
• اختبار الإعداد
• حذف المستخدم الضيف

RabbitMQ هو وسيط رسائل مفتوح المصدر يدعم AMQP و STOMP وتقنيات الاتصالات الأخرى. يتم استخدامه على نطاق واسع في تطبيقات المؤسسات وبنيات الخدمات الصغيرة الحديثة حيث يعمل كقناة رسائل غير متزامنة بين الخدمات الدقيقة المختلفة. يصف هذا الدليل كيف يمكنك تجميع RabbitMQ على عدة خوادم CentOS 7 لتشكيل وسيط رسائل عالية التوفر. في هذا البرنامج التعليمي ، سيعمل خادم واحد كخادم رئيسي وستعمل الخوادم الأخرى كخوادم متطابقة في حالة عدم توفر الخادم الرئيسي.

المتطلبات الأساسية

• ما لا يقل عن حالتين جديدتين تم تحديثهما وتحديثهما في نفس الشبكة الفرعية مع تمكين الشبكات الخاصة
• تم تثبيت RabbitMQ مع تمكين وحدة تحكم الإدارة على كل خادم (انظر كيفية تثبيت RabbitMQ على CentOS 7 )
• مستخدم غير إداري لديه حقوق sudo (انظر كيفية استخدام Sudo على Debian و CentOS و FreeBSD )

تكوين جدار الحماية

firewalldلا يسمح جدار الحماية CentOS ، ( ) ، بأي حركة مرور واردة بشكل افتراضي. لإتاحة RabbitMQ للأنظمة الأخرى داخل الشبكة وخارجها ، وللسماح لنا بالوصول إلى وحدة تحكم الإدارة ، يجب علينا أولاً فتح بعض المنافذ.

تستمع وحدة تحكم إدارة واجهة الويب الخاصة بـ RabbitMQ افتراضيًا على المنفذ 15672. نود أن نجعل وحدة تحكم الإدارة متاحة للجميع حتى نتمكن من الوصول إليها من جهاز الكمبيوتر الخاص بنا. لذلك سنوجه تعليمات firewalldلفتح المنفذ بشكل دائم 15672في المنطقة العامة (وهي المنطقة الافتراضية والنشطة في مثيل Vultr).

sudo firewall-cmd --zone=public --add-port=15672/tcp --permanent

يجب أن تكون عقد RabbitMQ قادرة على التواصل مع بعضها البعض. نود أن نفتح المنافذ الضرورية ، ولكن فقط عبر الشبكة الداخلية. لا نريد أن يتمكن أي شخص على الإنترنت من إدارة خوادمنا أو الاتصال بها مباشرة. تفترض الأوامر التالية أن خوادمنا موجودة على 192.168.0.100/24الشبكة الفرعية.

الخدمة الأولى هي خدمة epmdاكتشاف الأقران التي تستمع افتراضيًا على المنفذ 4369.

sudo firewall-cmd --permanent --zone=public --add-rich-rule='
  rule family="ipv4"
  source address="192.168.0.100/24"
  port protocol="tcp" port="4369" accept'

بالنسبة للاتصالات الداخلية و CLI ، يحتاج RabbitMQ إلى الاتصال عبر المنفذ 25672.

sudo firewall-cmd --permanent --zone=public --add-rich-rule='
  rule family="ipv4"
  source address="192.168.0.100/24"
  port protocol="tcp" port="25672" accept'

تتواصل أدوات CLI عبر نطاق المنافذ 35672-35682.

sudo firewall-cmd --permanent --zone=public --add-rich-rule='
  rule family="ipv4"
  source address="192.168.0.100/24"
  port protocol="tcp" port="35672-35682" accept'

إذا كانت تطبيقاتك تحتاج إلى بروتوكول AMQP ، فستحتاج أيضًا إلى فتح المنافذ 5671و 5672. إذا كنت بحاجة إلى أن تكون قادرًا على التواصل عبر بروتوكول آخر ، فيمكنك العثور على المعلومات الضرورية حول متطلبات الشبكات الخاصة بـ RabbitMQ على وثائق RabbitMQ الرسمية .

sudo firewall-cmd --permanent --zone=public --add-rich-rule='
  rule family="ipv4"
  source address="192.168.0.100/24"
  port protocol="tcp" port="5672" accept'

sudo firewall-cmd --permanent --zone=public --add-rich-rule='
  rule family="ipv4"
  source address="192.168.0.100/24"
  port protocol="tcp" port="5671" accept'

الآن بعد أن firewalldتمت تهيئته ، نحتاج إلى توجيهه لإعادة تحميل التكوين.

sudo firewall-cmd --reload

كرر الخطوات من هذا القسم على جميع الخوادم.

تثبيت rabbitmqadmin

يأتي المكوّن الإضافي للإدارة مع أداة Python تسمى rabbitmqadminوالتي يمكن تثبيتها بسهولة على النظام بمجرد تمكين المكوّن الإضافي للإدارة.

sudo wget http://localhost:15672/cli/rabbitmqadmin
sudo mv rabbitmqadmin /usr/local/bin/
sudo chmod +x /usr/local/bin/rabbitmqadmin

تكوين DNS

يجب عليك استخدام أسماء مضيف الخادم لتحديد الخوادم عند التجميع. بشكل افتراضي ، لم يتم تعيين سجل DNS للملقمات وسيفشل الاتصال. للتغلب على ذلك بسرعة ، أضف اسم المضيف الرئيسي والمرئي إلى /etc/hostsالملف باستخدام محررك المفضل.

على سبيل المثال ، قد يبدو ملف المضيفين الرئيسيين كما يلي. لاحظ آخر سجلين ، مما يسمح للخوادم بالتعرف على بعضهما البعض بواسطة اسم المضيف. تأكد من تغيير عناوين IP الخاصة بك.

127.0.0.1   localhost localhost.localdomain localhost4 localhost4.localdomain4
::1         localhost localhost.localdomain localhost6 localhost6.localdomain6

127.0.0.1 guest
::1       guest

127.0.0.1 YOUR_MASTER_SERVER_HOST_NAME
::1       YOUR_MASTER_SERVER_HOST_NAME


192.168.0.101 YOUR_MASTER_SERVER_HOST_NAME
192.168.0.102 YOUR_MIRROR_SERVER_HOST_NAME

قم بتجميع العقد

أحد شروط الاستيراد للسماح للعقد بالانضمام إلى بعضها البعض هو أن ملف تعريف الارتباط Erlang لجميع العقد متطابق. بشكل افتراضي ، سيتم تعيين ملف تعريف ارتباط Erlang فريد لكل عقدة ، لذلك يجب إعادة تكوينه على جميع العقد.

سيقوم الأمر التالي بتعيين ملف تعريف الارتباط Erlang على " WE<3COOKIES" ، ولكن لا تتردد في تغيير هذا حسب رغبتك. قم بذلك على جميع الخوادم.

sudo sh -c "echo 'WE<3COOKIES' > /var/lib/rabbitmq/.erlang.cookie"

أعد تشغيل RabbitMQ على جميع الخوادم للتأكد من إعادة تحميل ملف تعريف الارتباط Erlang بشكل صحيح.

sudo systemctl restart rabbitmq-server.service

نفّذ الأوامر التالية على جميع الخوادم باستثناء الخادم الرئيسي. سيسمح ذلك للعقد بالانضمام إلى الخادم الرئيسي وتشكيل مجموعة.

sudo rabbitmqctl stop_app
sudo rabbitmqctl join_cluster "rabbit@<YOUR_MASTER_SERVER_HOST_NAME>"
sudo rabbitmqctl start_app

تحقق من أن العقد قد انضمت إلى الكتلة بتشغيل الأمر التالي.

sudo rabbitmqctl cluster_status

سوف تظهر كل من العقد الخاص بك في nodesو running_nodesقسم من الإنتاج. من الآن فصاعدًا ، لم تعد بحاجة إلى تكرار الخطوات على كل خادم ، وسيتم عكس التكوين تلقائيًا على العقد الأخرى.

إنشاء سياسة توفر عالية

الآن بعد أن أصبح لدينا مجموعة من عقد RabbitMQ ، يمكننا استخدام هذا لإنشاء قوائم انتظار وتبادلات عالية التوفر من خلال وضع سياسة جديدة. يمكن إضافة هذه السياسة من خلال وحدة تحكم إدارة RabbitMQ أو باستخدام واجهة سطر الأوامر.

sudo rabbitmqctl set_policy -p "/" --priority 1 --apply-to "all" ha ".*" '{ "ha-mode": "exactly", "ha-params": 2, "ha-sync-mode": "automatic"}'

توضح القائمة التالية معنى كل جزء من الأمر.

• -p "/": استخدم هذه السياسة على "/"vhost (الافتراضي بعد التثبيت)
• --priority 1: ترتيب تطبيق السياسات
• --apply-to "all": يمكن أن يكون "queues"، "exchanges"أو"all"
• ha: الاسم الذي نطلقه على سياستنا
• ".*": التعبير العادي المستخدم لتحديد قوائم الانتظار أو التبادلات التي يتم تطبيق هذه السياسة عليها. ".*"ستطابق أي شيء
• '{ "ha-mode": "exactly", "ha-params": 2, "ha-sync-mode": "automatic"}': تمثيل JSON للسياسة. يصف هذا المستند أننا نريد - عقدتان بالضبط تتم مزامنة البيانات تلقائيًا عليهما

باختصار ، ستضمن هذه السياسة أنه سيكون لدينا دائمًا نسختان من البيانات في قائمة انتظار أو تبادل طالما لدينا عقدتان على الأقل قيد التشغيل. إذا كان لديك المزيد من العقد يمكنك زيادة قيمة ha-params. N/2 + 1ينصح بنصاب العقد ( ). سيؤدي الحصول على المزيد من نسخ بياناتك إلى ارتفاع استخدام القرص ، وإدخال / إخراج ، واستخدام صافي مما قد يؤدي إلى تدهور الأداء.

إذا كنت ترغب في عكس البيانات على جميع العقد في المجموعة ، فيمكنك استخدام مستند JSON التالي.

'{ "ha-mode": "all", "ha-sync-mode": "automatic"}'

إذا كنت ترغب في عكس البيانات فقط على عقد محددة ، (على سبيل المثال: node-1و node-2) ، يمكنك استخدام ما يلي.

'{ "ha-mode": "nodes", "ha-params" :["rabbit@node-1", "rabbit@node-2"], "ha-sync-mode": "automatic"}'

يمكنك تغيير التعبير العادي لتعيين سياسات مختلفة لقوائم انتظار مختلفة. لنفترض أن لدينا العقد الثلاث التالية:

• أرنب @ سيد
• أرنب @ العميل هكتار
• أرنب @ المنتج هكتار

يمكننا بعد ذلك إنشاء سياستين تؤديان إلى جعل قوائم الانتظار تحمل اسمًا يبدأ بـ "العميل" ليتم عكسها في rabbit@client-haالعقدة وجميع قوائم الانتظار التي تبدأ باسم "منتج" ليتم عكسها في rabbit@product-haالعقدة.

sudo rabbitmqctl set_policy -p "/" --priority 1 --apply-to "queues" ha-client "client.*" '{ "ha-mode": "nodes", "ha-params": ["rabbit@master", "rabbit@client-ha"], "ha-sync-mode": "automatic"}
sudo rabbitmqctl set_policy -p "/" --priority 1 --apply-to "queues" ha-product "product.*" '{ "ha-mode": "nodes", "ha-params": ["rabbit@master", "rabbit@product-ha"], "ha-sync-mode": "automatic"}

ملاحظة صغيرة هنا: قوائم الانتظار الحصرية لا يتم عكسها أو استمرارها في RabbitMQ ، حتى لو كانت هذه السياسة تتطابق مع قوائم الانتظار هذه. يتم تدمير قوائم الانتظار الحصرية تلقائيًا بمجرد قطع اتصال العميل ، وعلى هذا النحو ، لن يكون من المفيد نسخها إلى خادم آخر. في حالة فشل الخادم ، سيتم قطع اتصال العميل به وسيتم إتلاف قائمة الانتظار تلقائيًا. سيتم تدمير الحالات المتطابقة أيضًا.

اختبار الإعداد

من أجل اختبار الإعداد المجمع ، يمكننا إنشاء قائمة انتظار جديدة باستخدام واجهة سطر الأوامر من خلال وحدة تحكم الإدارة.

sudo rabbitmqadmin declare queue --vhost "/" name=my-ha-queue durable=true

سيؤدي هذا إلى إنشاء قائمة انتظار دائمة على /vhost الافتراضي بالاسم my-ha-queue.

شغّل الأمر التالي وتحقق في الإخراج من أن قائمة الانتظار قد تم تعيين سياسة "ha" الخاصة بنا وبها pid على الصفحة الرئيسية وعلى عقدة معكوسة.

sudo rabbitmqctl list_queues name policy state pid slave_pids

يمكننا الآن نشر رسالة إلى قائمة الانتظار من العقدة الرئيسية وإيقاف RabbitMQ على العقدة الرئيسية.

sudo rabbitmqadmin -u user_name -p password  publish routing_key=my-ha-queue payload="hello world"
sudo systemctl rabbitmqctl shutdown

الآن احصل عليه مرة أخرى عن طريق الاتصال بالعقدة المتطابقة.

 sudo rabbitmqadmin -H MIRROR_NODE_IP_OR_DNS -u user_name -p password get queue=my-ha-queue

أخيرًا ، يمكننا إعادة تشغيل العقدة الرئيسية.

sudo systemctl start rabbitmq-server.service

حذف المستخدم الضيف

كما ذكرنا من قبل ، يقوم RabbitMQ تلقائيًا بإنشاء مستخدم ضيف بكلمة مرور ضيف افتراضية. سيكون من الممارسات السيئة ترك هذا المستخدم الافتراضي على نظام مكشوف للعامة.

sudo rabbitmqctl delete_user guest