67 lines
1.8 KiB
PHP
67 lines
1.8 KiB
PHP
<?php
|
||
|
||
declare(strict_types=1);
|
||
|
||
namespace app\common\service;
|
||
|
||
use support\Redis;
|
||
use Throwable;
|
||
|
||
/**
|
||
* 热点缓存回源刷新队列：LPUSH / RPOP，由独立进程消费，削峰 Redis 与 DB 回读。
|
||
* 业务线程在落库后仍会同步刷新缓存；队列任务为幂等补偿，避免瞬时高峰打满连接。
|
||
*/
|
||
final class GameHotDataWriteQueue
|
||
{
|
||
public const OP_USER_REFRESH = 'user.refresh';
|
||
|
||
public const OP_GC_REFRESH = 'gc.refresh';
|
||
|
||
public const OP_GR_SYNC = 'gr.sync';
|
||
|
||
public static function queueListKey(): string
|
||
{
|
||
$k = config('game_hot_cache.queue_list_key', 'dfw:q:hot_data_write');
|
||
return is_string($k) && $k !== '' ? $k : 'dfw:q:hot_data_write';
|
||
}
|
||
|
||
public static function enabled(): bool
|
||
{
|
||
return filter_var(config('game_hot_cache.enable_cache_write_queue', true), FILTER_VALIDATE_BOOLEAN);
|
||
}
|
||
|
||
/**
|
||
* @param array<string, mixed> $job 须含 op 字段
|
||
*/
|
||
public static function enqueue(array $job): void
|
||
{
|
||
if (!self::enabled()) {
|
||
return;
|
||
}
|
||
if (!isset($job['op']) || !is_string($job['op']) || $job['op'] === '') {
|
||
return;
|
||
}
|
||
$job['v'] = 1;
|
||
$job['ts'] = time();
|
||
$max = self::maxQueueLength();
|
||
try {
|
||
if ($max > 0) {
|
||
$len = Redis::lLen(self::queueListKey());
|
||
if (is_int($len) && $len >= $max) {
|
||
Redis::rPop(self::queueListKey());
|
||
}
|
||
}
|
||
Redis::lPush(self::queueListKey(), json_encode($job, JSON_UNESCAPED_UNICODE));
|
||
} catch (Throwable) {
|
||
}
|
||
}
|
||
|
||
public static function maxQueueLength(): int
|
||
{
|
||
$v = config('game_hot_cache.queue_max_length', 50000);
|
||
$n = filter_var($v, FILTER_VALIDATE_INT);
|
||
|
||
return ($n === false || $n < 0) ? 50000 : $n;
|
||
}
|
||
}
|