尾部寫入 for ($i=1;$i<=1000;$i++){Cache::store('redis')->rpush('list',date("Y-m-d H:i:s")."消息{$i}"); }頭部讀取消息隊列并刪除 $list = Cache::store('redis')->lpop('list');

1、新建個方法運行寫入隊列

public function hello(){for ($i=1;$i<=1000;$i++){Cache::store('redis')->rpush('list',date("Y-m-d H:i:s")."消息{$i}");} }

2、tp6創建命令生成文件Dade

php think make:command Dade

加入命令config/console.php

<?php // +---------------------------------------------------------------------- // | 控制臺配置 // +---------------------------------------------------------------------- return [// 指令定義'commands' => [//定時任務命令'Dade' => app\command\Dade::class], ];

編寫

Dade.php

<?phpnamespace app\admin\command;use think\console\Command; use think\console\Input; use think\console\Output; use app\admin\model\Dade; use think\facade\Cache;class Dade extends Command {protected function configure(){$this->setName('ExcelTask');}protected function execute(Input $input, Output $output){//php think OrderTask$this->start();$output->writeln('操作成功');}/*** 啟動*/public function start(){while (1) {//執行讀取，看效果sleep(1);$list = Cache::store('redis')->lpop('list');if(!empty($list)){$data = [];$data['name'] = "大得";$data['date'] = $list;Dade::create($data);echo $list."\n";}}}}

3.執行

php think Dade

4、寶塔添加守護進程（以防死掉，守護進行重新啟動）

Supervisor

5、tp6官方說數據庫配置文件開啟

// 是否需要斷線重連 'break_reconnect' => true,

?

總結

以上是生活随笔為你收集整理的tp6使用redis消息队列的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。