집 >백엔드 개발 >PHP 튜토리얼 >PHP+MySQL을 이용한 메시지 큐 구현 방법 분석

PHP+MySQL을 이용한 메시지 큐 구현 방법 분석

不言원래의: 2018-05-09 10:20:081248검색

이 글에서는 주로 PHP+MySQL로 메시지 큐를 구현하는 방법을 소개하고, 메시지 큐를 구축하고 타이머를 사용하여 간헐적으로 정보를 보내는 php+mysql의 관련 작업 기술을 예시 형식으로 설명합니다. it

이 문서의 예제에서는 PHP+MySQL이 메시지 대기열 메서드를 구현하는 방법을 설명합니다. 참고할 수 있도록 모든 사람과 공유하세요. 세부 사항은 다음과 같습니다.

최근 문자 메시지를 일괄 전송해야 하는 상황이 발생했으며 문자 메시지 인터페이스는 제3자가 제공합니다. 처음에는 휴대폰 번호를 받은 후 루프에서 인터페이스를 호출하여 보내는 것으로 충분하지 않을까 생각했습니다.

하지만 문제는 빨리 발견되었습니다. 문자 메시지의 양이 많으면 시간이 많이 걸릴 뿐만 아니라 성공률도 매우 낮습니다.

그래서 PHP와 MySQL을 사용하여 메시지 큐를 구현하고 문자 메시지를 하나씩 보내려고 생각했습니다. 구체적인 구현 방법은 다음과 같습니다.

먼저 다음 필드를 포함하는 데이터 테이블 sms를 만듭니다.

id,
phone, //휴대폰 번호
content //SMS content

문자 메시지 및 모바일 전송해야 하는 전화번호는 SMS 테이블에 저장됩니다.

다음으로 PHP를 사용하여 정기적으로 기록을 읽고 문자 메시지를 보내는 타이머를 구현해야 합니다.

<?php
$db = new Db();
$sms = new Sms();
while(true){
  $item = $db->getFirstRecord(); //获取数据表第一条记录
  if(!$item){
    //如果队列中没有数据，则结束定时器
    break;
  }
  $res = $sms->send($item[&#39;phone&#39;],$item[&#39;content&#39;]); //发送短信
  if($res){
    $db->deleteFristRecord(); //删除发送成功的记录
    echo $item[&#39;phone&#39;].&#39;发送成功&#39;;
  }else{
    echo $item[&#39;phone&#39;].&#39;发送失败，稍后继续尝试&#39;；
  }
  sleep(10); //每隔十秒循环一次
}
echo &#39;发送完毕！&#39;;
?>

코드를 타이머_sms.php로 저장하고 명령줄을 열고 타이머를 실행합니다.

php timer_sms.php

좋아, PHP 타이머는 설정된 시간 간격(여기에서는 10초로 설정됨)에 따라 문자 메시지 전송 작업을 자동으로 완료합니다. 작업이 완료되면 타이머가 자동으로 종료되고 더 이상 서버 리소스를 차지하지 않습니다.

내 테스트에 따르면 PHP 타이머는 많은 리소스를 차지하지 않으며 서버에 부담을 주지 않습니다. 또한 데이터베이스에 비동기적으로 액세스해도 데이터베이스 작동에는 영향을 미치지 않습니다.

이 방법의 장점은 다음과 같습니다.

1. 백그라운드에서 실행되므로 프런트엔드에서 기다릴 필요가 없습니다.

2. 성공률이 높으며 실패한 기록은 성공할 때까지 자동으로 재전송됩니다.

PHP+MySQL을 이용한 메시지 큐 구현 방법 분석

관련 기사