한국어
한국어
오늘날의 인터넷 아키텍처에서 분산 시스템은 고도로 가용적이고 고성능 응용 프로그램을 구축하는 데 중요한 토대가되었습니다. 다중 노드 공동 작업 작업이 특히 중요한 환경에서 자원의 동기 제어가 특히 중요합니다. 동시 충돌을 효과적으로 해결하기 위해 분산 자원 잠금 장치는 시스템 일관성을 보장하는 주요 기술 수단이되었습니다. 이 기사에서는 PHP 언어를 기반으로하고 Kafka 메시지 대기열과 결합 된 실행 가능한 분산 리소스 잠금 구현 솔루션을 소개합니다.
분산 리소스 잠금은 여러 노드로 공유 리소스에 대한 액세스를 조정하는 데 사용되는 메커니즘입니다. 주요 목적은 여러 노드가 동시에 동일한 리소스를 동시에 작동하지 않도록하여 데이터 불일치 또는 충돌을 일으키는 것입니다. 분산 잠금에는 일반적으로 두 가지 핵심 기능이 있습니다.
메시지 큐는 분산 시스템에서 분리 및 비동기 통신에 널리 사용되는 미들웨어입니다. 리소스 잠금을위한 메시지 채널을 구축하면 노드 간의 리소스 운영 제어를 달성 할 수 있습니다. 이 기사는 Kafka를 메시지 큐 도구로 사용하고 PHP 개발을 결합하여 분산 잠금 프로세스를 구현합니다.
개발을 시작하기 전에 Kafka 서비스는 시스템에 설치 및 구성되어야합니다. Kafka 서비스가 올바르게 실행 중이며 해당 주제와 메시지를 명령 줄 작업을 통해 관리 할 수 있는지 확인하십시오. 공식 문서를 참조하여 설치를 완료 할 수 있습니다.
리소스 잠금 관리에 특별히 사용 되려면 kafka에서 resource_lock 이라는 새로운 주제 (주제)를 만듭니다.
<span class="fun">bin/kafka-topics.sh-크레이트-부트 스트랩-서버 LocalHost : 9092-Topic Resource_Lock-파트 라인 1- 반복 요소 1</span>
작곡가를 통해 Kafka의 PHP 클라이언트 라이브러리를 설치할 수 있습니다.
<span class="fun">작곡가는 슈퍼 볼리스트/PHP-Pubsub-Kafka가 필요합니다</span>
다음은 Kafka 생산 및 소비 메시지를 통한 잠금 및 잠금 해제 제어 흐름을 구현하는 방법을 보여주는 완전한 PHP 예입니다.
<?php
require 'vendor/autoload.php';
use Superbalist\PubSub\Kafka\KafkaConnectionFactory;
class DistributedLock
{
private $topic;
private $connection;
public function __construct($topic)
{
$this->topic = $topic;
$this->connection = $this->createConnection();
}
private function createConnection()
{
$config = [
'metadata.broker.list' => 'localhost:9092',
'enable.auto.commit' => 'false',
];
return KafkaConnectionFactory::create($config);
}
public function acquireLock($identifier)
{
$producer = $this->connection->createProducer();
$message = json_encode(['identifier' => $identifier]);
$producer->produce($this->topic, $message);
}
public function releaseLock($identifier)
{
$consumer = $this->connection->createConsumer();
$consumer->subscribe([$this->topic]);
while (true) {
$message = $consumer->consume(1000);
if ($message) {
$payload = json_decode($message->getPayload(), true);
if ($payload['identifier'] == $identifier) {
break;
}
}
}
}
}
// 샘플 코드
$lock = new DistributedLock('resource_lock');
$identifier = 'example_identifier';
echo 'Acquiring lock...' . PHP_EOL;
$lock->acquireLock($identifier);
echo 'Lock acquired!' . PHP_EOL;
// 리소스 운영을 시뮬레이션합니다
sleep(3);
echo 'Releasing lock...' . PHP_EOL;
$lock->releaseLock($identifier);
echo 'Lock released!' . PHP_EOL;프로젝트에서 잠금 메커니즘을 사용하려면 다음 단계를 따르십시오.
이 기사는 예제를 통해 PHP 및 Kafka를 사용하여 분산 리소스 잠금 메커니즘을 구현하는 방법을 소개하여 여러 노드 간의 공유 리소스 간의 동시 충돌 문제를 효과적으로 해결합니다. 이 방법은 확장 성이 높고 비동기 특성이 우수하며 다양한 분산 시스템 아키텍처에 적합합니다. Kafka 외에도 Rabbitmq, Redis Stream 등과 같은 다른 메시지 큐 미들웨어도 유사한 개발 관행에 사용될 수 있습니다.
