PHP および MySQL におけるメッセージの重複排除とメッセージ冪等性におけるキューテクノロジーの応用-PHPチュートリアル-php.cn

PHP および MySQL におけるメッセージの重複排除とメッセージ冪等性におけるキューテクノロジーの応用

王林

リリース： 2023-10-15 12:44:02

オリジナル

1334 人が閲覧しました

PHP および MySQL におけるメッセージの重複排除とメッセージ冪等性におけるキューテクノロジーの応用

PHP および MySQL におけるメッセージ重複排除とメッセージべき等性におけるキューテクノロジの適用

要約: インターネットアプリケーションの継続的な開発により、メッセージキューは重要な要素の 1 つになりました。高度な同時実行性と非同期操作を処理するためのツール。 PHP と MySQL では、キューを使用してメッセージの重複排除とメッセージのべき等性の問題を解決するにはどうすればよいでしょうか?この記事では、Redis と MySQL を使用してこれら 2 つの機能を実装する具体的なコード例を紹介します。

はじめに
メッセージキューは、アプリケーション間でメッセージを配信する方法であり、システムのスケーラビリティと信頼性を向上させることができます。 PHP 分野には、RabbitMQ、Kafka、Redis など、成熟したメッセージキューツールが多数ありますが、MySQL は一般的なリレーショナルデータベースです。
メッセージの重複排除
メッセージキューに重複したメッセージが表示されることがあります。メッセージの繰り返しにより、一部の操作が繰り返され、データの混乱やその他の問題が発生する可能性があります。この問題を解決するには、Redis の Set データ構造を使用してメッセージの重複を排除します。

サンプルコードは次のとおりです:

// 连接Redis
$redis = new Redis();
$redis->connect('127.0.0.1', 6379);

// 消息去重
function deduplicate($message) {
    if ($redis->sismember('processed_messages', $message)) {
        return false; // 已处理过的消息，不再处理
    }
    
    // 处理消息的逻辑...
    
    $redis->sadd('processed_messages', $message);
    return true;
}

ログイン後にコピー

上記のコードでは、Redis の sismember メソッドとsadd メソッドを使用して、メッセージが処理されたかどうかを判断します。メッセージが Redis コレクションの処理済み_messages に既に存在する場合、メッセージは処理されたことを意味し、直接 false が返されます。それ以外の場合は、メッセージを処理してコレクションに追加します。

メッセージ冪等性
分散システムでは、ネットワークやその他の理由により、メッセージが繰り返し消費される可能性があります。システムの正確性を保証するには、メッセージを冪等に処理する必要があります。つまり、同じメッセージを複数回処理すると、1 回処理した場合と同じ効果が得られます。 MySQL では、一意のインデックスを使用してメッセージの冪等性を実現できます。

サンプルコードは次のとおりです。

CREATE TABLE messages (
    id INT AUTO_INCREMENT PRIMARY KEY,
    message VARCHAR(255) NOT NULL
    UNIQUE KEY message_index (message)
);

ログイン後にコピー

上記のコードでは、メッセージフィールドが UNIQUE KEY を通じて一意のインデックスを定義するメッセージテーブルを作成しました。次に、メッセージを挿入する前に、メッセージがすでに存在するかどうかを確認する必要があります。

サンプルコードは次のとおりです。

// 连接MySQL
$mysqli = new mysqli('localhost', 'username', 'password', 'database');

// 消息幂等性处理
function handle_message($message) {
    $escaped_message = $mysqli->real_escape_string($message);
    
    $select_query = "SELECT id FROM messages WHERE message = '$escaped_message'";
    
    $result = $mysqli->query($select_query);
    if ($result->num_rows > 0) {
        return; // 消息已存在，不再处理
    }
    
    // 处理消息的逻辑...
    
    $insert_query = "INSERT INTO messages (message) VALUES ('$escaped_message')";
    $mysqli->query($insert_query);
}

ログイン後にコピー

上記のコードでは、mysqli の real_escape_string メソッドを使用してメッセージをエスケープし、SQL インジェクション攻撃を防ぎます。次に、メッセージテーブルにクエリを実行して、メッセージがすでに存在するかどうかを確認します。結果セットの行数が 0 より大きい場合は、メッセージがすでに存在しており、直接返すことができることを意味します。それ以外の場合は、メッセージを処理してテーブルに挿入します。

結論
Redis と MySQL を使用することで、PHP と MySQL でのメッセージ重複排除とメッセージ冪等性におけるキューテクノロジの適用を実現できます。メッセージの重複排除により、メッセージの繰り返し処理を回避し、システムのパフォーマンスと信頼性を向上させることができます。また、メッセージの冪等性を実現することで、システムの正確性を確保し、同じメッセージを複数回処理することによる副作用を回避できます。実際のアプリケーションでは、ビジネスニーズに応じてメッセージをより柔軟に処理することもできます。

参考資料: