Hangfire 中的“作业”字段为 null 或空值

Question

在 Startup.cs 中，我尝试将重复作业排入队列，如下所示：

RecurringJob.AddOrUpdate(() => Console.WriteLine("test"), Cron.Daily);

但收到错误：

请帮助找出我做错了什么。

我的配置：

    //HangFire
    services.AddHangfire(configuration => configuration
      .SetDataCompatibilityLevel(CompatibilityLevel.Version_170)
      .UseSimpleAssemblyNameTypeSerializer()
      .UseRecommendedSerializerSettings()
      .UseSqlServerStorage(Configuration.GetConnectionString("HangfireConnection"),
          new SqlServerStorageOptions
          {
              CommandBatchMaxTimeout = TimeSpan.FromMinutes(5),
              SlidingInvisibilityTimeout = TimeSpan.FromMinutes(5),
              QueuePollInterval = TimeSpan.Zero,
              UseRecommendedIsolationLevel = true,
              DisableGlobalLocks = true,
          }
      ));

附注尽管“一劳永逸”的工作确实有效。

Answer 1

Hangfire 的来源表示当表达式

!recurringJob.ContainsKey("Job") || String.IsNullOrWhiteSpace(recurringJob["Job"])

为 true 时抛出此异常（和消息）。

try
{
    if (!recurringJob.ContainsKey("Job") || String.IsNullOrWhiteSpace(recurringJob["Job"]))
    {
        throw new InvalidOperationException("The 'Job' field has a null or empty value");
    }

    Job = InvocationData.DeserializePayload(recurringJob["Job"]).DeserializeJob();
}
catch (Exception ex)
{
    _errors.Add(ex);
}

recurringJob

字典通过方法

GetAllEntriesFromHash

设置：

public override Dictionary<string, string> GetAllEntriesFromHash(string key)
{
    if (key == null) throw new ArgumentNullException(nameof(key));

    return _storage.UseConnection(_dedicatedConnection, connection =>
    {
        var result = connection.Query<SqlHash>(
            $"select Field, Value from [{_storage.SchemaName}].Hash with (forceseek, readcommittedlock) where [Key] = @key",
            new { key },
            commandTimeout: _storage.CommandTimeout)
            .ToDictionary(x => x.Field, x => x.Value);

        return result.Count != 0 ? result : null;
    });
}

所以可能发生的情况是

GetAllEntriesFromHash

方法返回

null,

或不包含键

Job

的字典（或者它是空/空格）。但是，在一个帖子中，一位 Hangfire 贡献者评论道：

这甚至不是问题，只需忽略这些异常或告诉 Visual Studio 不要中断它们即可。 Hangfire 处理大量异常，并且可能在关闭期间生成大量

OperationCanceledException

，告诉所有后台进程已请求关闭。

因此，这个错误似乎可以忽略。

Answer 2

还不确定它是如何工作的，但对我来说，问题与此属性的使用有关：

[Queue("queue-name")]
public async Task Refresh(PerformContext context)

当我将其从我的方法中删除后，它就开始正常工作了。