Laravel中如何让UniqueMessage实例跨调度进程全局可用？

核心问题在于Laravel的调度任务是独立进程，每个任务启动时都会重新初始化Kernel类，内存中的静态变量无法跨进程共享，所以你的静态实例方案必然失效。要实现跨进程的日志去重，必须依赖持久化存储来共享去重状态，同时将UniqueMessage注册为单例服务确保单进程内复用。

方案一：基于Redis/缓存的跨进程去重（推荐） #

1. 修改UniqueMessage类，改用缓存存储状态 #

<?php

namespace App\Services;

use Illuminate\Support\Facades\Cache;
use Illuminate\Support\Carbon;

class UniqueMessage
{
    protected $maxAge;
    protected $logCallback;
    protected $cacheKey = 'unique_message_logs';

    public function __construct(int $maxAge, callable $logCallback)
    {
        $this->maxAge = $maxAge;
        $this->logCallback = $logCallback;
    }

    public function log(string $message)
    {
        // 清理过期记录
        $this->purgeExpired();

        $messages = Cache::get($this->cacheKey, []);
        $currentTime = Carbon::now()->timestamp;

        // 检查消息是否未记录或已过期
        if (!isset($messages[$message]) || $currentTime - $messages[$message] > $this->maxAge) {
            $messages[$message] = $currentTime;
            // 缓存时间设置为最大过期时间+缓冲，避免提前失效
            Cache::put($this->cacheKey, $messages, $this->maxAge + 60);
            
            // 执行日志写入
            call_user_func($this->logCallback, $message);
        }
    }

    protected function purgeExpired()
    {
        $messages = Cache::get($this->cacheKey, []);
        $cutoff = Carbon::now()->subSeconds($this->maxAge)->timestamp;

        foreach ($messages as $msg => $timestamp) {
            if ($timestamp < $cutoff) {
                unset($messages[$msg]);
            }
        }

        Cache::put($this->cacheKey, $messages, $this->maxAge + 60);
    }
}

2. 注册UniqueMessage为单例服务 #

在app/Providers/AppServiceProvider.php的register方法中注册单例，确保同一进程内复用实例：

<?php

namespace App\Providers;

use App\Services\UniqueMessage;
use Illuminate\Support\Facades\Log;
use Illuminate\Support\ServiceProvider;

class AppServiceProvider extends ServiceProvider
{
    public function register()
    {
        $this->app->singleton(UniqueMessage::class, function ($app) {
            // 从环境变量读取最大过期时间，默认3600秒（1小时）
            $maxAge = (int) env('LOGACCS', 3600);
            return new UniqueMessage($maxAge, [Log::class, 'info']);
        });
    }
}

3. 在Kernel的调度中使用 #

通过Laravel的服务容器获取实例，直接用于日志去重：

<?php

namespace App\Console;

use App\Services\UniqueMessage;
use Illuminate\Console\Scheduling\Schedule;
use Illuminate\Foundation\Console\Kernel as ConsoleKernel;

class Kernel extends ConsoleKernel
{
    protected function schedule(Schedule $schedule)
    {
        $uniqueLogger = app(UniqueMessage::class);

        $schedule->command('your:task')->everyMinute()->then(function () use ($uniqueLogger) {
            $uniqueLogger->log('任务your:task执行完成');
        });

        // 也可以在自定义命令的handle方法中通过依赖注入直接使用
        // 例如：public function handle(UniqueMessage $uniqueLogger) { ... }
    }
}

方案二：基于文件存储的跨进程去重（适合小型项目） #

如果没有Redis环境，也可以用本地文件存储状态，替换UniqueMessage中的缓存操作：

protected function getMessages()
{
    $filePath = storage_path('logs/unique_messages.json');
    if (!file_exists($filePath)) {
        return [];
    }
    return json_decode(file_get_contents($filePath), true) ?: [];
}

protected function saveMessages(array $messages)
{
    $filePath = storage_path('logs/unique_messages.json');
    // 确保目录存在
    if (!is_dir(dirname($filePath))) {
        mkdir(dirname($filePath), 0755, true);
    }
    file_put_contents($filePath, json_encode($messages));
}

然后修改log和purgeExpired方法，用上述两个方法替代Cache的操作即可。

关键说明 #

• 静态变量仅在单个进程内有效，调度任务是多进程模式，必须用持久化存储共享状态。
• 注册单例服务是为了在同一进程内避免重复创建UniqueMessage实例，优化资源使用。
• Redis方案的性能远高于文件存储，适合高频率调度任务的场景。

内容的提问来源于stack exchange，提问作者Arne