這篇文章主要介紹ThinkPHP5中thinkphp-queue怎么用，文中介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們一定要看完！

專(zhuān)注于為中小企業(yè)提供網(wǎng)站設(shè)計(jì)、成都網(wǎng)站設(shè)計(jì)服務(wù),電腦端+手機(jī)端+微信端的三站合一,更高效的管理,為中小企業(yè)寶山免費(fèi)做網(wǎng)站提供優(yōu)質(zhì)的服務(wù)。我們立足成都，凝聚了一批互聯(lián)網(wǎng)行業(yè)人才，有力地推動(dòng)了超過(guò)千家企業(yè)的穩(wěn)健成長(zhǎng)，幫助中小企業(yè)通過(guò)網(wǎng)站建設(shè)實(shí)現(xiàn)規(guī)模擴(kuò)充和轉(zhuǎn)變。

1、安裝 thinkphp-queue

推薦使用Composer進(jìn)行安裝，切換到項(xiàng)目的根目錄，執(zhí)行：composer require topthink/think-queue

2、配置消息隊(duì)列的存儲(chǔ)環(huán)境

配置文件位于 application\extra\queue.php，如圖：

使用Redis驅(qū)動(dòng)，如果Redis環(huán)境還沒(méi)有安裝，請(qǐng)自行安裝哦，很簡(jiǎn)單的，或者也可以使用其他類(lèi)型驅(qū)動(dòng)，如圖：

3、任務(wù)的創(chuàng)建

我們?cè)趇ndex模塊下，Index.php文件，建立一個(gè)名為 queue 的方法（一定要這樣么？當(dāng)然不是，本教程，只是例子，你可以新建模塊，方法名也可以是其他），如圖：

4、任務(wù)消息的消費(fèi)以及刪除處理

我們?cè)?index模塊下創(chuàng)建一個(gè) job 文件，該文件用來(lái)處理消費(fèi)模式，如圖：

在 Demo 這個(gè)類(lèi)下，創(chuàng)建一個(gè) fire 方法，該方法是消息隊(duì)列默認(rèn)調(diào)用的方法。如圖：

以上就是完成任務(wù)的創(chuàng)建--》推送--》消費(fèi)了。
在瀏覽器或者終端，執(zhí)行一下我們 index/queue.html 方法，就完成創(chuàng)建以及推送了，關(guān)于任務(wù)消費(fèi)，可以參考一下命令，在終端切換到項(xiàng)目的根目錄：

5、監(jiān)聽(tīng)任務(wù)并執(zhí)行

php think queue:listen
php think queue:work –daemon（不加–daemon為執(zhí)行單個(gè)任務(wù)）

兩種，具體的可選參數(shù)可以輸入命令加 –help 查看

可配合supervisor使用，保證進(jìn)程常駐

1.1 命令模式

• queue:subscribe 命令 [截至2017-02-15，作者暫未實(shí)現(xiàn)該模式，略過(guò)]

• queue:work 命令

  work 命令： 該命令將啟動(dòng)一個(gè) work 進(jìn)程來(lái)處理消息隊(duì)列。

  php think queue:work --queue helloJobQueue

• queue:listen 命令

  listen 命令： 該命令將會(huì)創(chuàng)建一個(gè) listen 父進(jìn)程 ，然后由父進(jìn)程通過(guò)proc_open(‘php think queue:work’) 的方式來(lái)創(chuàng)建一個(gè)work 子 進(jìn)程來(lái)處理消息隊(duì)列，且限制該work進(jìn)程的執(zhí)行時(shí)間。

  php think queue:listen --queue helloJobQueue

2.2 命令行參數(shù)

• Work 模式

  php think queue:work \
  --daemon            //是否循環(huán)執(zhí)行，如果不加該參數(shù)，則該命令處理完下一個(gè)消息就退出
  --queue  helloJobQueue  //要處理的隊(duì)列的名稱(chēng)
  --delay  0 \        //如果本次任務(wù)執(zhí)行拋出異常且任務(wù)未被刪除時(shí)，設(shè)置其下次執(zhí)行前延遲多少秒,默認(rèn)為0
  --force  \          //系統(tǒng)處于維護(hù)狀態(tài)時(shí)是否仍然處理任務(wù)，并未找到相關(guān)說(shuō)明
  --memory 128 \      //該進(jìn)程允許使用的內(nèi)存上限，以 M 為單位
  --sleep  3 \        //如果隊(duì)列中無(wú)任務(wù)，則sleep多少秒后重新檢查(work+daemon模式)或者退出(listen或非daemon模式)
  --tries  2          //如果任務(wù)已經(jīng)超過(guò)嘗試次數(shù)上限，則觸發(fā)‘任務(wù)嘗試次數(shù)超限’事件，默認(rèn)為0

• Listen 模式

  php think queue:listen \
  --queue  helloJobQueue \   //監(jiān)聽(tīng)的隊(duì)列的名稱(chēng)
  --delay  0 \         //如果本次任務(wù)執(zhí)行拋出異常且任務(wù)未被刪除時(shí)，設(shè)置其下次執(zhí)行前延遲多少秒,默認(rèn)為0
  --memory 128 \       //該進(jìn)程允許使用的內(nèi)存上限，以 M 為單位
  --sleep  3 \         //如果隊(duì)列中無(wú)任務(wù)，則多長(zhǎng)時(shí)間后重新檢查，daemon模式下有效
  --tries  0 \         //如果任務(wù)已經(jīng)超過(guò)重發(fā)次數(shù)上限，則進(jìn)入失敗處理邏輯，默認(rèn)為0
  --timeout 60         //創(chuàng)建的work子進(jìn)程的允許執(zhí)行的最長(zhǎng)時(shí)間，以秒為單位

  可以看到 listen 模式下，不包含--deamon 參數(shù)，原因下面會(huì)說(shuō)明

Linux啟動(dòng)守護(hù)進(jìn)程，以tp5為例子

nohup php think queue:work --daemon --queue 任務(wù)名稱(chēng) &
 nohup php think queue:work --daemon --queue 任務(wù)名稱(chēng) &

在Linux查看任務(wù)數(shù)量，可以在終端輸入：jobs -l

以上是“ThinkPHP5中thinkphp-queue怎么用”這篇文章的所有內(nèi)容，感謝各位的閱讀！希望分享的內(nèi)容對(duì)大家有幫助，更多相關(guān)知識(shí)，歡迎關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道！

當(dāng)前文章：ThinkPHP5中thinkphp-queue怎么用-創(chuàng)新互聯(lián)
文章起源：http://weahome.cn/article/eoicp.html