ThinkPHP5에서 thinkphp-queue를 사용하시겠습니까?

다음 튜토리얼 칼럼인 thinkphp Framework에서는 ThinkPHP5에서 thinkphp-queue를 사용하는 방법을 소개하겠습니다. 도움이 필요한 친구들에게 도움이 되길 바랍니다!

최근 편집자는 ThinkPHP5.0 프레임워크를 사용할 때 php-queue 사용법을 모르는 그룹의 친구로부터 메시지를 받았습니다(정말 당황스럽습니다. 인터넷에 이에 대한 튜토리얼이 많이 있습니다). ). 하하, 참고하고 싶지 않으셔도 상관없습니다. 자세히 살펴보겠습니다~~ 큐란 무엇인가요? 대기열은 무엇을 해결합니까? 대기열에 대한 시나리오는 무엇입니까? ...등등. 개발자는 먼저 이러한 문제를 스스로 이해해야 합니다. 또한 이 경우는 ThinkPHP 프레임워크에서 특정 작업만 수행합니다.

1. thinkphp-queue 설치

Composer를 사용하여 설치하는 것을 권장하며, 프로젝트의 루트 디렉터리로 전환하여 실행합니다. composer require topthink/think-queue

2. message queue

구성 파일은 그림과 같이 applicationextraqueue .php에 있습니다.

Redis 드라이버를 사용하세요. Redis 환경이 설치되지 않은 경우 직접 설치하시기 바랍니다. 그림과 같이 다른 유형의 드라이버를 사용합니다.

3. 작업 생성

인덱스 모듈 아래의 Index.php 파일에 queue라는 메서드를 생성합니다(이렇게 해야 합니까? 물론 그렇지 않습니다. 이 튜토리얼은 단지 예시일 뿐이며, 그림과 같이 새 모듈을 생성할 수 있으며 메서드 이름은 기타가 될 수 있습니다.

4. 작업 메시지 소비 및 삭제 처리

우리는 그림과 같이 소비 모드를 처리하는 데 사용되는 index 모듈 아래의 작업 파일입니다.

Demo 클래스 아래에서 기본적으로 메시지 큐에서 호출되는 메서드인 fire 메서드를 만듭니다. 그림과 같이:

위는 완료된 작업-"Push--"Consumer의 생성입니다.
브라우저 또는 터미널에서 index/queue.html 메소드를 실행하여 생성 및 푸시를 완료합니다. 작업 소비와 관련하여 명령을 참조하고 터미널에서 프로젝트의 루트 디렉터리로 전환할 수 있습니다:

5.

php think queue:listen
php think queue:work –daemon（不加–daemon为执行单个任务）

두 가지 종류가 있는 특정 선택적 매개변수의 경우 명령을 입력하고 –help를 추가하면

감독자와 함께 사용하여 프로세스가 상주하는지 확인할 수 있습니다

1.1 명령 모드

• queue:subscribe 명령 [ 2017-02-15 현재 작성자는 이 모드를 아직 구현하지 않았습니다. 건너뛰기]

• queue:work 명령

  work 명령: 이 명령은 시작됩니다. 메시지 큐를 처리하는 작업 프로세스입니다.

  php think queue:work --queue helloJobQueue

• queue:listen 명령

  listen 명령: 이 명령은 수신 대기 상위 프로세스를 생성하며, 이 프로세스는 proc_open('php think queue:work')를 통해 상위 프로세스에 의해 생성됩니다. 작업 하위 프로세스는 메시지 큐를 처리하고 작업 프로세스의 실행 시간을 제한합니다. proc_open(‘php think queue:work’) 的方式来创建一个work 子 进程来处理消息队列，且限制该work进程的执行时间。

  php think queue:listen --queue helloJobQueue

2.2 命令行参数

• Work 模式

  php think queue:work \
  --daemon            //是否循环执行，如果不加该参数，则该命令处理完下一个消息就退出
  --queue  helloJobQueue  //要处理的队列的名称
  --delay  0 \        //如果本次任务执行抛出异常且任务未被删除时，设置其下次执行前延迟多少秒,默认为0
  --force  \          //系统处于维护状态时是否仍然处理任务，并未找到相关说明
  --memory 128 \      //该进程允许使用的内存上限，以 M 为单位
  --sleep  3 \        //如果队列中无任务，则sleep多少秒后重新检查(work+daemon模式)或者退出(listen或非daemon模式)
  --tries  2          //如果任务已经超过尝试次数上限，则触发‘任务尝试次数超限’事件，默认为0

• Listen 模式

  php think queue:listen \
  --queue  helloJobQueue \   //监听的队列的名称
  --delay  0 \         //如果本次任务执行抛出异常且任务未被删除时，设置其下次执行前延迟多少秒,默认为0
  --memory 128 \       //该进程允许使用的内存上限，以 M 为单位
  --sleep  3 \         //如果队列中无任务，则多长时间后重新检查，daemon模式下有效
  --tries  0 \         //如果任务已经超过重发次数上限，则进入失败处理逻辑，默认为0
  --timeout 60         //创建的work子进程的允许执行的最长时间，以秒为单位

  可以看到 listen 模式下，不包含 --deamon

  nohup php think queue:work --daemon --queue 任务名称 &
   nohup php think queue:work --daemon --queue 任务名称 &

  
  

  2.2 명령줄 매개변수

  Work 모드

  rrreee🎜🎜🎜Listen 모드 🎜rrreee🎜청취 모드에서 --를 볼 수 있습니다. deamon 매개변수가 포함되어 있지 않습니다. 이유는 아래에 설명되어 있습니다.🎜🎜🎜🎜Linux는 tp5를 예로 들어 데몬 프로세스를 시작합니다.🎜🎜rrreee🎜Linux에서 작업 수를 확인하려면 jobs -l을 입력하세요. 🎜🎜🎜🎜 터미널에서

  위 내용은 ThinkPHP5에서 thinkphp-queue를 사용하시겠습니까?의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!