船に強い風が吹きました。 小さい水しぶきと雨滴により、メガネの下のわずかにひげを剃っていない顔が目を細めました。 寒いだけではありませんでした。あらゆる場所に寒さが浸透しました。 ジャケットの下にパンツ。 彼の手は麻痺し、血が凍った。 しかし、船乗りは岬のどこかに静かな島があり、悪天候を待つことができることを知っていました。

海岸は枯れた乗組員に木の音とreのささやきで出会った。 人々は、休息し、洗って、要素との闘いを続ける日が1日しかないことを知っていました。







しかし、サバイバルタスクを欠く、沈黙と自然との一致のまさにこの瞬間に、参加者の一人である人生のプログラマーの脳は復geの問題を探し始めました。 それは著者の脳であり、彼はそのアイデアを生み出しました...

まえがき

7ノットの平均速度で、5日間で船上で楽しむことができました。

はじめに

プログラマーの職業上の幸福は非常に簡単です-あなたの好きな言語で面白いタスクを書いて、それのためにお金を受け取ること（できれば小さくはないが、常にお金は少ないが）。 このような要望は、 SOA （特にSOAP / WSDL / XML-RPC / JSON-RPCなど）、REST、マイクロサービスアーキテクチャなど、スタンドアロンアプリケーションとそれらの間の交換プロセスという形でアプローチ全体が生まれたという事実につながりました。 一番下の行は、Unixの原則に従って、個別の機能がアプリケーションに割り当てられ、それらの間のデータ交換が個別に指定されるということです。

私の趣味の1つは、スマートホーム、コンピューティングシステム、およびその他の同様のタスクなど、小さなモジュールの分散ネットワークの作業に関連しています。 それらの間の通信には、中央のメッセージブローカーを使用すると便利です。 典型的なソリューション： RabbitMQ 、Redis、 ActiveMQおよびその他の同様のソリューション。 業界のモンスターには、 IBM Broker、IBM MQ 、 Tibcoなどがあります。

しかし、私はそれらについて好きではなかったもの

既存のソリューションの致命的な欠陥

• Apache Active MQおよびその他のJavaベースのブローカー。 開始時に少なくとも100MB-怒りは16GBのRAMでさえもかかります。 私はJavaに対して何もありませんが、それでも...
• IBM、Tibcoおよびその他。 それはそんなにお金になるだろう-私は何か他のものにそれを使うだろう。
• Rabbit MQ、Redis 。 おそらく最も正しい選択肢ですが、私は休暇中です。つまり、これは私たちのやり方ではありません。

選択は、シンプルでプロトコルルーターメッセージを使用した、リソース消費の少ない、ユニバーサルで高速な独自の実装に基づいています。

コンポーネント

メッセージングを容易にするためのZeroMQ形式の通信層。

プログラミング言語には問題があります。 JVMベースのPython、Rubyは、仮想マシンのために一掃されています。これは、過剰なリソース消費を意味します。 Rustが欲しかったのですが、実装を開始した後、標準ライブラリがさらに安定するまで待たなければならないことに気付きました。 Go-zmqのネイティブ実装があれば素晴らしいでしょう。 結果はC ++ / Cです。

主な実装

ブローカーの構成は次のとおりです。

• サービス-要求への応答モードで動作するパーソナライズされたクライアント（ZMQ_DEALER）
• クライアント-匿名クライアント（ZMQ_REQ）。ブローカーを通じてサービスへのリクエストを処理し、応答を待ちます。

ブローカー接続ポイントは、ROUTERタイプのソケットです。 （クライアントから）REQソケットからデータを受信すると、一意のクライアントコードを含むメッセージが生成されます。 次に、サービス名、顧客番号、その他のデータで構成されるサービスへのリクエスト用のパッケージが作成されます。 概略的には、これは次のように表すことができます。







コードはGitHubで表示できます。

二次実装

実装は非常に単純に見えました。 問題の別の部分を見つけて解決する必要がありました。

同じ名前の複数のサービスインスタンスを使用する方法

負荷分散と耐障害性に適しています。

実際、DEALER-to-ROUTERモードで同じ接続名を使用すると、最後の接続のみが使用されます。

ソリューションは、ブローカーに接続し、DEALER-to-DEALERモードで個別の接続ポイントを作成するサービスごとに個別のロードバランサーです。 この場合、サービスの場合、接続アドレスをブローカーではなくバランサーに変更するだけで十分です。







コードはgithubにあります

HTTP経由でサービスへのアクセスを提供する方法は？

少なくともスマートトースターを介して作業する能力を考えれば、HTTPインターフェースに対する人々の大いなる愛を考えれば、それは無意味ではありません。正しく実行する必要があります。json/プレーン出力、GETおよびPOSTリクエストの両方のサポート、すべての消防士のJSONPです。

Pocoライブラリを使用すると、別のデーモンとして実装されることがわかりました。

• GET要求またはPOST本体のargsパラメーターには、JSON配列が含まれている必要があります。
• オプションのタイムアウトパラメータは、ミリ秒単位の最大応答時間です。
• オプションのパラメータータイプ-戻りデータタイプ-プレーンまたはjson
• オプションのjsonpまたはcallabackパラメーター-JSON-Pリクエストの関数名

コードはgithubにあります

優れた管理者を作り、プログラムに消極的な人を作るにはどうすればいいですか？

他のプログラムを呼び出し、メッセージフィールドを引数として渡し、出力を回答として解釈するデーモンを作成します。 このようなCGIによって簡素化されます。







コードはgithubにあります

さらに改善する方法は？

コンソールからすべてのサービスにアクセスします。 プレーン/ hex / base64 / json入出力を使用。







ここのコードはgithubです

すべての組み立て

GIT + CMake +メイク

 git clone https://github.com/reddec/waha.git && cd waha && mkdir build && cd build
 cmake ../-DCMAKE_BUILD_TYPE =リリース
 make && make package

Debian用パッケージはwahaにあります-*。Deb、残りのwaha-*。Zip

使用例

読み込みの負荷が大きく、書き込みが少ないユーザーの承認。

ブローカーの起動（デフォルトポートは10000）

 $ワハブローカー

読み取りのためのバランサーの開始（デフォルトでは、ポート10001）

 $ waha-proxy-balance -n system.user.check

httpasswdを起動して、ログイン/パスワードを確認します（負荷を分散するために必要な回数だけ実行します）。 シャットダウンコードのみを返します。 後に来るものはすべて、引数としてスクリプトに渡されます。

 $ waha-service-script -u tcp：//127.0.0.1：10001 -n system.user.check -s htpasswd --ret-code --no-stdout--bv users.passwd

出力とともにユーザーを追加するためのスクリプトを実行する（バランスをとることなく）

 $ waha-service-script -n system.user.add -s htpasswd --ret-code --stderr--b users.passwd

HTTPインターフェースの開始（デフォルトのポート9001）

 $ waha-proxy-http

リクエスト例

 http://127.0.0.1:9001/system.user.check?args=["admin","admin "]
 http://127.0.0.1:9001/system.user.check?args=["admin","admin"†&callback=func123

コマンドインターフェイスの使用

フォーマットなしの出力：

  $ waha-cli -n system.user.check admin admin 

JSONでの出力：

  $ waha-cli -o json -n system.user.check admin admin 

まとめ

レジャーやリラクゼーション中に楽しいプログラマーによって書かれた、機能するモジュール式のメッセージブローカー。 コードが消えないように、公開しました。

これが必要な場合は、ご相談ください。