BizTalk发送端口预组装阶段生成双消息异常的原因与解决方法

你遇到的核心问题是：BizTalk管道组件的Execute方法默认只会被框架调用一次（除非组件明确表示还有更多消息）。你的代码虽然把两个消息放进了队列，但只返回了第一个，剩下的消息根本没机会被框架获取到，所以组装阶段只收到了一个消息。

为什么当前代码不生效？ #

你在Execute方法内部创建了队列，加入两个消息后只返回了第一个。但这个队列是局部变量，方法执行完就销毁了，框架没有办法知道还有第二个消息存在，自然不会去取。而且直接复用同一个pInMsg实例也有隐患——BizTalk的消息对象是有状态的，重复使用会导致上下文属性混乱、消息流异常。

正确实现多消息输出的步骤 #

要让管道组件输出多个消息，需要让组件在多次Execute调用中依次返回消息，直到返回null表示没有更多消息。具体要做这几点：

1. 把消息队列声明为组件的成员变量（而非局部变量），这样多次调用Execute时能保留状态。
2. 必须为每个输出消息创建独立副本，不能直接复用输入消息实例。
3. 在每次Execute调用时返回队列的下一个消息，队列为空时返回null，同时重置队列状态以便处理下一个输入消息。

修正后的代码示例 #

// 将队列声明为组件的私有成员变量，保存多消息状态
private System.Collections.Queue _outputMessageQueue;

public IBaseMessage Execute(IPipelineContext pipelineContext, IBaseMessage inputMessage)
{
    // 仅在第一次调用时初始化队列并创建消息副本
    if (_outputMessageQueue == null)
    {
        _outputMessageQueue = new System.Collections.Queue();
        
        // 创建第一个消息副本
        var msg1 = CreateMessageCopy(pipelineContext, inputMessage);
        // 创建第二个消息副本
        var msg2 = CreateMessageCopy(pipelineContext, inputMessage);
        
        _outputMessageQueue.Enqueue(msg1);
        _outputMessageQueue.Enqueue(msg2);
    }

    // 返回队列中的下一个消息，无消息时返回null
    if (_outputMessageQueue.Count > 0)
    {
        return (IBaseMessage)_outputMessageQueue.Dequeue();
    }
    else
    {
        // 重置队列，确保下一次处理新输入消息时重新初始化
        _outputMessageQueue = null;
        return null;
    }
}

// 辅助方法：创建输入消息的独立副本
private IBaseMessage CreateMessageCopy(IPipelineContext context, IBaseMessage sourceMsg)
{
    // 使用消息工厂创建新消息实例
    var newMsg = context.GetMessageFactory().CreateMessage();
    
    // 克隆消息体部分
    newMsg.AddPart(sourceMsg.BodyPart.Clone(), true);
    
    // 复制所有上下文属性
    foreach (DictionaryEntry prop in sourceMsg.Context)
    {
        newMsg.Context.Write((string)prop.Key, (string)prop.Value, prop.Value);
    }
    
    return newMsg;
}

关键细节说明 #

• 消息副本的必要性：直接复用inputMessage会导致多个输出消息共享同一个消息体和上下文，在后续的组装/编码阶段会出现属性覆盖、消息流异常等问题。通过克隆BodyPart和复制上下文，保证每个消息都是独立的。
• 队列状态重置：处理完当前输入消息的所有输出后，重置队列，避免下一个输入消息复用之前的队列状态。
• 框架调用逻辑：BizTalk管道框架会反复调用Execute方法，直到返回null，这样就能依次处理队列中的两个消息，最终都传递到组装阶段。

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