Kafka がマイクロサービスでどのように動作するか

マイクロサービスがおしゃべりを始めたとき: Kafka が会話の流れを保つ方法

忙しいレストランのキッチンを想像してみてください。料理長が大声で注文を出します。それを聞いたグリル料理人がステーキを焼き始めます。でもサラダステーションは？彼らは何も知らずに切り捨てています。フライ料理人はそれを完全に見逃しています。混乱が起こります。よく焼かれたステーキが冷たい前菜と一緒に到着します。サービスが適切に通信できない場合、ソフトウェア内でこのようなことが起こります。データは失われ、注文は重複し、システム全体が昨日のコーヒーで稼働しているように感じられます。

それは、物事を結び付ける別の方法を発見する前に、多くの人が直面する静かな混乱です。もっと大声で叫ぶことではありません。それは、必要な人のためにすべてのメモが整然と保管される、より良いキッチン掲示板をセットアップすることです。それはカフカのようなパターンが生き生きと現れる空間です。

では、これは実際にどのように機能するのでしょうか?ちょっと喩えをやめてみましょう。

これは中心となる、終わりのない日誌のようなものだと考えてください。 1 つのサービス、たとえば「注文済み」サービスは、このログに「顧客 #456 が商品 #789 を注文した」というイベントを書き込みます。誰が聞いているかを知る必要はありません。もう 1 つのサービスである「インベントリ」サービスが購読されています。そのエントリを読み取り、在庫を更新します。一方、「通知」サービスも同じエントリを読み取り、確認メールを送信します。データは永続的で再生可能であり、誰もが自分のペースでデータを取得できます。 1 つのサービスが休止している場合に、慌てて直接呼び出しが失敗することはもうありません。

なぜこれほど違うように感じられるのでしょうか？関係が逆転してしまうからです。サービスが相互に応答を厳しく要求するのではなく、単にニュースをブロードキャストし、関心のある人に購読を許可するだけです。これは、全員に @ を送信して返信を待つ混沌としたグループ チャットから、整理されたニュース フィードに移行するようなものです。システムの回復力が高まります。通知サービスが 5 分間ダウンした場合でも、オンラインに戻ったときに見逃したニュースをキャッチするだけです。データが失われることも、注文が滞ることもありません。

これでは複雑さが増すだけではないかと疑問に思うかもしれません。新しい作品を管理する必要がありますか？そうかもしれません。本当の秘訣は、それをどのように実装するかにあります。それはツールだけの問題ではありません。それは設計哲学に関するものです。出来事の中で「何が起こったんだろう？」と考え始めます。 「今何を尋ねるべきですか？」ではなく

ここで物語が実践的になります。このアプローチで構築したチームにとって、その利点はまるで物語のように展開されます。まず疎結合です。イベントの「言語」に同意している限り、チームは独立してサービスを開発できます。次に、スケーラビリティです。作成者の手間をかけずに、人気のイベント ストリームにさらに多くのリーダーを追加できます。最後に、回復力です。システムの一部が一時的に不安定になっても、メッセージ ログが辛抱強く待っているため、システムは正常に動作し続けます。

しかし、はっきりさせておきたいのは、これはあらゆる問題を解決してくれる魔法の妖精の粉ではないということです。これは、状態の変化を追跡し、システム間でデータを移動し、何が起こったかの信頼できる履歴を構築するのに最適です。単純で即時の要求と応答のタスクにはあまり適していません。その線をどこに引くかを知ることは技術の一部です。

このフローの実装は、多くの場合、自然な流れに従います。主要なビジネス イベント (「注文の発注」、「支払いの処理」、「商品の出荷」) を特定します。これらのイベント メッセージの構造は慎重に設計します。ログ ストリームを設定し、サービスを公開またはサブスクライブするように構成します。次に、以前の直接接続の蜘蛛の巣が単純化され、よりクリーンでより組織化された情報の流れになるのを観察します。

この変化後の感覚は明白です。消防も少なくなりました。すべてを時系列に記録できるため、デバッグが容易になります。新しい機能を構築するということは、多くの場合、既存のイベント ストリームをサブスクライブしてロジックを追加することだけを意味します。このシステムは、もろさが軽減され、より適応力が増したように感じられます。まるで背骨がより強くなったように感じられます。

物事をスムーズに進めるという観点から見ると、このアプローチは説得力のある答えを提供します。これは、現代の分散システムが実際に非同期で確実に大規模に動作する必要がある数と一致しています。ポイントツーポイント メッセージのデータを共有資産に変換します。

接続されたシステムの世界では、堅牢な通信を確保することは単なる技術的なタスクではありません。それはその後に続くすべての基礎となります。耐久性、切り離し、拡張性を優先する方法を選択することは最適化ではありません。多くの場合、それが、壊れやすいプロトタイプと、現実世界の複雑さを処理できるシステムとを分けるものになります。アプリケーションのすべての部分が楽にループ内に留まり、決して途切れることのない会話を構築することが重要です。

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