MassTransit Courier路由重复活动间变量与参数传递问题

针对循环活动中OrderItems列表无法更新传递的问题，核心是利用MassTransit Courier的路由单全局变量存储动态状态，结合活动内动态扩展路由单的方式实现循环逻辑，具体步骤如下：

• 区分参数类型

  • 预定义固定参数（如SOAP客户端配置、目标系统标识）：若所有活动共用，直接存入路由单全局变量；若仅单个活动使用，作为活动执行参数（Arguments）传入。
  • 动态状态参数（如OrderItems列表、当前处理索引）：全部存入路由单全局变量，确保活动间共享最新状态。

• 构建初始路由单
  初始化时仅添加第一个循环活动实例，将预定义参数和初始动态状态存入变量：

  var routingSlip = new RoutingSlipBuilder(NewId.NextGuid());
  
  // 预定义参数存入全局变量
  routingSlip.AddVariable("SoapClientConfig", new SoapClientConfig { Url = "xxx", ApiKey = "xxx" });
  // 动态状态初始化
  routingSlip.AddVariable("OrderItems", originalOrderItemsList);
  routingSlip.AddVariable("CurrentItemIndex", 0);
  
  // 添加第一个循环活动实例
  routingSlip.AddActivity("SyncOrderItem", new Uri("queue:sync-order-item"), new SyncOrderItemArguments());
  
  await _bus.Execute(routingSlip.Build());
  

• 循环活动的执行逻辑
  在SyncOrderItemActivity的Execute方法中，读取变量中的最新状态，处理完成后更新变量，再判断是否需要添加下一个活动实例：

  public async Task<ExecutionResult> Execute(ExecuteContext<SyncOrderItemArguments> context)
  {
      // 从全局变量读取最新状态
      var currentIndex = context.Variables.Get<int>("CurrentItemIndex");
      var orderItems = context.Variables.Get<List<OrderItem>>("OrderItems");
      var soapConfig = context.Variables.Get<SoapClientConfig>("SoapClientConfig");
  
      // 处理当前订单项（调用SOAP客户端）
      var currentItem = orderItems[currentIndex];
      await _soapClient.SyncOrderItem(currentItem, soapConfig);
  
      // 更新全局变量中的列表（标记已处理或替换为最新数据）
      orderItems[currentIndex] = new OrderItem { Id = currentItem.Id, Synced = true, ... };
      context.Variables.Set("OrderItems", orderItems);
      context.Variables.Set("CurrentItemIndex", currentIndex + 1);
  
      // 动态添加下一个活动实例（如果还有未处理项）
      if (currentIndex + 1 < orderItems.Count)
      {
          context.AddActivity("SyncOrderItem", new Uri("queue:sync-order-item"), new SyncOrderItemArguments());
      }
  
      return context.Completed();
  }
  

这种方式能保证每个活动实例读取的都是最新的OrderItems列表，解决循环中状态无法传递的问题。

MassTransit Courier中参数的优先级遵循以下规则，优先级从高到低：

1. 活动执行参数（Arguments）
   添加活动时直接传入的Arguments对象优先级最高，活动执行时会优先使用该对象中的值，即使路由单全局变量中有同名键，也不会覆盖Arguments的内容。适用于单个活动的固定参数。

2. 路由单全局变量（Variables）
   当活动的Arguments中不存在某个参数时，会自动从路由单的全局变量中读取对应值。全局变量存储的是路由单的动态状态，所有活动共享，更新后后续活动能读取到最新值。

3. 补偿活动参数（CompensateArguments）
   补偿活动的参数优先级规则与执行活动一致：CompensateArguments > 全局变量。

注意：如果活动逻辑中同时依赖Arguments和Variables，需明确区分固定参数与动态状态，避免同名键导致的预期外行为。

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