マイクロサービスでの Kafka の使用

マシンが話すとき: Kafka がマイクロサービスの同期を保つ方法

歯車の世界からは遠いように感じられるかもしれないことについて話しましょう。サーボモーター: ソフトウェア サービスを取得して通信します。複雑なロボット アームを開発していると想像してください。 1 つのモーターが手首の傾きを処理し、もう 1 つのモーターがグリップを管理し、12 個のセンサーが位置データをフィードバックします。さて、これらのコンポーネントのそれぞれが、他のコンポーネントが聞いているという保証もなく、混雑した騒々しい部屋に向かって自分のステータスを叫ぶ場合を想像してみてください。混沌ですよね？グリップの準備が整う前に手首がひねったり、騒音の中でセンサー信号が失われたりする可能性があります。それは、マイクロサービスで構築された現代のデジタル システム内でよく起こることであり、騒々しくてまとまりのない部屋となります。

マイクロサービス (それぞれが 1 つの仕事を適切に実行する独立した小さなソフトウェア プログラム) は、最終的に互いに通信しなくなる可能性があります。 1 つのサービスは注文ステータスを更新しますが、在庫サービスはメモを見逃します。ユーザーのプロフィールの変更は、請求モジュールには決して届きません。データは古くなり、プロセスは滞り、システム全体が壊れやすく時を刻む時計になり、1 つの歯車が滑ると機構全体が狂ってしまう可能性があります。それはリアルタイムハーモニーの問題です。

では、ソフトウェア アーキテクチャ内のこれらすべての独立した「アクチュエーター」を完全に協調して動作させるには、どうすればよいでしょうか?信頼できる神経系を構築するにはどうすればよいでしょうか?

メッセージ キューに入る: 単なるパイプではなく中枢神経系

ここで、Apache Kafka のようなテクノロジーが登場します。これが私たちのコンセプトです。キロパワー私たちの機械の世界から深く理解します。 Kafka を 2 つの点を接続する単純なワイヤーとしてではなく、堅牢で高速な中央コンベア ベルト、またはデータに対して正確にタイミングを合わせたカムシャフトとして考えてください。分散型イベントストリーミングプラットフォームです。簡単に言うと、サービスがメッセージ (イベント) をログに公開し、他のサービスがお互いのドアを直接ノックすることなく、自分のペースでメッセージ (イベント) を購読して読み取ることができるシステムです。

なぜこれが重要なのでしょうか?専門用語を使わずに分解してみましょう。

• 混沌を切り裂く:サービスは常に相互に呼び出して応答を待つのではなく (確認が得られるまでモーターが停止するように)、Kafka ログに何が起こったかを「伝える」だけです。のサーボ情報を必要とする企業は情報を聞き、準備ができたら行動します。この疎結合は、ロボット アームの各関節に、共通の命令ストリームによってバッファリングされた自律的な知能を少し与えるようなものです。
• すべてを記憶します:Kafka はメッセージ ストリームを保存します。新しいサービスがオンラインになると、過去のすべてのイベントを巻き戻して読み取って、現在の状態に追いつくことができます。これは、マシンに送信されたすべての位置コマンドの完全で消去できない記録を保持しているようなものです。ゼロから始めることはありません。
• 洪水を処理します:大規模なスケール向けに設計されており、1 秒あたり数百万のメッセージを処理できます。 e コマース プラットフォームでフラッシュ セールが発生したり、センサー ネットワークでデータ バーストが発生したりしても、メッセージ バックボーンは曲がりません。

「これは単なる複雑な技術層ではないのか?」と疑問に思うかもしれません。ソフトウェアによって制御される工場の組立ラインを考えてみましょう。部品がスキャンされ (サービス A)、その品質が記録され (サービス B)、在庫が差し引かれ (サービス C)、配送ラベルが印刷されます (サービス D)。これらの手順が直接の脆弱な呼び出しに依存している場合、ロギング サービスの不具合により回線全体が停止する可能性があります。 Kafka では、スキャン イベントが公開されます。ロギング、インベントリ、および配送サービスは、それぞれ独立してそのイベントを消費します。ロギング サービスが 1 分間ダウンした場合でも、復帰すると中断したところから再開されるだけで、ラインは動き続けます。弾力性が焼き付けられています。

摩擦ではなく流れで構築する

これを実装するということは、より複雑なものを積み重ねることではありません。それは基本的なレベルでコミュニケーションを簡素化することです。目標は、十分に潤滑されたカムフォロアのように、滑らかで信頼性が高く、磨耗を最小限に抑えたデータの流れを実現することです。企業にとって、これはシステムの保守、拡張、理解が容易になることを意味します。開発者は、絡み合った直接的な依存関係を解き明かすことに行き詰まりません。新しい機能をイベント ストリームに組み込むことができます。システムは一種の優雅な耐久性を獲得します。

でキロパワー、あらゆる工学的システムに類似点が見られます。同期しているかどうかにかかわらず、精度、タイミング、信頼性の高い信号伝送は普遍的なニーズです。サーボ自動化された設備にモーターを搭載したり、顧客の注文がカートから配送までシームレスに流れるようにしたりすることができます。哲学は同じです。重要な情報のための堅牢なチャネルを作成し、孤立した部分の合計よりも全体のパフォーマンスが向上するようにします。

このための適切な基盤、つまり「メッセージ バックボーン」を選択することが重要です。産業グレードの耐久性、中心となるコンセプトのシンプルさ、全面的な再構築を強いることなく景観にフィットする能力が必要です。それは独裁者ではなく、促進者であるべきです。成功の尺度は、静かで中断のない操作、つまりすべてが正常に動作するためにテクノロジーにのみ気づくような操作です。

In the end, whether you’re orchestrating metal or data, the principle is about creating harmony from individual actions.それは、混雑した部屋での叫び声を、システムのすべての部分が確実に時間通りに最高の作業を実行できるようにする、同期された回復力のあるクリアな情報のストリームに置き換えることです。

2005年に設立され、キロパワーは、中国広東省東莞に本社を置く、コンパクトモーションユニットの専門メーカーです。 Kpower は、モジュール式ドライブ技術の革新を活用して、高性能モーター、高精度減速機、マルチプロトコル制御システムを統合し、効率的でカスタマイズされたスマート ドライブ システム ソリューションを提供します。 Kpower は、スマート ホーム システム、自動エレクトロニクス、ロボティクス、精密農業、ドローン、産業オートメーションなどのさまざまな分野をカバーする製品で、世界中の 500 を超える企業クライアントにプロフェッショナルなドライブ システム ソリューションを提供してきました。