how-to-install-and-configure-nats-on-ubuntu-16-04

Posted on: 2019-11-08 2019-11-19
Tags: Applications, High Availability, Monitoring, Node.js, Scaling, Ubuntu 16.04

前書き

NATSは、オープンソースの高性能メッセージングシステムであり、「クラウドの中枢神経システム」と呼ばれることがよくあります。 1秒間に数百万のメッセージをルーティングできるため、マイクロサービスと_IoT_（モノのインターネット）デバイスの接続に最適です。

NATSはPub Subメッセージングシステムです。この種のシステムでは、1つ以上の_publishers_が特定のサブジェクトを含むメッセージを_message broker_に送信し、メッセージブローカーがこれらのメッセージを任意のクライアントまたは特定のサブジェクトの_subscribers_に配信します。パブリッシャーはサブスクライバーを知りませんし、気にしません。その逆も同様です。このアーキテクチャにより、システムの残りの部分に影響を与えることなくパブリッシャーとサブスクライバーを追加できるため、システムのスケーリングと新しい機能の追加が容易になります。このタイプのシステムは、サーバーとデバイスの監視に最適です。デバイスはメッセージを送信でき、電子メールまたはその他の手段で通知を送信するためにそれらのメッセージを購読できます。

このチュートリアルでは、公式のNATSサーバーである `+ gnatsd `をサービスとしてインストールし、安全な方法でアクセスできるようにします。また、メッセージブローカーとして「 gnatsd +」を使用して、サーバーの負荷が高くなりすぎると電子メールを送信する基本的なサーバーオーバーロード警告システムを作成します。

前提条件

このチュートリアルを完了するには、次のものが必要です。

新しいUbuntu 16.04サーバー。
`+ sudo +`特権を持つ標準ユーザーアカウント。 Ubuntu 16.04での初期サーバー設定に従って標準アカウントを設定できます。

ステップ1-NATSサーバーのダウンロード

まず、 `+ gnatsd +`サーバーをダウンロードし、問題なくシステムで実行されることを確認します。

最新の安定した `+ gnatsd +`リリースは、このチュートリアルが作成された時点ではバージョン0.9.4です。 NATSダウンロードページで新しいバージョンを確認し、新しいバージョンを使用する場合は、必要に応じて以下のコマンドを調整できます。

最初に、非ルートアカウントでサーバーにログインします。

ssh @

次に、ユーザーのホームディレクトリにいることを確認します。

cd

次に、 `+ wget `を使用して ` gnatsd +`をサーバーにダウンロードします。

wget https://github.com/nats-io/gnatsd/releases/download/v/gnatsd-v-linux-amd64.zip

ダウンロードしたアーカイブは圧縮されたアーカイブであるため、ファイルを抽出するには「+ unzip 」をインストールする必要があります。 ` apt +`でインストールできます：

sudo apt-get install -y unzip

次に、 `+ unzip `を使用して ` gnatsd +`を抽出します。

unzip -p gnatsd-v-linux-amd64.zip gnatsd-v-linux-amd64/gnatsd > gnatsd

次に、実行できるように `+ gnatsd +`を実行可能にします：

chmod +x gnatsd

現在のディレクトリから実行することで、 `+ gnatsd `を実行できることをテストしてみましょう。次のコマンドを使用して、 ` gnatsd +`を開始します。

./gnatsd --addr 127.0.0.1 --port 4222

表示される出力は、次の例のようになります。

Output[1851] 2016/09/23 05:20:02.247420 [INF] Starting nats-server version 0.9.4
[1851] 2016/09/23 05:20:02.248182 [INF] Listening for client connections on
[1851] 2016/09/23 05:20:02.248626 [INF] Server is ready

デフォルトでは、 `+ gnatsd `はすべてのインターフェースに対応するアドレス ` 0.0.0.0 `のポート ` 4222 `でリッスンします。 `-port `引数を使用してポートを変更でき、 `-addr `を使用してリッスンするアドレスを変更できます。 `-addr 127.0.0.1 `で ` gnatsd `を実行したため、サーバー内でのみ使用でき、外部クライアントからはアクセスできません。チュートリアルの後半で、 ` gnatsd +`を保護し、世界中に公開します。

`+ CTRL + C `を押して ` gnatsd +`をシャットダウンします。

動作することがわかったので、より正式な方法で設定してみましょう。

手順2-ディレクトリ構造と構成ファイルの作成

サードパーティのLinuxでは、サービス関連のソフトウェアはしばしば `+ / srv `ディレクトリに保存されます。その規則に従い、NATS関連のファイルを ` / srv / nats `の下に保持します。 ` gnatsd `実行可能ファイルを ` / srv / nats / bin +`に配置します。

最初に、 `+ / srv / nats / bin +`フォルダを作成します：

sudo mkdir -p /srv/nats/bin

次に、 `+ gnatsd `を ` / srv / nats / bin +`フォルダーに移動します。

sudo mv ~/gnatsd /srv/nats/bin

サーバーは、その構成をファイルからロードできます。これは、チュートリアルの後半でサーバー設定を変更する必要がある場合に便利です。ファイル `+ / srv / nats / gnatsd.config +`を作成します。

sudo nano /srv/nats/gnatsd.config

そして、次の内容をファイルに追加します。

/srv/nats/gnatsd.config

port: 4222
net: '127.0.0.1'

この設定ファイルは、以前と同様に、アドレス「127.0.0.1」のポート「4222」でリッスンするように「+ gnatsd +」サーバーに指示しますが、今回はコマンドラインでこれらのオプションを指定する必要はありません。

サーバーを再度実行して、設定が正しいことを確認します。次のコマンドを実行して、新しい構成ファイルを使用して `+ gnatsd +`を起動します。

/srv/nats/bin/gnatsd -c /srv/nats/gnatsd.config

出力は、前に見たものに似ています：

Output[1869] 2016/06/18 05:30:55.988856 [INF] Starting nats-server version 0.9.4
[1869] 2016/06/18 05:30:55.989190 [INF] Listening for client connections on
[1869] 2016/06/18 05:30:55.989562 [INF] Server is ready

もう一度、「+ CTRL + C 」を押して「 gnatsd +」をシャットダウンし、プロンプトに戻ります。次に、このサービスを実行するユーザーを作成しましょう。

ステップ3-サービスユーザーの作成

サービスが侵害された場合の損害を制限するために、独自のユーザーアカウントで各サービスを実行することは、セキュリティ上の良い習慣です。 NATSサービスとNATS関連のファイルを所有するユーザーとグループを作成しましょう。

まず、 `++`というシステムユーザーとグループを作成しましょう。

sudo adduser --system --group --no-create-home --shell /bin/false nats

OutputAdding system user `nats' (UID 106) ...
Adding new group `nats' (GID 114) ...
Adding new user `nats' (UID 106) with group `nats' ...
Not creating home directory `/home/nats'.

`+ nats `システムユーザーに ` / bin / false `シェルを割り当てて、このユーザーのログインを無効にし、ホームディレクトリの作成を抑制しました。また、 ` nats +`グループも作成しました。

`+ / srv `ディレクトリの所有者を ` nats +`ユーザーとグループに変更しましょう：

sudo chown -R nats:nats /srv

`+ nats +`ユーザーとグループを作成したので、NATSサービスの作成を続けましょう。

ステップ4-サービスとしてgnatsdを実行する

システムの起動時に `+ gnatsd +`を起動し、クラッシュした場合は再起動したいと思います。 _systemd_を使用してこれを処理します。

systemdは、Linuxシステムのサービスマネージャーです。起動時にサービスを開始し、必要に応じてサービスを再起動し、システムのシャットダウン時に制御された方法でサービスを停止します。

NATSサービスを開始する方法と時期を定義するために、サービス構成を作成する必要があります。ユーザーが作成したサービスファイルは `+ / etc / systemd / system `にあるため、ファイル ` / etc / systemd / system / nats.service +`を作成します。

sudo nano /etc/systemd/system/nats.service

そして、ファイルにこのスクリプトを配置して、 `+ gnatsd +`の起動方法を定義します。

/etc/systemd/system/nats.service

[Unit]
Description=NATS messaging server

[Service]
ExecStart=/srv/nats/bin/gnatsd -c /srv/nats/gnatsd.config
User=nats
Restart=on-failure

[Install]
WantedBy=multi-user.target

`+ [Unit] `セクションには、サービスを説明する ` Description +`など、サービスに関する一般的な情報が含まれます。
`+ [Service] `セクションには、サービス関連の設定が含まれています。 ` ExecStart `はサーバーを実行するコマンドです。ここでは、 ` gnatsd `実行可能ファイルの絶対パスを使用します。 ` Restart = on-failure`は、サービスがクラッシュまたは障害で終了した場合、サービスを再起動する必要があることを意味します。 systemdによって停止された場合、再起動されません。
+ [Install] +`セクションには、サービスに関するインストール情報が含まれています。 `+ WantedBy = multi-user.target`は、 + multi-user.target`の開始時にsystemdにサービスを開始するように指示します。これは、システム起動時にサービスを開始する一般的な方法です。

サービスの説明を作成したら、次のコマンドで開始できます。

sudo systemctl start

`+ PING `メッセージを送信して、 ` gnatsd +`が実行されていることを確認しましょう：

printf "PING\r\n" | nc 127.0.0.1 4222

`+ nc `を使用して ` gnatsd `と通信しました。 ` nc +`は、TCPまたはUDPサーバーと通信するためのコマンドラインユーティリティです。使用したコマンドは、次のような出力を出力します。

OutputINFO {"server_id":"Os7xI5uGlYFJfLlfo1vHox","version":"0.9.4","go":"go1.6.3","host":"127.0.0.1","port":4222,"auth_required":false,"ssl_required":false,"tls_required":false,"tls_verify":false,"max_payload":1048576}

応答 `+ PONG +`により、サーバーが期待どおりにリッスンして動作していることがわかります。 NATSサーバーをブート時に起動するには、最後の1つのコマンドを実行する必要があります。

sudo systemctl enable

サービスがインストールされたことを確認する次の出力が表示されます。

OutputCreated symlink from /etc/systemd/system/multi-user.target.wants/nats.service to /etc/systemd/system/nats.service.

サービスとして実行するように `+ gnatsd +`を正常に設定しました。次に、セキュリティを確保して、外部クライアントがアクセスできるようにします。

ステップ5-NATSサービスへの接続の保護

`+ gnatsd `で使用したいすべてのパブリッシャーとサブスクライバーが同じサーバー上で実行されていた場合、それを呼び出して先に進むことができますが、最近はほとんどありません。外部クライアントが安全な方法でメッセージを「 gnatsd +」に接続して公開できるようにする必要があります。

`+ gnatsd `はTLSトランスポートをサポートしているため、これを使用して ` gnatsd +`とNATSクライアント間の通信を保護します。

まず、証明書が必要です。商用証明書を購入するか、http：//letsencrypt.org [Let’s Encrypt]から取得するか、自己署名証明書を生成できます。証明書の取得はこの記事の範囲外であるため、後者のアプローチを使用します。

証明書を一時的に保持するディレクトリを作成します。

mkdir ~/priv

次に、次のコマンドで自己署名証明書を作成します。

openssl req -x509 -nodes -days 3650 -newkey rsa:2048 \
   -keyout priv/gnatsd.key -out priv/gnatsd.crt \
   -subj "/C=US/ST=/L=/O=/CN=www."

このコマンドは、2048ビットで有効期間が10年のRSA証明書を作成します。この記事では `+ gnatsd +`サーバーのTLS検証を有効にしないため、任意のドメイン名を使用していることに注意してください。

これで、 `〜/ priv +`ディレクトリにファイル ` gnatsd.key `と ` gnatsd.crt `があるはずです。これらのファイルを「 / srv / nats / +」ディレクトリ構造の下に移動して、すべてが1つの場所に収まるようにします。次のコマンドを実行してください。

sudo mv ~/priv /srv/nats

ここで、 `+ nats `ユーザーとグループのみが ` / srv / nats / priv +`にアクセスできるようにします：

sudo chmod 440 /srv/nats/priv/*
sudo chmod 550 /srv/nats/priv
sudo chown -R nats:nats /srv/nats/priv

ここで、作成した証明書とキーを含むように `+ / srv / nats / gnatsd.config +`を更新します。構成ファイルを再度開きます。

sudo nano /srv/nats/gnatsd.config

そして、次のセクションを追加して、 `+ gnatsd +`に証明書とキーを使用するように指示します。

/srv/nats/gnatsd.config

. . .

tls {
 cert_file: ""
 key_file: ""
 timeout: 1
}

ファイルを保存し、エディターを終了します。次に、サービスを再起動して、変更を反映できるようにします。

sudo systemctl restart

証明書が機能することをテストしてみましょう。このコマンドを実行してください。

printf "PING\r\n" | nc localhost 4222

今回、コマンドは次のメッセージを出力します。

OutputINFO {"server_id":"npkIPrCE5Kp8O3v1EfV8dz","version":"0.9.4","go":"go1.6.3","host":"127.0.0.1","port":4222,"auth_required":false,"ssl_required":true,"tls_required":true,"tls_verify":false,"max_payload":1048576}

サーバーは、「+-ERR ‘Secure Connection-TLS Required’ +」というメッセージを返しました。これは、新しい構成が選択され、安全な接続が必要であることを確認します。

本格的なNATSクライアントをインストールせずにNATSサービスと通信できるようにするには、_catnats_というツールを使用します。最初にダウンロードしましょう：

wget https://github.com/yuce/catnats/raw/0.1.2/catnats.py

実行可能にします。

chmod +x catnats.py

最後に、 `+ catnats.py `を ` / srv / nats / bin `フォルダーに移動し、名前を ` catnats +`に変更します。

sudo mv catnats.py /srv/nats/bin/catnats

以前に送信したものと同じ `+ PING `メッセージを送信することにより、 ` catnats +`を使用してNATSサービスと通信できることを確認しましょう。

printf "PING\r\n" | /srv/nats/bin/catnats --addr 127.0.0.1:4222

接続が安全であることを示す次の出力が表示されます。

OutputINFO {"server_id":"npkIPrCE5Kp8O3v1EfV8dz","version":"0.9.4","go":"go1.6.3","host":"127.0.0.1","port":4222,"auth_required":false,"ssl_required":true,"tls_required":true,"tls_verify":false,"max_payload":1048576}

通信を保護したので、認証を有効にして、NATSへの接続にユーザー名とパスワードが必要になるようにします。

ステップ6-認証を要求する

NATSサービスはデフォルトで認証を必要としません。これは、サービスがプライベートネットワークでのみアクセス可能な場合は問題ありませんが、認証を有効にする必要があるため、インターネットでNATSサービスにアクセスできるようにする必要があります。 `+ gnatsd +`はユーザー名とパスワードの認証をサポートしており、簡単に有効にできます。

`+ / srv / nats / gnatsd.config +`ファイルを開きます：

sudo nano /srv/nats/gnatsd.config

クレデンシャルを指定する新しい `+ authorization +`セクションを追加します。このチュートリアルでは、ユーザー名として「」を、パスワードとして「」を使用します。実稼働環境では、より長く複雑なパスワードを使用する必要があります。

/srv/nats/gnatsd.config

. . .

authorization {
 user:
 password:
}

ファイルを保存し、システム上の他のユーザーからユーザー名とパスワードを保護するために、 `+ / srv / nats / gnatsd.config `の所有者を ` nats +`に変更し、そのユーザーが読み取れるようにします。

sudo chown nats /srv/nats/gnatsd.config
sudo chmod 400 /srv/nats/gnatsd.config

次に、変更を有効にするためにサービスを再起動します。

sudo systemctl restart nats

「+ PING 」メッセージを「 gnatsd 」に送信して、すべてが正常かどうかを確認しましょう。もう一度、 ` catnats +`を使用してメッセージを送信します。

printf "PING\r\n" | /srv/nats/bin/catnats --addr 127.0.0.1:4222

次の出力が表示されます。

OutputNFO {"server_id":"sY0SSJBNbEw53HxzS9mH1t","version":"0.9.4","go":"go1.6.3","host":"127.0.0.1","port":4222,"auth_required":true,"ssl_required":true,"tls_required":true,"tls_verify":false,"max_payload":1048576}

これにより、変更が正常に適用され、サービスに接続するために正しいユーザー名とパスワードを送信する必要があることがわかります。もう一度試してみましょう。今回はユーザー名「」とパスワード「」を指定します。

printf "PING\r\n" | /srv/nats/bin/catnats --addr 127.0.0.1:4222 --user  --pass

今回は、次の出力からわかるように機能しました。

OutputINFO {"server_id":"sY0SSJBNbEw53HxzS9mH1t","version":"0.9.4","go":"go1.6.3","host":"127.0.0.1","port":4222,"auth_required":true,"ssl_required":true,"tls_required":true,"tls_verify":false,"max_payload":1048576}

ユーザー名とパスワードを知っているクライアントにこのサービスを制限したので、外部クライアントが接続できるようにサービスを再構成できます。

ステップ7-サービスを世界に公開する

NATSサーバーは、ローカルインターフェイスである「127.0.0.1」でリッスンするように設定しました。「0.0.0.0」でリッスンさせると、世界中で利用可能になります。最後に `+ / srv / nats / gnatsd.config +`を更新しましょう：

sudo nano /srv/nats/gnatsd.config

次に、「+ net +」設定に関連付けられているIPアドレスを変更します。

/srv/nats/gnatsd.config

. . .
net: ''
. . .

ファイルを保存して、サービスを再起動します。

sudo systemctl restart nats

これで、NATSサービスは外部クライアント接続の準備ができました。使い方を学ぶために、NATSサーバーをメッセージブローカーとして使用する簡単な監視サービスを作成しましょう。

ステップ8-（オプション）サーバーの過負荷に関する通知の構成

このセクションでは、NATSサービスを利用する簡単な過負荷監視システムを作成します。システムは、サーバーの平均負荷を受け取り、サーバーのいずれかが過負荷になった場合に管理者にメールを送信します。

サンプルプロジェクトは、次のコンポーネントで構成されます。

構成したばかりのNATSサービス。
ホスト名、負荷平均、およびサーバーのプロセッサ数を60秒ごとに「+ stats.loadaverage +」サブジェクトに公開する_monitor_。負荷を監視するサーバーでこのコンポーネントを実行する必要があります。
notifier。これは、 `+ stats.loadaverage +`サブジェクトにサブスクライブし、サーバーのホスト名、負荷平均、およびプロセッサー数を受け取ります。ホストの負荷平均が特定のしきい値を超えている場合、通知者はSMTPサーバーを介して事前定義されたアドレスに電子メールを送信します。

簡単にするためにこれらすべてのコンポーネントを同じサーバーで実行しますが、このチュートリアルを完了したら、各コンポーネントを異なるサーバーで実行してみてください。

モニターのセットアップ

Linuxシステムの平均負荷は、「+ / proc / loadavg +」から読み取ることができます。このプロジェクトでは、出力の最初のフィールドである直前の負荷平均のみに関心があります。この値を取得するには、次のコマンドを使用します。

cat /proc/loadavg | cut -f1 -d" "

次の出力が表示されます。

Output0.11

「+ / proc / loadavg +」を読み取ることで得られる負荷平均は、プロセッサの数に依存するため、負荷平均をプロセッサの数で割って正規化する必要があります。次のコマンドを使用して、サーバーのプロセッサカウントを取得できます。

getconf _NPROCESSORS_ONLN

端末に結果が表示されます：

Output1

サーバーのデフォルトシェルは浮動小数点演算を処理できないため、メッセージのペイロードとしてホスト名とともに負荷平均とプロセッサ数の両方を送信し、後で通知機能で分割します。ペイロードを構築するために使用するコマンドは次のとおりです。

echo $(hostname) `cat /proc/loadavg | cut -f1 -d" "` `getconf _NPROCESSORS_ONLN`

このコマンドは、ホスト名、負荷平均、およびプロセッサ数をそれぞれ表示します。

Output 0.28 1

ホスト名、負荷平均、プロセッサ数をサブジェクト `+ stats.loadaverage `でNATSサーバーに公開するシェルスクリプトを作成しましょう。このスクリプトを定期的に実行するようにシステムを構成します。 `〜/ publish_load_average.sh +`という名前の新しいファイルを作成します。

nano ~/publish_load_average.sh

ファイルに次のスクリプトを追加します。

〜/ publish_load_average.sh

NATS_ADDR=
LOADAVG=
NPROC=
SUBJECT=
PAYLOAD=
MESSAGE=
printf "$MESSAGE" | /srv/nats/bin/catnats -q --raw --addr $NATS_ADDR --user  --pass

このスクリプトはメッセージを作成し、それを `+ catnats `にパイプし、NATSサービスにメッセージを公開します。「 -q 」スイッチを指定して「 catnats 」を実行し、出力を抑制します。「-raw 」スイッチを使用して、「 catnats 」が入力内容を解釈しないようにします。 NATSサービスが別のサーバー上にある場合、 ` $ NATS_ADDR +`変数の値を変更できます。

スクリプトが負荷平均をNATSに送信することをテストしてみましょう。

次のコマンドは、5秒ごとに `〜/ publish_load_average.sh +`を実行します。行末で `＆+`文字を使用して、バックグラウンドでコマンドを実行することに注意してください。

while true; do sh ~/publish_load_average.sh; sleep 5; done &

コマンドがプロセスIDでバックグラウンドで実行されていることを示す出力が表示されます。

Output[1]

次に、NATSに接続し、サブジェクト `+ stats.loadaverage +`をサブスクライブして、負荷平均を取得します。

printf "SUB stats.loadaverage 0\r\n" | /srv/nats/bin/catnats --raw --no-exit --pong --user  --pass

`-no-exit +`フラグを使用して自動終了を無効にし、 `-pong +`を使用してNATSへの接続を維持します。すべてが正しい場合、5秒ごとに更新される次のような出力を取得する必要があります。

OutputINFO {"server_id":"A8qJc7mdTy8AWBRhPWACzW","version":"0.8.1","go":"go1.6.2","host":"0.0.0.0","port":4222,"auth_required":true,"ssl_required":true,"tls_required":true,"tls_verify":false,"max_payload":1048576}
+OK
+OK
MSG stats.loadaverage 0 27

`+ CTRL + C `を押して ` catnats `を終了します。 ` publish_load_average.sh `を実行するより良い方法があるので、 ` publish_load_average.sh +`を呼び出したループも停止しましょう。

kill

私たちが今採用したアプローチはテストには最適ですが、永続的に使用したいものではありません。システムが毎分実行するために `+ publish_load_average.sh `を実行したいと思います。それを実現するために、_crontab_エントリを追加できます。 Linuxシステムは、指定したスケジュールでコマンドまたは「ジョブ」を実行できるシステムである ` cron `を使用します。 ` crontab +`コマンドを使用すると、これらのジョブを管理できます。 Cronのすべてについては、チュートリアルhttps://www.digitalocean.com/community/tutorials/how-to-use-cron-to-automate-tasks-on-a-vps[Cronを使用してタスクを自動化する方法]で学ぶことができます。 VPSで]。

新しいエントリを作成するには、次のコマンドを実行します。

crontab -e

上記のコマンドを実行したことがない場合は、次のプロンプトが表示され、エントリを管理するためのテキストエディターを選択するよう求められます。

Outputno crontab for demo - using an empty one

Select an editor.  To change later, run 'select-editor'.
 1. /bin/ed
 2. /bin/nano        <---- easiest
 3. /usr/bin/vim.basic
 4. /usr/bin/vim.tiny

Choose 1-4 [2]:

最も使いやすいエディタに対応する番号を入力し、 `+ ENTER`を押します。選択したエディターにファイルが表示されます。

開いたファイルの最後に次の行を追加しますが、「++」以外の何かを使用した場合はユーザー名を置き換えます：

*/1 * * * * bash /home//publish_load_average.sh

上記のエントリは、 `+ publish_load_average.sh `スクリプトを毎分実行するように ` cron +`に指示します。ファイルを保存し、エディターを閉じます。

次に、負荷平均の定期的な公開が機能していることをテストします。

printf "SUB stats.loadaverage 0\r\n" | /srv/nats/bin/catnats --raw --no-exit --pong --user  --pass

数分待つと、表示される出力は次のようになります。

OutputINFO {"server_id":"A8qJc7mdTy8AWBRhPWACzW","version":"0.8.1","go":"go1.6.2","host":"0.0.0.0","port":4222,"auth_required":true,"ssl_required":true,"tls_required":true,"tls_verify":false,"max_payload":1048576}
+OK
+OK
MSG stats.loadaverage 0 27

MSG stats.loadaverage 0 27

`+ CTRL + C `を押して ` catnats +`を終了します。

モニターのセットアップに成功し、NATSサーバーにメッセージを送信しています。次に、このデータを使用する通知機能を設定します。

Notifierの作成

NATSサービスに接続し、 `+ stats.loadaverage +`メッセージをリッスンする通知機能を作成しましょう。プログラムがメッセージを受信するたびに、プロセッサごとの負荷平均を計算します。 0.6またはプロセッサあたり60％のCPU使用率よりも高い場合、メッセージを発行したホストに警告フラグを設定し、事前定義されたアドレスに電子メールを送信します。プロセッサごとの負荷平均が0.4未満の場合、ホストの警告フラグはクリアされます。受信ボックスのフラッディングを防ぐために、警告フラグが設定されている場合は1つのメールを送信します。

Node.js用の優れたNATSクライアントがあるため、Node.JSを使用してノーティファイアを作成します。そのため、最初にNode.jsをインストールします。

sudo apt-get install -y npm

次に、通知機能のディレクトリを作成し、切り替えます。

mkdir ~/overload_notifier && cd ~/overload_notifier

Node.jsプロジェクトは、プロジェクトとその依存関係に関する情報を含む「+ package.json +」というファイルを使用します。次のコマンドを実行して、そのファイルを作成します。

npm init -y

次に、Node.js用のNATSクライアントと、このプロジェクトで警告メールを送信するために使用する `+ nodemailer +`モジュールをインストールします。

npm install [email protected] [email protected] --save-exact

これで、通知機能を作成できます。ファイル `+ notifier.js +`を作成します。

nano notifier.js

次に、次のコードをファイルに追加します。

notifier.js

var NATS_URL = 'nats://127.0.0.1:4222';
var NATS_USER = '';
var NATS_PASS = '';
var EMAIL_TO = '';

NATSサービスのユーザー名とパスワード、および電子メールアドレスと一致するようにこれらのオプションを変更してください。

次に、このコードを追加してNode.js NATSクライアントをインポートし、 `+ gnatsd +`サービスに接続します。

notifier.js

var tlsOptions = {
 rejectUnauthorized: false,
};
var nats = require('nats').connect({url: NATS_URL,
                                   tls: tlsOptions,
                                   user: NATS_USER,
                                   pass: NATS_PASS});

次に、このコードを追加してメーラーをセットアップし、メールを送信するSMTPサーバーに接続します。このサーバーをすぐにセットアップします。

notifier.js

var nodemailer = require('nodemailer');
var transport = nodemailer.createTransport('smtp://localhost:2525');

次に、残りのコードを追加して負荷平均を計算し、通知メールを送信する必要があるかどうかを判断します。

notifier.js

// keep the state of warnings for each host
var warnings = {};

function sendEmail(subject, text) {
   transport.sendMail({
       to: EMAIL_TO,
       subject: subject,
       text: text
   });
}

function processMessage(message) {
   // message fields: host load processor_count
   var fields = message.split(" ");
   var host = fields[0];
   var loadAverage = parseFloat(fields[1]) / parseInt(fields[2]);
   if (loadAverage > 0.6) {
       if (!warnings[host]) {
           // send warning email if one wasn't already sent
           var res = sendEmail('Warning! Server is Overloaded: ' + host,
                               'Load average: ' + loadAverage);
           // set warning for the host
           warnings[host] = true;
       }
   }
   else if (loadAverage < 0.4) {
       if (warnings[host]) {
           // clear the warning
           warnings[host] = false;
       }
   }
}

nats.subscribe('stats.loadaverage', processMessage);

メッセージをサブスクライブし、メッセージを受信するたびに、送信したペイロードを解析して負荷平均を決定する「+ processMessage +」関数を実行します。高すぎる場合はメッセージを送信し、ホスト名に基づいてフラグを設定することで以前に送信したかどうかを追跡します。このようにして、ホストごとに通知を追跡できます。負荷平均がしきい値を下回っている場合、そのフラグをクリアします。

モニターと通知機能を配置したら、サンプルプロジェクトをテストします。

プロジェクトのテスト

これを試乗してみましょう。人工的な負荷を生成し、負荷が高くなりすぎたときに通知者が警告メールを送信するかどうかを確認します。

サーバーにCPU負荷を生成するために、「+ stress +」ツールをインストールしましょう。

sudo apt-get install -y stress

次に、通知機能からメッセージをメールで送信するようにSMTPサーバーを設定する必要があります。本格的なSMTPサーバーをインストールして構成することは、このテストではやり過ぎになるため、実際に送信する代わりに、渡された電子メールを表示するだけの単純なSMTPサーバーを使用します。 Pythonプログラミング言語には、受信したメールを破棄するがロードできる「+ DebuggingServer +」モジュールがありますが、画面に表示されるので、確実に機能します。 PythonはすでにUbuntuサーバーにインストールされているため、これは完璧なソリューションです。

バックグラウンドでSMTPサーバーのデバッグを開始しましょう。「+ notifier.js 」コードで設定したSMTPアドレスと一致する「 localhost 」ポート「+2525」でリッスンするようにします。次のコマンドを実行して、SMTPサーバーを起動します。

python -m smtpd -n -c DebuggingServer localhost:2525 &

次に、次のコマンドを使用して、バックグラウンドで通知機能を起動します。

nodejs ~/overload_notifier/notifier.js &

最後に、サーバーのすべてのプロセッサに負荷をかけましょう。次のオプションを使用して、 `+ stress +`コマンドを実行します。

stress --cpu $(getconf _NPROCESSORS_ONLN)

数分後に、SMTPサーバーがノーティファイアによって送信されたメッセージの表示を開始すると、次のような出力が表示されます。

Output---------- MESSAGE FOLLOWS ----------
Content-Type: text/plain
To:
Subject: Warning! Server is Overloaded:
Message-Id: <[email protected]>
X-Mailer: nodemailer (2.4.2; +http://nodemailer.com/;
SMTP/2.5.0[client:2.5.0])
Content-Transfer-Encoding: 7bit
Date: Sun, 19 Jun 2016 16:47:02 +0000
MIME-Version: 1.0
X-Peer: 127.0.0.1


------------ END MESSAGE ------------

これにより、サーバーの負荷が高くなりすぎたときにメールを正常に送信したことがわかります。

負荷の生成を停止するには、 `+ CTRL + C +`を押します。サンプルプロジェクトを完了しました。これで、ご使用の環境でこの作業を行う方法を十分に理解できるはずです。

結論

この記事では、NATS PubSubメッセージングシステムについて学び、安全な方法でサービスとしてインストールし、サンプルプロジェクトでテストしました。サンプルプロジェクトではNode.JSクライアントを使用しましたが、NATSには、http：//nats.io/download [NATSダウンロードページ]にリストされている他の言語およびフレームワークのクライアントがあります。 NATSの詳細については、http：//nats.io/documentation/ [公式ドキュメント]をご覧ください。