tp6中使用Redis实现消息队列（tp6redis列队）

ThinPHP6通过TP自带的Cache类及Redis扩展，实现消息队列，主要实现一对一和一对多消息传递，带来出人意料地易用性和效率。本文将介绍如何在 ThinPHP6 中使用Redis实现消息队列。

在拓展下安装Redis扩展，地址是;https://pecl.php.net/package/redis 。

然后，安装完毕后，编辑 TP 框架根目录`config/app.php`文件，把Redis扩展加到cache配置项中：

'cache'     => [
    'type'   => 'redis',
    'host'  => '127.0.0.1',
    'port' => '6379',
     // 更多参数（如auth） 也可以在这里加上
],

接着，在`application/commom.php`文件中，定义消息队列操作类：

class Queue{

    //设置消息
    public function set($data){
        \think\Cache::store('redis')->rpush('tp6_log',$data);
    }
    //获取消息数量
    public function count(){
        return \think\Cache::store('redis')->llen('tp6_log');
    }
    //获取一个消息
    public function lpop(){
        return \think\Cache::store('redis')->lpop('tp6_log');
    }
}

我们就可以在我们的代码中开始使用这些函数了：

$Queue= new Queue;
//存储一个消息
$Queue->set('tp6 message');
echo $Queue->count(); //输出 1

//获取一个消息
$msg = $Queue->lpop();
echo $msg; //输出 tp6 message

以上就是在 ThinPHP6 中如何使用Redis实现消息队列的教程。由于Redis具有高效、高性能等优势，ThinPHP6 也因此更加高效，这一切都归功于Redis实现的消息队列。