CentOS 7でのRabbitMQのクラスタリング

• 前提条件
• ファイアウォールを構成する
• rabbitmqadminをインストールする
• DNSを構成する
• ノードをクラスター化する
• 高可用性ポリシーを作成する
• セットアップのテスト
• ゲストユーザーを削除する

RabbitMQは、AMQP、STOMP、その他の通信技術をサポートするオープンソースのメッセージブローカーです。エンタープライズアプリケーションや最新のマイクロサービスアーキテクチャで広く使用されており、異なるマイクロサービス間の非同期メッセージチャネルとして機能します。このガイドでは、複数のCentOS 7サーバーでRabbitMQをクラスター化して、高可用性メッセージブローカーを形成する方法について説明します。このチュートリアルでは、マスターサーバーが使用できなくなった場合に備えて、1つのサーバーがマスターサーバーとして機能し、他のサーバーがミラーサーバーとして機能します。

前提条件

• プライベートネットワーキングが有効になっている同じサブネット内に、新しく導入および更新された少なくとも2つのCentOS 7インスタンス
• 各サーバーで管理コンソールを有効にしてインストールされたRabbitMQ（CentOS 7にRabbitMQをインストールする方法を参照）
• sudo権限を持つ管理者以外のユーザー（Debian、CentOS、およびFreeBSDでSudoを使用する方法を参照）

ファイアウォールを構成する

CentOSファイアウォール（firewalld）は、デフォルトでは着信トラフィックを許可しません。RabbitMQをネットワーク内外の他のシステムで使用できるようにし、管理コンソールにアクセスできるようにするには、まずいくつかのポートを開く必要があります。

RabbitMQのWebインターフェース管理コンソールは、デフォルトでポートで待機します15672。コンピュータからアクセスできるように、管理コンソールを公開します。したがって、パブリックゾーン（Vultrインスタンスのデフォルトでアクティブなゾーン）でfirewalldポートを永続的に開くように指示し15672ます。

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

rabbitmqadmin管理プラグインには、管理プラグインが有効になるとシステムに簡単にインストールできるPythonツールが付属しています。

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

DNSを構成する

クラスタリング時にサーバーを識別するには、サーバーのホスト名を使用する必要があります。デフォルトでは、サーバーにはDNSレコードが割り当てられておらず、接続は失敗します。これをすばやく解決するには/etc/hosts、お気に入りのエディターを使用して、マスターとミラーのホスト名をファイルに追加します。

たとえば、マスターのhostsファイルは次のようになります。最後の2つのレコードに注目してください。これにより、サーバーはホスト名でお互いを識別できます。必ず自分の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 Cookieが同一であることです。デフォルトでは、各ノードには一意のErlang Cookieが割り当てられるため、すべてのノードで再構成する必要があります。

次のコマンドはErlangクッキーを " WE<3COOKIES"に設定しますが、これを自由に変更してください。すべてのサーバーでこれを行います。

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

すべてのサーバーでRabbitMQを再起動して、Erlang Cookieが正しくリロードされることを確認します。

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"}'

正規表現を変更して、異なるポリシーを異なるキューに割り当てることができます。次の3つのノードがあるとします。

• rabbit @ master
• rabbit @ client-ha
• rabbit @ product-ha

次に、「client」rabbit@client-haで始まる名前のキューがノードにミラーリングされる2つのポリシーを作成し、「product」で始まる名前のすべてのキューを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

これ/により、名前がのデフォルトの仮想ホストに永続キューが作成されます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