한국어
한국어
인터넷 애플리케이션의 빠른 개발로 메시지 대기 기술은 높은 동시성 및 비동기 운영을 처리하기위한 핵심 도구 중 하나가되었습니다. 이 기사는 시스템의 효율성과 신뢰성을 보장하기 위해 Redis 및 MySQL을 통한 메시지 중복 제거 및 메시지 Idempotence를 달성하는 방법을 소개합니다.
메시지 큐는 응용 프로그램 간 메시지를 전달하는 메커니즘으로 시스템의 확장 성과 신뢰성을 효과적으로 향상시킬 수 있습니다. 그러나 큐에 중복 메시지가 나타날 수있어 일부 작업이 반복되어 데이터 혼동이나 불일치가 발생할 수 있습니다. 이를 피하기 위해 Redis의 데이터 구조를 사용하여 메시지를 제거 할 수 있습니다.
우리는 Redis의 Sismember 및 SADD 방법을 사용하여 중복 메시지를 판단하고 제거 할 수 있습니다. 구현 된 PHP 코드는 다음과 같습니다.
// 연결하다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의 "Processed_Messages"컬렉션에 존재하는지 여부를 확인하고 메시지가 이미 존재하는 경우 False를 반환합니다. 그렇지 않으면 컬렉션에 추가하고 추가합니다.
분산 시스템에서 네트워크 이유로 인해 메시지가 반복적으로 소비 될 수있어 동일한 메시지가 여러 번 처리되어 시스템의 안정성 및 데이터 일관성에 영향을 미칩니다. 이 문제를 해결하기 위해 MySQL의 고유 인덱스를 통해 메시지의 Idempotence를 달성 할 수 있습니다. 즉, 동일한 메시지를 처리하는 효과가 여러 번 일관되도록하십시오.
먼저 MySQL에 테이블을 만들고 중복 삽입을 방지하기 위해 메시지 필드의 고유 인덱스를 설정해야합니다. 테이블 작성을위한 SQL 코드는 다음과 같습니다.
CREATE TABLE messages (
id INT AUTO_INCREMENT PRIMARY KEY,
message VARCHAR(255) NOT NULL,
UNIQUE KEY message_index (message)
);
이 코드에서는 메시지 필드에 대한 고유 인덱스를 생성하여 각 메시지를 한 번만 삽입 할 수 있도록합니다.
그런 다음 메시지를 삽입하기 전에 데이터베이스에 이미 존재하는지 확인해야합니다. PHP 코드 예는 다음과 같습니다.
// 연결하다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 주입을 방지하고 메시지가 존재하는지 여부를 쿼리하고, 존재하는 경우 삽입을 건너 뛰고, 그렇지 않으면 새 메시지를 처리하고 삽입합니다.
Redis와 MySQL을 결합함으로써 큐잉 기술은 PHP 및 MySQL의 메시지 중복 제거 및 메시지 Idempotence 문제를 효과적으로 해결할 수 있습니다. 메시지 중복 제거를 구현하면 중복 메시지가 처리되는 것을 방지하고 시스템 성능을 향상시킬 수있을뿐만 아니라 Idemptence 처리를 통해 시스템 안정성 및 데이터 일관성을 보장 할 수 있습니다. 실제 응용 분야에서 메시지 처리 프로세스는 비즈니스 요구에 따라 추가로 최적화 될 수 있으며 시스템의 신뢰성을 향상시킬 수 있습니다.
관련 태그:
MySQL
