3

我遇到一个问题,hangfire 上的某些作业使用相同的参数排队不止一次,这些作业几乎同时排队。

我试图将工人的数量限制为一个,然后用DisableConcurrentExecution.

我使用 sqlserver 作为存储。任何人都遇到过这个问题,有一些技巧可以避免它吗?

PS:我使用DisableConcurrentExecution是因为在hangfire文档中说互斥锁和信号量不能保证只调用一次作业。

PS2:检查我的hangfire服务器我注意到我有两个实例,每个实例都有1个工作人员,所以我认为这是一个并行问题而不是并发问题。

4

2 回答 2

2

根据Hangfire 文档,当重复作业/任务没有标识符时会出现重复作业问题:“为每个重复作业使用唯一标识符,否则您将以单个作业结束。” .

RecurringJob.AddOrUpdate("some-id", () => Console.WriteLine(), Cron.Hourly);

资料来源:

  1. https://gist.github.com/odinserj/a8332a3f486773baa009
  2. https://discuss.hangfire.io/t/how-do-i-prevent-creation-of-duplicate-jobs/1222/4
于 2020-05-14T20:46:49.027 回答
0

这项工作对我有用。我用MaximumConcurrentExecutions(1)装饰hangfire运行的接口方法。

这并没有单独解决我的问题,因为有多个服务器(自动扩展)。

所以在启动类中我创建了另一个 backgroundjobserveroptions 来为这个作业创建一个独占服务器,以保证当应用程序扩展时不会创建另一个带有另一个队列的服务器,我必须在 sqlserver hangfire.server 中查询并检查我的队列已经存在。

if(!HangfireServerInfo.QueueExists("queuename", AppSettings.GetConnectionString("Hangfire"))){
        var hangfireServerOptions = new BackgroundJobServerOptions { WorkerCount = 1, Queues = new[] {"queuename"} };
        app.UseHangfireServer(hangfireServerOptions);
    }


public static class HangfireServerInfo
    {
        public static bool QueueExists(string queueName, string connectionString)
        {
            using (var connection = new SqlConnection(connectionString))
            {
                var cmd = connection.CreateCommand();
                cmd.CommandText = 
                    $@"SELECT COUNT(*) 
                    FROM {YOURHANGFIRESERVER.server}
                    WHERE JSON_QUERY(data, '$.queues') = '[""{queueName}""]'";

                connection.Open();
                var result = (int)cmd.ExecuteScalar();
                connection.Close();

                return result > 0;
            }
        }
    }

可能这是解决它的更好方法,但这有效。

于 2020-05-15T22:10:07.363 回答