源码
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
| <?php
declare(strict_types=1);
namespace Hyperf\Cache\Aspect;
use Hyperf\Cache\Annotation\CacheAhead;
use Hyperf\Cache\AnnotationManager;
use Hyperf\Cache\CacheManager;
use Hyperf\Cache\Driver\KeyCollectorInterface;
use Hyperf\Di\Aop\AbstractAspect;
use Hyperf\Di\Aop\ProceedingJoinPoint;
class CacheAheadAspect extends AbstractAspect
{
public array $classes = [];
public array $annotations = [
CacheAhead::class,
];
public function __construct(protected CacheManager $manager, protected AnnotationManager $annotationManager)
{
}
public function process(ProceedingJoinPoint $proceedingJoinPoint)
{
$className = $proceedingJoinPoint->className;
$method = $proceedingJoinPoint->methodName;
$arguments = $proceedingJoinPoint->arguments['keys'];
$now = time();
[$key, $ttl, $group, $annotation] = $this->annotationManager->getCacheAheadValue($className, $method, $arguments);
$driver = $this->manager->getDriver($group);
[$has, $result] = $driver->fetch($key);
if ($has && isset($result['expired_time'], $result['data'])) {
if ($now < $result['expired_time']) {
return $result['data'];
}
if (! $driver->getConnection()->set($key . ':lock', '1', ['NX', 'EX' => $annotation->lockSeconds])) {
return $result['data'];
}
}
$result = $proceedingJoinPoint->process();
if (! in_array($result, (array) $annotation->skipCacheResults, true)) {
$driver->set(
$key,
[
'expired_time' => $now + $annotation->ttl - $annotation->aheadSeconds,
'data' => $result,
],
$ttl
);
if ($driver instanceof KeyCollectorInterface && $annotation instanceof CacheAhead && $annotation->collect) {
$driver->addKey($annotation->prefix . 'MEMBERS', $key);
}
}
return $result;
}
}
|
解析
这段代码实现了一个名为缓存预热（Cache Ahead）的切面，是在 Hyperf 框架下实现的。缓存预热是一种优化策略，它通过在缓存过期之前更新缓存数据，以确保用户在请求数据时能够快速获取到最新的数据，从而提高系统的性能和响应速度。
首先，让我们逐步分析这段代码的主要功能：
切面类定义与注解声明：
这个切面类继承自 Hyperf 框架的 AbstractAspect 类，用于实现面向切面编程。在类中定义了 $classes 和 $annotations 两个属性，分别用于指定该切面要拦截的类和注解，这里指定了 CacheAhead 注解。
构造函数注入依赖：
构造函数中注入了 CacheManager 和 AnnotationManager 对象，这些对象用于管理缓存和注解信息，后续会在方法中使用它们来获取缓存和注解的相关信息。
核心处理方法 process：
这是切面类中最重要的方法，它接收一个 ProceedingJoinPoint 对象，表示一个切点，即被拦截的方法调用。
首先，从 ProceedingJoinPoint 对象中获取了当前方法所在的类名、方法名和参数，以及当前时间戳。
然后，通过注解管理器 AnnotationManager 获取了缓存预热相关的注解信息，包括缓存键、过期时间等。
接着，通过缓存管理器 CacheManager 获取了对应缓存组的驱动器对象。
在获取了缓存驱动器之后，首先尝试从缓存中读取数据，如果缓存数据存在且未过期，则直接返回缓存数据。
如果缓存数据不存在或已过期，则尝试获取锁，避免多个请求同时更新缓存。如果成功获取到锁或者锁已存在（即有其他请求已经在更新缓存），则继续执行目标方法（被拦截的方法），获取最新的数据。
获取到最新数据后，将数据更新到缓存中，并设置新的过期时间。
如果需要收集缓存键，则在驱动器中进行相应操作。
最后，返回最新的数据给调用方。
通过以上分析，可以看出这段代码的核心思想是在方法执行前检查缓存是否过期，如果过期则执行目标方法获取最新数据，并更新缓存。在高并发情况下，通过加锁机制确保只有一个请求可以更新缓存，其他请求获取老数据，从而避免了缓存击穿问题，提高了系统的稳定性和性能。
