TP5异步操作Redis列表的实践（tp5 redis 列表）

随着现在各类不同的互联网技术的迅速发展，更多的应用系统倾向于使用Redis作为其存储系统，而在PHP开发中，Thinkphp框架更是无处不在。本文将重点介绍在TP5中通过Redis存储列表，实现异步处理的操作实践。

首先需要在TP5项目中创建一个helper文件夹和一个redis.php文件，在redis.php文件中引入Redis数据库操作类，实现redis相关的操作：

“`php

use Redis;

namespace helper;

class Redis {

public $redis;

// 连接redis

public function __construct() {

$host = ‘127.0.0.1’; //服务器ip

$port = 6379; //端口

$password = ”; //密码

$this->redis = new \Redis;

$this->redis->connect($host, $port) or die(“Fled to connect”);

if($password != ”) {

$this->redis->auth($password) or die(“Fled to authenticate”);

}

}

// 断开连接

public function close() {

$this->redis->close();

}

// 将字符串放入redis列表中

public function writeList($listName, $val) {

if($this->redis->lPush($listName, $val) > 0) {

return true;

}

return false;

}

// 从redis的列表中弹出字符串

public function readList($listName) {

return $this->redis->lPop($listName);

}

}

接下来我们在控制器controller中调用Redis类，将需要异步处理的字符串put进列表中：

```php

namespace index\controller;
use think\Controller;
use think\Request;

class RedisController extends Controller
{
 public function index() {
  $listName = 'listName';
  $val = 'foo';
  
  $redis = new \helper\Redis();
  $res = $redis->writeList($listName, $val);
  if($res) {
   echo '写入成功';
  } else {
   echo '写入失败';
  }
  $redis->close();
 }
}

在守护进程中，循环检测$listName中是否有数据，并异步处理：

“`php

namespace index\controller;

use think\Controller;

class IndexController extends Controller

{

public function daemon() {

while(true) {

$listName = ‘listName’;

$redis = new \helper\Redis($listName);

//当队列为空时，睡眠一小段时间，避免过度消耗资源

while($redis->lLen($listName) == 0) {

//睡眠1s

sleep(1);

}

// 从redis队列中取一条数据

$str = (string) $redis->readList($listName);

if ($str) {

echo $str;

//解析接收到的字符串，异步处理数据

$this->process($str);

}

$redis->close();

}

}

// 异步处理函数

private function process($str) {

// dosomething

}

}

上面我们就介绍了如何通过Redis存储列表实现TP5的异步处理，这样就可以提高程序的性能，提升用户体验。