反応的製品開発

産業

技術情報

Akka Akka-http DSE stack(Cassandra, Graph, Solr, Spark)Event Sourcing Redis Scala

はじめに

ナッシュテックは、Knolway（ナッシュテックのソフトウェア開発方法論）のリズムでSpokの構築に取り組み始めた。

SPOKについて

Spokはソーシャルコンテンツ共有アプリケーションです。スポーク」とは、ユーザーによって公開される（「スポーク」される）コンテンツ（画像、アニメーションGIF、ビデオ、サウンド、URL、生テキスト、HTMLテキスト、投票、なぞなぞ、その他まだまだあります）のことです。その後、すべてのスポークは、他のユーザーによって再スポークされる可能性がある（されない可能性もある）。すべてのユーザーとのやりとり（新規スポーク、再スポーク、アンスポーク、コメントなど）は、詳細なスペースと時間情報とともに保存される。

スポークが投稿されると、それはすべてのユーザー間で共有されるオブジェクトになります。このシステムの強みは、スポークが他のユーザーのリ・スポークに左右されることなく、自分自身の人生を生きることだ。スポークが削除されても（作成者または再スポーカーによって）、他のすべてのスポーカーがそのスポークを使用できます。スポークとスポーカーの関連は削除されるが、スポークはその生涯を続ける。

課題

このアプリケーションは、ユーザーとのやり取り（新規スポーク、リ・スポーク、アン・スポーク、コメント…）を、詳細なスペースと時間情報とともに保存する必要があった。その目的は、複数の視点（特定のユーザー、特定のスポーク、またはアプリケーション全体）から、これらのインタラクションの完全なタイムラインマップを提供することであった。

Spokアプリでは、アーキテクチャは非同期、ノンブロッキング、高度なフォールトトレラントである。データはウェブ・ソケットを通じて送信される。これはプルとプッシュのデュアル・メッセージング・システムで、事前のリクエストを必要としない。

例えば、クライアントからサーバーへ、特定のチャンネルを通して必要なデータをプッシュするだけで、クライアントUIをインタラクションなしで更新することができる。そのため、Websocketベースのプル／プッシュ・メカニズムが多用され、リアクティブな風味が与えられている。主要な課題は、Akka-HTTPの助けを借りて行われたウェブソケットベースのマイクロサービス・アーキテクチャを設計することでした。

データモデル側では、すべてのスポークとスポーカーをリンクさせる予定だった。また、スポーカーが他のスポーカーをフォローしたり、リ・スポークをしたりすることもある。もうひとつの大きな課題は、すべてのAPIのパフォーマンスを100ミリ秒以下に抑えることだ。

解決策

NashTechは、Knolway（NashTechソフトウェア開発方法論）のリズムでSpokの構築を開始しました。この開発方法論は、4つのステップ（Fusion、Architecture Release、Development Release、Maintain and Enhance）に分かれています。このアーキテクチャはリアクティブ・マニフェストに基づき、あらゆるレベルで非同期かつノンブロッキングのAPIとなるように設計されている。イベント・ソーシングの管理にはEventuateを使いました。 DSEのフルスタックを使うことにしたので、データ間のリンクはDSEグラフで管理し、ビッグデータ分析はDSEアナリティクスで管理し、検索はDSEサーチで実装しています。サービスはマイクロサービスとして分散され、RESTエンドポイントを通じて利用できる。この製品を作るのに、およそ12回のスプリントを要した。各スプリントの後には、本番環境でのデモとリリースが行われた。製品を作り上げた後、膨大なデータの分析とベンチマークを行った。どのAPIも100ミリ秒以下で応答している。

その結果

製品については、必要性に応じて適切な技術を使用した。これにより、私たちは定められた時間内に、適切な品質でプラットフォームを構築することができました。私たちは、DSEスタック、ウェブソケットベースのマイクロサービス・アーキテクチャを使用し、CodeSquadを通じて管理している高品質のコーディングに投資しました。わずか6ヶ月で、スポックは市場に投入される準備が整った。