简化 Redis 管道与事务操作

[huangdijia]

Laravel 对 Redis 的管道与事务做了封装，使用起来特别简单、方便

• 事务

use Illuminate\Support\Facades\Redis;

Redis::transaction(function ($redis) {
    $redis->incr('user_visits', 1);
    $redis->incr('total_visits', 1);
});

• 管道

use Illuminate\Support\Facades\Redis;

Redis::pipeline(function ($pipe) {
    for ($i = 0; $i < 1000; $i++) {
        $pipe->set("key:$i", $i);
    }
});

Hyperf 的 Redis 为了保持与原生的一致性，并未做任何封装。如果想要体验像 Laravel 一样的简便怎么办？也不复杂，也不做过多的思路讲解，解决方案就是 classMap，原因有几个：

• Redis 并未支持 Macroable
• 考虑到 RedisProxy，依赖置换的方案也不够完美
• 对 Redis 类做 classMap，维护相对复杂

最终决定对 Hyperf\Redis\ScanCaller 下手。

<?php

declare(strict_types=1);

namespace Hyperf\Redis;

trait ScanCaller
{
    public function scan(&$cursor, ...$arguments)
    {
        return $this->__call('scan', array_merge([&$cursor], $arguments));
    }

    public function hScan($key, &$cursor, ...$arguments)
    {
        return $this->__call('hScan', array_merge([$key, &$cursor], $arguments));
    }

    public function zScan($key, &$cursor, ...$arguments)
    {
        return $this->__call('zScan', array_merge([$key, &$cursor], $arguments));
    }

    public function sScan($key, &$cursor, ...$arguments)
    {
        return $this->__call('sScan', array_merge([$key, &$cursor], $arguments));
    }

    /**
     * Execute commands in a pipeline.
     *
     * @return array|\Redis
     */
    public function pipeline(callable $callback = null)
    {
        $pipeline = $this->__call('pipeline', []);

        return is_null($callback) ? $pipeline : tap($pipeline, $callback)->exec();
    }

    /**
     * Execute commands in a transaction.
     *
     * @return array|\Redis|\RedisCluster
     */
    public function transaction(callable $callback = null)
    {
        $transaction = $this->__call('multi', []);

        return is_null($callback) ? $transaction : tap($transaction, $callback)->exec();
    }
}

配置 classMap

<?php
return [
    'scan' => [
        'paths' => [
            BASE_PATH . '/app',
        ],
        'collectors' => [
        ],
        'ignore_annotations' => [
            'mixin',
        ],
        'class_map' => [
Hyperf\Redis\ScanCaller::class => BASE_PATH . '/app/Kernel/ClassMap/ScanCaller.php',
        ]
];

使用方法

di(\Hyperf\Redis\Redis::class)->transaction(function ($redis) {
    $redis->incr('user_visits', 1);
    $redis->incr('total_visits', 1);
});

di(\Hyperf\Redis\Redis::class)->pipeline(function($pipe) {
    for ($i = 0; $i < 1000; $i++) {
        $pipe->set("key:$i", $i);
    }
});