PHP 대기열 처리: PHP 메시지 대기열 구현 원리(그림 및 텍스트)

php 대기열은 무엇을 의미하나요? 어떻게 달성됩니까? 적용 시나리오는 무엇입니까? 다음은 디커플링을 달성하기 위해 mysql을 사용하고 트래픽을 줄이기 위해 redis를 사용하여 PHP 메시지 큐의 구현 원리를 자세히 설명합니다.

큐의 개념:

1 큐 구조의 미들웨어입니다.

2. 메시지가 배치됩니다 즉시 처리가 필요하지 않습니다

3, 구독자가 처리합니다 /소비자 순서대로 #🎜🎜 ##🎜🎜 #

대기열 원칙:

#🎜 🎜#도 솔루션입니다 결합의 원리: 비즈니스 시스템과 대기열 처리 시스템 사이에는 아무런 관계가 없습니다

하나는 쓰기(비즈니스 시스템)이고 다른 하나는 읽기(큐 관리 시스템)입니다.

그냥 쓰기

대기열에

write, 다른 것은 걱정하지 마세요. 다 읽을 수 있는지 또는 읽을 수 있는지는 중요하지 않습니다. not# 🎜🎜# 마찬가지로 대기열에서 을 읽고

읽고

을 읽고, 오면 일하고 일이 없으면 쉬세요#🎜 🎜## 🎜🎜#응용 시나리오: Redundancy:

대기열의 영구 저장

. 이후에 주문 처리 프로그램에서 가져옵니다. 처리가 완료되면 이 레코드를 삭제하세요 디커플링: 이 2개의

시스템(비즈니스 및 대기열 처리)을 분리하는 것입니다. 일반적으로 수행하는 작업은 하나의 시스템입니다. 대기열 입력 및 종료 시스템 사이에는 직접적인 관계가 없습니다.

한 시스템이 충돌하더라도 다른 시스템은 영향을 받지 않습니다 중간에 대기열이 있기 때문입니다

# 🎜🎜# 트래픽 감소: 반짝 세일과 급한 세일. 트래픽이 급격하게 증가하여

캐시와 함께 메시지 큐를 사용했습니다 (즉, 제한에 따라 10개만 허용되면 10개가 큐에 저장된 후에는 더 이상 저장되지 않습니다. , 플래시 세일이 끝났다는 메시지가 표시됩니다) 비동기 통신: 메시지 자체로 대기 중인 시스템이

직접 반환될 수 있으므로 비동기 작업은 프로그램이 실현됩니다

시나리오 확장 속성: 예를 들어

이제 주문 시스템과 금융 시스템만 있으면 유통 시스템을 추가하고 싶습니다. 앞으로 배포 시스템이 이 대기열을 직접 구독하도록 하세요

정렬 보장: #🎜🎜과 같은 일부 시나리오에서 # 은행 데이터의 처리 순서는 매우 중요합니다 대기열 자체를 단일 스레드, 단일 입력, 단일 출력 시스템으로 만들 수 있기 때문에 신뢰성이 높고 쉽습니다. 구현 속도 느림

2. Redis 사용: 단일 대용량 메시지 패키지에 대한 빠르고 낮은 효율성

3 보다 전문적인 타사 라이브러리 사용: 매우 전문적입니다. 신뢰할 수 있고 배우는 데 비용이 많이 듭니다. 메시지 처리 트리거 메커니즘:

1. 무한 루프 읽기: 구현하기 쉬우며 오류 발생 시 제때 응답할 수 없음(

반짝세일 등 단기 거래에 적합 )

2. 예정된 작업 : 압력이 고르게 분산되고 처리 상한선이 있습니다(피크가 아무리 불안정하더라도) 대기열 앞의 시스템 값은

입니다. 대기열 뒤에 있는 시스템은 여전히 ​​정기적으로 대기열을 실행합니다

)

참고: 타이밍 시간이 핵심입니다. 이전 예정된 작업이 완료되기 전에 다음 예정된 작업을 시작하지 마세요.# 🎜🎜#

사례: 주문 시스템, 주문한 후 주문 정보가 대기열에 기록되고 주문이 완료됩니다. 즉시 반환되었습니다. 배포 시스템은 몇 분마다 정기적으로 대기열을 읽고 주문을 요약합니다

3. 데몬 프로세스: php-fpm 및 cgi와 유사하며 쉘 기반이 필요합니다. 큐에 콘텐츠가 있는지 감지하는 프로세스입니다. 콘텐츠가 있으면 Dequeuing 시스템을 시작하여 처리합니다.) 디커플링 사례:

디커플링 이유: 아키텍처가 함께 있는 경우. 주문 시스템은 큰 압박을 받고 있으며 물류 정보를 즉시 반환할 필요가 없습니다. 주문이 무너지면 물류도 무너지므로 분리해야 합니다.

주문 시스템은 대기열에 코드를 작성합니다.

Distribution 시스템은 대기열 코드를 읽습니다.

예약된 작업 수행Crontab -e

# 🎜🎜#

참고: 새 로그 파일을 직접 만들어야 합니다

#🎜🎜 #

1. 브라우저를 통해 액세스

order.php주문 추가 #🎜 🎜#2, 결과를 보려면 데이터베이스로 이동하고, 로그인에서 결과를 확인하세요

shell

(했습니다 성공적으로 실행되지 않으면 다음과 같을 수 있습니다# 🎜🎜#sh파일은 특정 디렉터리에 있어야 하며 검토가 완료된 후 실행됩니다)# 🎜🎜##🎜 🎜#트래픽 차단 사례에 Redis 사용

# 🎜🎜#

# 🎜🎜#Idea:

1 Redis에 쓰기를 요청합니다.

2. Redis에 저장된 데이터를 삭제하고, 상한치를 초과하면 폐기합니다(플래시 세일 종료시 반납)#🎜 🎜#3. Redis에 저장된 데이터를 데이터베이스에 병합하는 무한 루프 처리 #🎜🎜 #
테이블 디자인:

#🎜🎜 #

플래시 세일 코드:

#🎜 🎜#

저장소 코드:

#🎜 🎜#

브라우저에서 #🎜🎜로 직접 액세스 #user.php

에서 사용됨
shell

# 🎜🎜#

php -f savetodb.php

# 🎜🎜#보기 위해 데이터베이스로 이동
관련 권장 사항:

#🎜🎜 #PHP 메시지 대기열 서비스

위 내용은 PHP 대기열 처리: PHP 메시지 대기열 구현 원리(그림 및 텍스트)의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!