Hangfire 在作业中使用变量

Question

我知道 hangfire 不运行与 ASP.NET 在相同的上下文中，它有自己的线程池，但我应该在我的后台作业中使用变量。这是可以理解的，因为事实上，这些作业可能不在同一台服务器上运行。这意味着如果我执行 _locked = false;（在 Checker() 中），它将永远不会被应用，因为它在另一个上下文中是运行ning。 BackgroundJob.Enqueue(() => Start(bot)); 也是如此，如果它是一个循环作业（cron 作业），我在内部使用的那些变量将始终在弹出的每个 cron 作业上重置。

在这种情况下如何使用变量？

private UpdateSubscription _subscription;

private StringBuilder _sb = new StringBuilder();
private bool _locked = false;

public void RunStart(Bot bot)
{
    BackgroundJob.Enqueue(() => Start(bot));
}

public void Start(Bot bot)
{
    ApplyCredentialsOnClient();

    var lastKnownKline = _client.GetKlines(bot.CryptoPair.Symbol, bot.TimeInterval.Interval, limit: 2).Data.First();
    _subscription = _socketClient.SubscribeToKlineUpdates(bot.CryptoPair.Symbol, bot.TimeInterval.Interval, async data =>
    {
        if (data.Data.Final)
        {
            _logger.LogError($"Final | Open time: {data.Data.OpenTime.ToLocalTime()}");
        }

        if (lastKnownKline.OpenTime != data.Data.OpenTime)
        {
            // Static
            _logger.LogError($"Static | Open time: {lastKnownKline.OpenTime.ToLocalTime()} | {lastKnownKline.Close}");
        }
        else if (lastKnownKline.OpenTime == data.Data.OpenTime && lastKnownKline.Close != data.Data.Close)
        {
            // Real time
            if (!_locked)
            {
                _logger.LogError($"Real time | Open time: {data.Data.OpenTime.ToLocalTime()} | {data.Data.Close}");
                _locked = true;

                BackgroundJob.Schedule(() => Checker(), TimeSpan.FromMinutes(1));
            }
            else
            {
                _logger.LogInformation("Locked");
            }
        }

        lastKnownKline = data.Data.ToKline();
    }).Data;
}

public void Checker()
{
    _logger.LogWarning($"{DateTime.UtcNow.ToLocalTime()}");

    _locked = false;
}

Answer 1

我想到了多种解决方案，我将从最简单的开始。

如果您是运行单例，则：

1-使用静态变量：

public static bool _locked = false;

或

2- 将整个 class 定义为 startup 中的单例，因此每次 Hangfire 尝试激活 class 时，它到达到同一个实例。

public void ConfigureServices(IServiceCollection services)
{
    //....

    services.AddSingleton<SomeClass>();

    //....
}

如果您在多个实例上运行执行此任务

那么你应该将这个变量存储到数据库中，比如 Redis 并使用数据库更改它的状态。因此可以从多个作业访问同一个变量。

Hangfire 在作业中使用变量

Hangfire use of variables inside jobs

c#

asp.net-core

hangfire