我知道Hangfire不在与ASP.NET相同的上下文中运行,它有自己的线程池,但是我应该在我的后台作业中使用变量。这是可以理解的,因为实际上,这些作业可能不会在同一台服务器上运行。这意味着,如果我执行 _locked = false;
(在Checker()
中),它永远不会被应用,因为它在另一个上下文中运行。对于BackgroundJob.Enqueue(() => Start(bot));
也是如此,如果它是一个定期作业(cron job),那么我在内部使用的那些变量将在每个单独的cron job出现时重置。
在这种情况下,如何使用变量?
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;
}
_lock
定义为静态变量或使用快速数据库(如Redis)来更改_lock
变量? - AminSojoudi