Tencent Cloud CKafkaスパイクシステムソリューション： 非同期ピーク・フィル・ピーク、数十億オーダーの洪水を容易に運ぶ

はじめに（ペインポイント分析）​

eコマース・プラットフォームのアーキテクトやデベロッパーとして、毎年プロモーションが急増することに不安を感じていませんか？時計がゼロを打つとき、膨大な数のユーザーが瞬時に流入し、あなたのシステムは次のような深刻な課題に直面しているかどうか：

• -フローパルス、システムクラッシュ。瞬間的なトラフィックは平日の100倍、1000倍にもなり、データベース接続プールは使い果たされ、サーバーのCPU/IOは100%まで急上昇し、ページ詰まりやサービスダウンに直結する。
• -過剰販売はデータと矛盾している。高い並行性の下では、従来の在庫控除ロジックは並行性の問題を非常に起こしやすく、在庫がマイナス（売れ過ぎ）になり、企業の評判とユーザーエクスペリエンスに深刻なダメージを与える。
• -同期のブロックとレスポンスの遅さ。ユーザーの注文リクエストは、在庫確認、注文作成、支払い初期化、その他の時間のかかる操作を完了するために同期される必要があります。

と悩んでいるなら大量の同時リクエストにスムーズ、確実、効率的に対処する方法メッセージキューCKafkaをベースにしたTencent Cloudの非同期ピークカットソリューションは、完全でスケーラブルなベストプラクティスを提供します。

​解决方案架构图与概述​

このプログラムの核心は“レイヤーピークシェービングと非同期デカップリング”.ユーザーの瞬時の注文リクエストとバックエンドの複雑な業務処理を分離し、メッセージキューCKafkaを強力なバッファプールとして使用することでトラフィックのパルスを滑らかにし、コアシステムの安定性を保証する。

​アーキテクチャ図。

ワークフローの概要。​

1. アクセスをリクエストする。ユーザーのスパイク要求は、まずグローバル・アクセラレーション・リンクを通過し、CLBのロードバランシングによって複数のフロントエンド・ビジネス・サーバーに分散される。
2. 事前キャリブレーション。フロントエンド・サーバー（CVM/EKS）は、ユーザーの適格性、パラメーターの検証、Redisを介した在庫残高の迅速なクエリなどの軽量ロジックを実行する。バリデーションが通過すると、注文情報がメッセージボディとして使用されます。CKafkaへの即時書き込みそして、「キューに入っている」ユーザーに素早く対応する。
3. 山あり谷あり。CKafkaクラスタは、その高いスループットと永続性機能により、すべての一時的なトラフィックを引き継ぎ、完璧なトラフィックのクリッピングを可能にする。
4. 非同期消費。下流のクラウド機能SCFまたはエラスティック・マイクロサービスTEMはコンシューマーとして機能し、制御された速度でCKafkaからメッセージを引き出し、在庫控除や注文の取り下げなどの最終的な整合性処理をスムーズに実行する。
5. データの永続性。処理後、結果はクラウドデータベース（MySQL/CynosDB）に書き込まれ、Redisのキャッシュ状態が更新される。

​核心产品与组件详解​

アセンブリー	役を演じる	关键配置/选型建议	なぜそれを選んだのですか？
​メッセージキュー CKafka​	​システムコアバッファピークカットとデカップリングの重要な役割を担う。	推奨される選択肢ハイレベル仕様パーティション数は、同時消費を促進するために、コンシューマー数より大きく設定されるべきである。	非常に高いスループットとスケーラビリティ、Kafkaエコシステムとの互換性、各種ビッグデータツールとのシームレスな統合、メンテナンスフリーのマネージドサービス。
​クラウドサーバー CVM / Elastic Container Service EKS​	​フロントエンドのビジネス・ロジック処理リクエストの検証、トークン生成、メッセージ生成を担当する。	採用容量課金モードとペアエラスティック・ストレッチ・グループ（AS）CPUの圧力に応じて自動的に拡大縮小する。	安定した信頼性の高いコンピューティングパワーを提供し、エラスティックなスケーリングにより、スパイクの前後でリソースが自動的に調整されるため、大幅なコスト削減が実現します。
​クラウドデータベース Redis​	​ホット・データ・キャッシュ秒単位のインベントリーの保存、ユーザーブラックリスト、回数制限など。	オプションメモリベーススペック永続性の有効化Luaスクリプトを使用して、インベントリのアトミックな控除を保証する。	非常に高い性能（10W+ QPS）を持つシングルスレッド・メモリー操作は、高度な同時読み書きに対応する優れたツールである。
​クラウド機能 SCF​	​非同期タスクコンシューマーCKafkaからメッセージを取得し、コアとなる順序付けロジックを処理する。	合理的同時執行とバッチ処理されたメッセージ数下流のデータベースに過度のストレスを与えないようにするためである。	​イベントドリブンサーバーレス・アーキテクチャにより、メッセージの蓄積量に応じて自動的にスケールアップ/ダウンし、真の従量課金とメンテナンスフリーを実現する。
​クラウドデータベース TencentDB for MySQL/TDSQL-C​	​最終データ保存注文、製品、その他の情報の永続的な保存。	採用高可用性版それほどまでに3ノード・エンタープライズ・エディションの使用を推奨する。読み書き分離建築。	高可用性と高性能のデータベースサービスを提供するTDSQL-C（CynosDB）は、価格性能比に優れ、大量の同時書き込みシナリオに特に適しています。
​ロードバランシング CLB​	​トラフィックのシングル・ポイント・エントリートラフィックの分散と高可用性を可能にする。	オプション高性能バージョン大量の同時接続をサポートする。	単一障害点を排除し、アクセス層での高可用性を確保。
​ウェブアプリケーションファイアウォール WAF​	​ガードマンCC攻撃、悪意のあるスワイプやその他の行動から守る。	コンフィグ正確なCCプロテクションルールとヒューマン・コンピュータ検証悪意のあるトラフィックをフィルタリングするためにフロントロードされたポリシー。	トラフィックが業務システムに侵入する前に攻撃の大部分を遮断し、キャンペーンの公平性と業務セキュリティを保護します。

​この計画のメリットをまとめたものです。​

• ⚡ 究極のユーザー体験。ユーザーのリクエストに対するレスポンスが速く（ミリ秒）、長い時間待つ必要がなく、システムにタイムラグがなく、注文プロセスがスムーズ。
• ​?システムの高い可用性と安定性。バックエンドシステムはトラフィックのピークから切り離され、データベースとサービスの圧力は常にスムーズで、過負荷による雪崩のようなダウンタイムは完全に回避される。
• ? コスト最適化のための柔軟なスケーリング。すべてのコンポーネントが弾力的に拡張可能であるため、ピーク時のトラフィック用に大量のアイドル・リソースを購入する必要がなく、ITのO&Mコストを大幅に削減できる。
• ? データの最終的な整合性。メッセージ・キューイングと信頼性の高い消費ロジックにより、在庫控除と注文生成のためのデータが、高い並行性の下でも最終的に一貫していることを保証し、売り過ぎを排除する。
• ?アーキテクチャーは分離され、柔軟でスケーラブル。各モジュールの責任は明確であり、将来的な新機能（減点、SMS通知など）の拡張は、主流のプロセスを変更することなく、新しい消費者を追加するだけでよい。

​应用场景与适用客户​

• 典型的なシーン。Eコマース・プラットフォームの618、ダブル11、ダブル12などの大型プロモーション・スパイク活動、新製品のデビュー・ラッシュ、チケット・システムの人気会場でのチケットつかみ取り。
• 該当するお客様​
  • 周期的または予測可能なトラフィックの洪水に直面するすべてのインターネットビジネス。
  • 1日の平均PVが100万を超え、ビジネスが急成長しているため、eコマース・プラットフォームには柔軟性の高いアーキテクチャが求められている。
  • 自前で構築したメンテナンスが困難なスパイクシステムから、完全にホストされた信頼性の高いクラウドネイティブアーキテクチャへの移行を検討している技術チーム。

​関連リンク