如何实现Azure WebJobs按用户单例运行，避免同一用户任务并行执行？

这个场景太典型了——定时触发的任务给用户发消息，结果慢的用户任务还没跑完，新的消息又进来导致并发。我来给你几个实用的解决方案，从最省心到自定义实现都有：

1. 优先用Azure Service Bus会话（最省心的原生方案） #

这是我最推荐的方式，不用自己写复杂的锁逻辑，Service Bus原生就支持顺序处理同一用户的消息：

• 第一步：修改Service Bus队列设置：在Azure门户里找到你的队列，开启「Enable sessions」（启用会话）。
• 第二步：发送消息时指定Session ID：TimerTrigger函数给每个用户发消息时，把SessionId设为用户唯一标识（比如用户ID）。代码示例大概是这样：

  var message = new ServiceBusMessage(JsonSerializer.Serialize(syncTaskData))
  {
      SessionId = userId.ToString() // 同一用户的消息用同一个SessionId
  };
  await serviceBusSender.SendMessageAsync(message);
  

• 第三步：WebJob开启会话接收模式：WebJob接收消息时，要基于会话来接收，Service Bus会保证同一个Session的消息必须等前一条处理完成（完成/放弃/死信）后，才会投递下一条。比如用ServiceBusSessionProcessor来处理：

  var processor = new ServiceBusSessionProcessor(connectionString, queueName);
  processor.ProcessMessageAsync += async args =>
  {
      // 处理用户同步任务
      var userId = args.Session.SessionId;
      await ProcessUserSyncTask(userId);
      await args.CompleteMessageAsync(args.Message);
  };
  await processor.StartProcessingAsync();
  

这种方式的好处是：完全不用自己维护锁的生命周期，Service Bus自动处理并发控制，就算任务崩溃，会话锁也会在消息超时后自动释放。

2. Azure Blob Lease（自定义分布式锁） #

如果因为某些原因不能用Service Bus会话，手动实现Blob Lease也是个可靠的方案：

• 思路：给每个用户创建一个唯一命名的Blob（比如locks/{userId}.lock），WebJob处理任务前尝试获取这个Blob的排他租约：
  • 成功获取租约：说明没有正在运行的任务，开始执行，任务完成后释放租约。
  • 获取失败：说明该用户已有任务在跑，直接放弃当前队列消息（或者放到死信队列，后续再重试）。
• 关键细节：
  • 租约时长要设得比任务最长执行时间长一点，比如如果任务最多跑1小时，就设2小时；如果任务可能跑更久，要在任务执行过程中定期续租。
  • 就算任务崩溃，租约到期后会自动释放，不会出现永久死锁。
• 代码示例大概是这样（用Azure.Storage.Blobs库）：

  var blobClient = new BlobClient(connectionString, containerName, $"locks/{userId}.lock");
  await blobClient.CreateIfNotExistsAsync();
  
  try
  {
      // 尝试获取租约，超时时间设为10秒，租约时长2小时
      var lease = await blobClient.AcquireLeaseAsync(TimeSpan.FromHours(2), null, TimeSpan.FromSeconds(10));
      try
      {
          // 执行同步任务
          await ProcessUserSyncTask(userId);
      }
      finally
      {
          // 释放租约
          await blobClient.ReleaseLeaseAsync(lease.Value);
      }
  }
  catch (RequestFailedException ex) when (ex.Status == 409)
  {
      // 租约已被占用，放弃当前消息
      await args.AbandonMessageAsync(args.Message);
  }
  

3. Azure Redis Cache分布式锁 #

如果你的项目已经在用Redis缓存，用它来实现锁也是个高性能的选择：

• 思路：任务开始前，用SETNX命令（只有键不存在时才设置成功）往Redis里加一个带过期时间的锁键（比如user_sync_lock:{userId}）：
  • 设置成功：拿到锁，执行任务，完成后删除键。
  • 设置失败：放弃当前消息。
• 注意：要给锁设置足够长的过期时间，或者在任务执行中定期续期，避免任务还没完成锁就过期了。

方案对比 #

针对你的场景，我优先推荐用Service Bus会话，改起来最快，也最省心。

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