خوشه بندی RabbitMQ در CentOS 7

• پیش نیازها
• دیوار آتش را پیکربندی کنید
• rabbitmqadmin را نصب کنید
• پیکربندی DNS
• گره ها را خوشه می زنند
• یک خط مشی در دسترس بالا ایجاد کنید
• آزمایش تنظیمات
• کاربر مهمان را حذف کنید

RabbitMQ یک کارگزار پیام منبع باز است که از AMQP ، STOMP و سایر فن آوری های ارتباطی پشتیبانی می کند. این نرم افزار به طور گسترده ای در برنامه های سازمانی و معماری های جدید خدمات میکرو استفاده می شود ، جایی که به عنوان یک کانال پیام ناهمزمان بین خدمات مختلف میکرو عمل می کند. در این راهنما توضیح داده می شود که چگونه می توانید RabbitMQ را روی چندین سرور CentOS 7 خوشه بندی کنید تا یک کارگزار پیام با دسترسی بالا تهیه کنید. در این آموزش ، در صورت عدم دسترسی سرور اصلی ، یک سرور به عنوان سرور اصلی عمل می کند و سرورهای دیگر به عنوان سرورهای آینه عمل می کنند.

پیش نیازها

• حداقل دو مورد CentOS 7 که اخیراً مستقر شده و به روز شده اند در همان زیر شبکه با شبکه های خصوصی فعال هستند
• RabbitMQ نصب شده با کنسول مدیریتی که روی هر سرور فعال شده است (به نحوه نصب RabbitMQ در CentOS 7 مراجعه کنید )
• یک کاربر غیر مدیر با حقوق سودو (به نحوه استفاده از سودو در Debian ، CentOS و FreeBSD مراجعه کنید )

دیوار آتش را پیکربندی کنید

فایروال CentOS ، ( firewalld) ، به طور پیش فرض هیچگونه ترافیک ورودی را مجاز نمی کند. برای اینکه 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

گره ها را خوشه می زنند

پیش شرط وارد کردن اجازه می دهد گره ها به یکدیگر بپیوندند این است که کوکی ارلانگ همه گره ها یکسان هستند. به طور پیش فرض ، به هر گره یک کوکی ارلانگ منحصر به فرد اختصاص داده می شود ، بنابراین باید آن را در همه گره ها مجددا پیکربندی کنید.

دستور زیر کوکی ارلانگ را " 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 از خط مشی. این سند توصیف می کند که ما می خواهیم - دقیقاً 2 گره ای که داده ها به طور خودکار همزمان می شوند

به طور خلاصه ، این سیاست اطمینان حاصل خواهد کرد که ما همیشه 2 نسخه از داده ها را در صف یا مبادله خواهیم داشت تا زمانی که حداقل 2 گره داشته باشیم و در حال اجرا باشیم. اگر گره های بیشتری دارید می توانید مقدار را افزایش دهید ha-params. ( N/2 + 1) ، از گره ها سهم ( ) استفاده می شود. داشتن نسخه های بیشتر از داده های شما منجر به دیسک بالاتر ، i / o و استفاده خالص می شود که می تواند منجر به عملکرد تخریب شود.

اگر می خواهید داده ها را در تمام گره های خوشه آینه کنید ، می توانید از سند 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"}'

می توانید عبارت معمولی را برای اختصاص خط مشی های مختلف در صف های مختلف تغییر دهید. بگویید ما سه گره زیر داریم:

• خرگوش @ استاد
• خرگوش @ مشتری-هکتار
• خرگوش @ product-ha

سپس می توانیم دو خط مشی ایجاد كنیم كه منجر به آن می شود كه صف هایی كه اسمی را شروع می كنند با "مشتری" شروع می شود تا 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" ما اختصاص داده شده است و دارای پید روی استاد و گره آینه است.

sudo rabbitmqctl list_queues name policy state pid slave_pids

اکنون می توانیم پیامی را از گره master منتشر کرده و 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