信頼性の高いメッセージング サービスの実装を検討する

＃＃＃導入＃＃＃ 分散トランザクションは、多くの場合、サービス指向の問題点です。多くのシナリオでは、ビジネスを通じて分散トランザクションを回避していますが、分散トランザクションに依存する必要があるシナリオもまだいくつかあります。分散トランザクションの処理方法について話しましょう1 一般的なソリューション 分散トランザクションの問題を解決するには多くの方法があり、インターネット上にはさまざまな解決策を提供するブログが多数あります。まとめると、大きく次の 2 つの方法に分けられます。 1. 2 フェーズ コミット (略して 2PC): これは一般的な分散トランザクション ソリューションです。この方法では、コーディネーター ノードは参加者ノードの操作を調整し、コミットまたはロールバック時にすべてのノードが合意に達することを保証します。 厳格な分散トランザクションと 2 フェーズ コミットは、強整合性を実現するメカニズムです。 厳格な分散トランザクションとは、分散システム内の複数の参加ノードによって実行される一連の操作を指し、アトミック性、つまりすべてが成功するかすべてが失敗するかを保証する必要があります。このメカニズムでは、すべての参加ノードがトランザクション実行中に同じプロトコルに従い、コーディネーター ノードのガイダンスを通じてトランザクション

を実装する必要があります。

柔軟な分散トランザクションは、分散システムでトランザクションを処理する方法です。ベストエフォート型のコミット戦略が採用されています。つまり、トランザクションの送信を完了するために最善を尽くしますが、一部の操作の失敗も許容されます。柔軟な分散トランザクションでは、通常、トランザクション管理の実装に TCC (試行-確認-キャンセル) モードが使用されます。 TCC モデルは、トランザクションを試行、確認、キャンセルの 3 つのフェーズに分解します。

まず、分散トランザクションの前提条件の保証を解決します。メッセージの繰り返しの送信がビジネスに影響を与えるのを防ぐために、インターフェースは冪等である必要があります。

2 信頼性の高いメッセージ システムの設計 (これは良い感じで比較的シンプルなので共有します)

上に示したとおり

実行の開始例: ＃＃＃試す{＃＃＃ if(prepare()) { //送信前フェーズ

doService(); //ビジネスロジックを実行

updateMsgStatus();//ステータスを確認するためにメッセージを更新

}

}

1 メッセージの事前送信、試行フェーズ。メッセージの事前送信が失敗した場合、ビジネスはまだ実行されていないため、システム A と B は依然として一貫性があり、処理は必要ありません。
これはわかりやすいですね

2 現在送信されたメッセージは成功し、ビジネス ロジックの実行が開始されます。実行が成功すると、更新された送信前メッセージのステータスが送信確認に変更されます。このときビジネスロジックの実行に失敗すると、送信済みのメッセージは新たなステータスに更新されず、この時点でメッセージ確認システムが動作し、業務システム１に戻ってメッセージのステータスを確認することになります。業務実行が失敗したことが判明した場合は、送信前ステータスを失敗ステータスに更新します。
＃＃＃３ この時点でビジネスの実行が成功し、送信を確認するためにメッセージが更新されていれば、問題はありません。メッセージの更新が失敗した場合でも、メッセージ確認システムはステータスをチェックし、メッセージが削除されたか送信が確認されたかを更新します。

4 メッセージ送信者は

を消費し始めます

1> たとえば、消費が失敗して不整合が発生した場合、メッセージ回復システムはメッセージのステータスを検出し、メッセージを再送信します。

2>ビジネスの実行が失敗した場合、メッセージは確認されません。メッセージ回復システムは引き続きメッセージのステータスを検出し、メッセージを再送信します

3>アスクが失敗した場合は、上記のロジックで再送しますが、もちろん再送回数には制限があり、毎回送信できるわけではありません。最大回数を超えた場合は再送を行ってください。 、デッドレターキューに入り、手動介入を待ちます。

4> 質問が成功すると、メッセージは正常に消費されます。これは完璧であり、信頼性の高いメッセージ サービスの問題を解決します。

3 頑張って提出してください

これは比較的単純です。リアルタイム パフォーマンスが低い一部のシナリオでは、失敗したメッセージを繰り返し送信して、メッセージのプッシュが確実に成功するようにします。

たとえば、トランザクションが完了すると、サードパーティのメッセージがプッシュされます。現時点では、努力の提出

を使用できます。

この記事はオープンソースチャイナコミュニティ[http://www.oschina.net]からの転載です。

以上が信頼性の高いメッセージング サービスの実装を検討するの詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。