3

我一直在使用带有新缓存组件(https://symfony.com/doc/current/components/cache.html)的 Symfony 3.1,我正在使用 redis 适配器

配置.yml

cache:
    app: cache.adapter.redis
    default_redis_provider: "redis://127.0.0.1:6379"

基本上,当我对特定资源执行 GET 时,我将数据保存在 redis 中,当我执行 POST 时,我将其从 redis 中删除。

在开发模式下使用 symfony,数据按我的预期从缓存中存储/删除。但是当我将其更改为 prod 时,“deleteItem”不再从 redis 缓存中删除该项目。我在日志中找不到任何错误,所以我有点迷失了。

这是我如何使用缓存的示例

protected function getCache(){
   return $this->get('cache.app');
}

public function getAction(){        
    $cacheItem = $this->getCache()->getItem('example-key');
    $data = ... // Check cacheItem isHit() ...      
    $cacheItem->expiresAfter($this->defaultCacheTime);
    $cacheItem->set($data);
    $this->getCache()->save($cacheItem);        
}

public function postAction() {
    ...
    $this->getCache()->deleteItem('example-key');
}

更新 - 我找到了可能导致此问题的原因

这是 symfony AbstractAdapter 和 RedisAdapter 的部分代码:

public function deleteItem($key)
{
    return $this->deleteItems(array($key));
}

public function deleteItems(array $keys)
{
    $ids = array();

    foreach ($keys as $key) {
        $ids[$key] = $this->getId($key);
        unset($this->deferred[$key]);
    }

    try {
        if ($this->doDelete($ids)) {
            return true;
        }
    } catch (\Exception $e) {
    }

    $ok = true;

    // When bulk-delete failed, retry each item individually
    foreach ($ids as $key => $id) {
        try {
            $e = null;
            if ($this->doDelete(array($id))) {
                continue;
            }
        } catch (\Exception $e) {
        }
        CacheItem::log($this->logger, 'Failed to delete key "{key}"', array('key' => $key, 'exception' => $e));
        $ok = false;
    }

    return $ok;
}

protected function doDelete(array $ids)
{
    if ($ids) {
        $this->redis->del($ids);
    }

    return true;
}

这是 Predis StreamConnection.php 的部分代码:

public function writeRequest(CommandInterface $command)
{
    $commandID = $command->getId();
    $arguments = $command->getArguments();

    $cmdlen = strlen($commandID);
    $reqlen = count($arguments) + 1;

    $buffer = "*{$reqlen}\r\n\${$cmdlen}\r\n{$commandID}\r\n";

    for ($i = 0, $reqlen--; $i < $reqlen; $i++) {
        $argument = $arguments[$i];
        $arglen = strlen($argument);
        $buffer .= "\${$arglen}\r\n{$argument}\r\n";
    }

    $this->write($buffer);
}   

当我调用 deleteItem('example-key') 时,它会调用 deleteItems(..) 来删除该键..

问题是,deleteItems() 正在调用 doDelete() 并传递一个像 'example-key' => 'prefix_example-key'

doDelete(),然后调用 Redis 客户端,传递相同的数组string => string,当我认为它应该是index => string,例如:[0] => 'prefix_example-key'而不是['example-key'] => 'prefix_example-key'

然后redis客户端在处理要执行的命令时,接收该数组作为$arguments,并在for循环中这样做: $argument = $arguments[$i];由于数组是string => string格式化的,它不会工作,在开发模式下,它显示Notice undefined offset 0错误

这是奇怪的部分

  • 在“开发”模式下,它会抛出一个错误,因此 deleteItems() 将捕获它,并尝试再次删除该项目,这一次,正确发送参数
  • 在“prod”模式下,Notice undefined offset 0不知道为什么,但它不会抛出异常,所以 deleteItems(..) 不会捕捉到它,直接返回..

我找到了一种让它对我有用的方法,如果我在 doDelete 方法中添加 array_values,它就可以工作:

protected function doDelete(array $ids)
{
    if ($ids) {
        $this->redis->del(array_values($ids));
    }

    return true;
}

我不知道所有这些是否有意义,我想我会在 symfony 错误跟踪器中打开一个问题

4

1 回答 1

0

我的错,这是由过时的 Predis 版本引起的,我认为我有最新版本的 Predis,但我没有

最新版本一切正常

于 2016-10-16T21:41:40.407 回答