wcf - WCF：通过装饰为操作注入自定义标头

Question

嗨，如果操作被修饰，我需要在消息中注入自定义标头。

到目前为止我做了什么？1) 通过继承 Attribute 和 IOperationBehavior 创建一个 Attribute 2) 附加一个自定义 OperationInvoker 与操作

属性：

public class RankAttribute : Attribute, IOperationBehavior
{ 
     public void ApplyDispatchBehavior(OperationDescription operationDescription, DispatchOperation dispatchOperation)
    {
        dispatchOperation.Invoker = new PublishMessageInvoker(dispatchOperation.Invoker);
    }
    //rest of the methods
}

界面：

public interface INullableService
{
    [OperationContract]
    [FaultContract(typeof(BusinessServiceException))]
    [Rank]
    NullableResponse NullChecking(NullableRequest request);

    [OperationContract]
    [FaultContract(typeof(BusinessServiceException))]
    NullableResponse NullChecking2(NullableRequest request);
}

现在的问题是，我不知道在哪里修改消息头，我可以通过 operationDiscription.Messages[] 访问消息，但文档说任何修改都会产生意想不到的结果。

谢谢， 阿维纳什

Answer 1

没关系 :) 这很简单 :) .. 你可以在 IOperationInvoker 中访问 OperationContext

public class PublishMessageInvoker : IOperationInvoker
{
    private IOperationInvoker invoker;


    public PublishMessageInvoker(IOperationInvoker invoker)
    {
        logger.Info("PublishMessageInvoker");
        this.invoker = invoker;

    }

    public object[] AllocateInputs()
    {

        if (invoker == null)
            return null;
        return this.invoker.AllocateInputs();
    }

    public object Invoke(object instance, object[] inputs, out object[] outputs)
    {
       OperationContext.Current.OutgoingMessageHeaders.Add(
            MessageHeader.CreateHeader(
                "customheader",
                "asnjnjdhbhb.com",
                "MyAction")
                );
        return this.invoker.Invoke(instance, inputs, out outputs);
    }

    public IAsyncResult InvokeBegin(object instance, object[] inputs, AsyncCallback callback, object state)
    {

        if (invoker == null)
            return null;
        return this.invoker.InvokeBegin(instance, inputs, callback, state);
    }

    public object InvokeEnd(object instance, out object[] outputs, IAsyncResult result)
    {

        if (invoker == null)
        {
            outputs = null;
            return null;
        }
        return this.invoker.InvokeEnd(instance, out outputs, result);
    }

    public bool IsSynchronous
    {
        get {

            if (invoker == null) return true;
            return this.invoker.IsSynchronous; 
        }
    }
}