Redis に基づく分散ロックと Redlock アルゴリズム

Redis に基づく分散ロックと Redlock アルゴリズム

[[403381]]

この記事はWeChatの公開アカウント「UP Technology Control」から転載したもので、著者はconan5566です。この記事を転載する場合は、UP Technology Controlの公式アカウントまでご連絡ください。

シングルプロセスシステムでは、複数のスレッドが同時に変数(可変共有変数)を変更できる場合、変数の同時変更を排除するために、変数またはコードブロックを同期して、変数を変更するときに線形に実行できるようにする必要があります。

同期の本質はロックを通じて実現されます。一度に 1 つのスレッドだけが同じコード ブロックを実行できるようにするには、どこかにマークを付ける必要があります。このマークはすべてのスレッドに表示される必要があります。マークが存在しない場合は設定可能です。後続の他のスレッドは、マークがすでに存在していることを検出すると、マークを持つスレッドが同期コード ブロックを終了し、マークをキャンセルするまで待機してから、マークの設定を試行します。このマークはロックとして理解できます。

すべてのスレッドがマークを見ることができる限り、異なる場所でロックを実装する方法も異なります。たとえば、Java では、同期によってオブジェクト ヘッダーにマークが設定されます。 Lock インターフェースの実装クラスは、基本的に volitile によって変更される int 変数にすぎず、これにより各スレッドが int の可視性とアトミックな変更を持つことが保証されます。 Linux カーネルは、マーキングにミューテックスやセマフォなどのメモリ データも使用します。

実際には、メモリ データをロックに使用することに加えて、相互に排他的なロックも使用できます (相互に排他的なケースのみを考慮します)。例えば、フローテーブル内のシリアル番号と冪等性チェックの時間を組み合わせて、解除されないロックとみなしたり、特定のファイルの存在をロックとして利用したりすることができます。マークを変更するときにのみ、アトミック性とメモリの可視性を確保する必要があります。

1 配布とは何ですか?

分散CAP理論は次のように語っています。

一貫性、可用性、およびパーティション耐性を同時に満たす分散システムはありません。最大で 2 つしか満たすことができません。

現在、多くの大規模な Web サイトやアプリケーションが分散形式で展開されています。分散シナリオにおけるデータの一貫性の問題は常に重要なトピックです。 CAP 理論に基づくと、多くのシステムは設計の初期段階でこれら 3 つの間でトレードオフを行う必要があります。インターネット分野のほとんどのシナリオでは、システムの高可用性と引き換えに強力な一貫性を犠牲にする必要があり、システムでは結果的一貫性のみを確保する必要があることがよくあります。

分散シナリオ

これは主に、複数の同一サービスが同時に開始されるクラスター モードを指します。

多くのシナリオでは、データの最終的な一貫性を保証するために、分散トランザクションや分散ロックなど、それをサポートする多くの技術的ソリューションが必要です。多くの場合、メソッドは同じスレッドによってのみ同時に実行できるようにする必要があります。スタンドアロン環境では、Java が提供する並行性 API を通じてこの問題を解決できますが、分散環境ではそれほど簡単ではありません。

  • 分散シナリオとスタンドアロン シナリオの最大の違いは、マルチスレッドではなくマルチプロセスであることです。
  • 複数のスレッドがヒープ メモリを共有できるため、メモリをタグの保存場所として簡単に使用できます。プロセスは同じ物理マシン上に存在しない可能性もあるため、マークはすべてのプロセスが参照できる場所に保存する必要があります。

分散ロックとは何ですか?

  • 分散モデルでデータのコピーが 1 つしかない場合 (または制限されている場合)、特定の時点でデータを変更するプロセスの数を制御するためにロック テクノロジが必要です。
  • スタンドアロン モードのロックと比較すると、プロセスの可視性を確保するだけでなく、プロセスとロック間のネットワークの問題も考慮する必要があります。 (分散環境では問題が複雑になる主な理由は、ネットワークの遅延と信頼性の低さを考慮する必要があるためだと思います...大きな落とし穴です)
  • 分散ロックではタグをメモリに保存できますが、メモリは特定のプロセスによって割り当てられるのではなく、Redis や Memcache などのパブリック メモリによって割り当てられます。データベースやファイルなどを使用してロックを作成する場合、タグが相互に排他的である限り、実装は単一のマシンの場合と同じです。

2 どのような分散ロックが必要ですか?

分散アプリケーション クラスターでは、同じメソッドは 1 台のマシン上の 1 つのスレッドによってのみ同時に実行されることが保証されます。

  • このロックは再入可能ロックである必要があります(デッドロックを回避するため)
  • このロックはブロッキング ロックとして最適です (ビジネス ニーズに基づいてこのロックを使用するかどうかを検討してください)
  • このロックは公平なロックとして最適です (ビジネス ニーズに基づいてこのロックを使用するかどうかを検討してください)

可用性の高いロック取得およびロック解放機能

ロックの取得と解放のパフォーマンスが向上しました

コードの実装

  1. パブリックインターフェイス IDistributedLock
  2. {
  3. ILockResult ロック(文字列リソースキー);
  4. ILockResult ロック(文字列リソースキー、TimeSpan 有効期限);
  5. ILockResult ロック(文字列リソースキー、有効期限の TimeSpan、待機時間の TimeSpan、再試行時間の TimeSpan);
  6. ILockResult Lock(文字列 resourceKey、TimeSpan expiryTime、TimeSpan waitTime、TimeSpan retryTime、CancellationToken cancellationToken);
  7. タスク<ILockResult> LockAsync(文字列リソースキー);
  8. Task<ILockResult> LockAsync(文字列リソースキー、TimeSpan 有効期限);
  9. Task<ILockResult> LockAsync(文字列リソースキー、有効期限の時間範囲、待機時間の時間範囲、再試行時間の時間範囲);
  10. Task<ILockResult> LockAsync(文字列 resourceKey、TimeSpan expiryTime、TimeSpan waitTime、TimeSpan retryTime、CancellationToken cancellationToken);
  11. }
  12.  
  13. パブリックインターフェイス ILockResult: IDisposable
  14. {
  15. 文字列 LockId { 取得; }
  16. bool IsAcquired { 取得; }
  17. int ExtendCount { 取得; }
  18. }
  1. クラス EndPoint:RedLock.RedisLockEndPoint
  2. {
  3. プライベート読み取り専用文字列 _connectionString;
  4. パブリックエンドポイント(文字列接続文字列)
  5. {
  6. _connectionString = 接続文字列;
  7. //139.196.40.252、パスワード=xstudio、デフォルトデータベース = 9
  8. var接続= connectionString.Split( ',' );
  9. var dict = 新しい辞書<文字列, 文字列>();
  10. foreach (var 項目in  繋がり
  11. {
  12. var keypar = item.Split( '=' );
  13. (keypar.長さ>1)の場合
  14. {
  15. dict[キーパー[0]] = キーパー[1];
  16. }
  17. }
  18. this.EndPoint = 新しい System.Net.DnsEndPoint(接続[0], 6379);
  19. if (dict.TryGetValue( "password" , out string password ))
  20. {
  21. this.Password =パスワード;
  22. }
  23. if (dict.TryGetValue( "defaultDatabase" , out string defaultDatabase) && int .TryParse(defaultDatabase, out  整数 データベース))
  24. {
  25. RedisDatabase =データベース;
  26. }
  27. }
  28. }
  1. [エクスポート(typeof(IDistributedLock))]
  2. クラス InnerLock: IDistributedLock
  3. {
  4. プライベート静的Lazy<RedLock.RedisLockFactory> _factory;
  5.  
  6. 静的InnerLock()
  7. {
  8. _factory = new Lazy<RedisLockFactory>(() => new RedisLockFactory(新しい EndPoint(ConfigurationManager.AppSettings[ "Redis" ])), System.Threading.LazyThreadSafetyMode.ExecutionAndPublication);
  9. }
  10. パブリックILockResult Lock(文字列リソースキー)
  11. {
  12. 新しい LockResult(_factory.Value.Create (resourceKey, TimeSpan.FromDays (1)))を返します
  13. }
  14.  
  15. パブリックILockResult ロック(文字列リソースキー、TimeSpan 有効期限)
  16. {
  17. 新しい LockResult(_factory.Value.Create ( resourceKey , expiryTime))を返します
  18. }
  19.  
  20. パブリックILockResult ロック (文字列リソース キー、有効期限の時間、待機時間の時間、再試行時間の時間)
  21. {
  22. 新しい LockResult(_factory.Value.Create (resourceKey, expiryTime, waitTime, retryTime))返します
  23. }
  24.  
  25. パブリックILockResult Lock(文字列 resourceKey、TimeSpan expiryTime、TimeSpan waitTime、TimeSpan retryTime、CancellationToken cancellationToken)
  26. {
  27. 新しい LockResult(_factory.Value.Create (resourceKey、expiryTime、waitTime、retryTime、cancelationToken))返します
  28. }
  29.  
  30. パブリック非同期タスク<ILockResult> LockAsync(文字列リソースキー)
  31. {
  32. var result = _factory.Value.CreateAsync(resourceKey, TimeSpan.FromDays(1)) を待機します。
  33. 新しいLockResult(result)を返します
  34. }
  35.  
  36. パブリック非同期タスク<ILockResult> LockAsync(文字列リソースキー、タイムスパン有効期限)
  37. {
  38. var result = _factory.Value.CreateAsync(resourceKey, expiryTime) を待機します。
  39. 新しいLockResult(result)を返します
  40. }
  41.  
  42. パブリック非同期 Task<ILockResult> LockAsync(文字列リソースキー、有効期限の時間範囲、待機時間の時間範囲、再試行時間の時間範囲)
  43. {
  44. var result = await _factory.Value.CreateAsync(resourceKey、expiryTime、waitTime、retryTime);
  45. 新しいLockResult(result)を返します
  46. }
  47.  
  48. パブリック非同期 Task<ILockResult> LockAsync(文字列リソースキー、有効期限時間、待機時間時間、再試行時間時間、キャンセルトークンキャンセルトークン)
  49. {
  50. var result = await _factory.Value.CreateAsync(resourceKey、expiryTime、waitTime、retryTime、cancelationToken);
  51. 新しいLockResult(result)を返します
  52. }
  53. }
  54.  
  55. クラス LockResult: ILockResult
  56. {
  57. プライベート IRedisLock _lock;
  58. パブリックLockResult(IRedisLock redisLock)
  59. {
  60. _lock = redisLock;
  61. }
  62.  
  63. パブリック文字列 LockId => _lock.LockId;
  64.  
  65. パブリックブール IsAcquired => _lock.IsAcquired;
  66.  
  67. 公共  int ExtendCount => _lock.ExtendCount;
  68.  
  69. パブリックvoid Dispose()
  70. {
  71. _lock.Dispose();
  72. }
  73. }

<<:  フレームワーク: 分散理論 CAP、BASE

>>:  Flux+Flagger+Istio+Kubernetes を使用して GitOps クラウドネイティブ プログレッシブ (カナリア) 配信を実装する

推薦する

dedipath - メモリアルデー、Windows を含む VPS が 50% オフ

アメリカ版「墓参りの日」(戦没者追悼記念日)が近づいており、dedipath はすべての VPS 製...

見逃せない人気の継続的インテグレーションツール 8 選

「継続的インテグレーション」に精通している方であれば、「継続的インテグレーションの使用は必須となって...

GoogleのPRアップデートで中国のウェブマスターに遅ればせながらの新年の贈り物

2012年、多くのウェブマスターがGoogleがウェブページのPR(ページランク)をいつ更新するかを...

分散Redisディープアドベンチャー-Sentinel

1 つのマスターと 1 つのスレーブ、または 1 つのマスターと複数のスレーブの構造では、マスター ...

alphavps-30 ユーロ/年 VPS、4g メモリ/4 コア/35g SSD/5 コンピュータ ルーム

ブルガリアのホスティング プロバイダー alphavps.bg は最近、KVM VPS、OpenVZ...

itldcはどうですか?オランダのVPS、データ共有の簡単なレビュー

itldcはどうですか? itldc オランダはどうですか? itldc オランダ VPS はどうで...

3分レビュー! 12月のクラウドコンピューティング分野の重要な動向を簡単に見てみましょう

今年からクラウドコンピューティングがトレンドになりました。ますます多くの資本と企業がクラウド コンピ...

知的財産訴訟トップ10のうち4件のオンライン訴訟の背景

4月17日、「3Q」紛争の第二段階の裁判が広東省高級人民法院で始まった。近年、インターネット上での知...

ecshop フルシリーズ バージョン ウェブサイトの脆弱性 リモート コード実行 SQL インジェクションの脆弱性

月収10万元の起業の夢を実現するミニプログラム起業支援プランecshopの脆弱性は、2018年9月1...

Bing検索エンジンの秘密を解き明かす: 高度な検索テクニックのコレクション

Microsoft の検索エンジン Bing は、非常に豊富な高度な検索構文を提供します。高度なキー...

テンセントの昨年の純利益は127億元、電子商取引の収益は44億元だった。

テンセント・ホールディングス(00700.HK)は昨日、2012年度の年次財務報告書を公開した。同社...

我が国の政府クラウド開発の現状と動向の分析

[[417926]] 1. 中国の政府クラウド市場は成長を続けている現在、デジタル経済の急速な発展と...

B2C医療電子商取引 - ブルーオーシャンにおける問題と解決策

正式な B2C 医薬品電子商取引は、2005 年に正式に人々の視界に入り始めました (単一ページ入札...

企業で働く SEO 担当者は、どうすれば SEO 目標を合理的に設定できるでしょうか?

SEO を行う人の中には、個人のウェブマスターではなく、企業にサービスを提供するタイプの人もいます。...

転職してクラウド コンピューティングに参加してみませんか?参考までに4つのキャリアの方向性を推奨します

クラウド市場の急成長により、多くの IT プロフェッショナルがクラウド コンピューティング分野に移行...