如何在双工回调中读取WCF消息头？

Question

如何在双工回调中读取WCF消息头？

5

在普通的WCF请求/响应协议中，您可以使用类似以下方式读取消息头：

OperationContract.Current.IncomingMessageHeaders

我无法理解的是如何在双工合同的回调端完成此操作。在回调实现中，OperationContext.Current 为 null。

编辑于2013年4月5日：我正在使用基于net.tcp的自定义绑定，但进行了许多自定义设置，例如使用协议缓冲区消息编码而不是XML，并且存在一些自定义安全性。

- Simon Gillbee

1个回答

网页内容由stack overflow 提供, 点击上面的

可以查看英文原文，
原文链接

- carlosfigueira · Accepted Answer

你使用的是哪种绑定方式？在下面的SSCCE示例中，回调实现中上下文不为空。

public class StackOverflow_15769719
{
    [ServiceContract(CallbackContract = typeof(ICallback))]
    public interface ITest
    {
        [OperationContract]
        string Hello(string text);
    }
    [ServiceContract]
    public interface ICallback
    {
        [OperationContract(IsOneWay = true)]
        void OnHello(string text);
    }
    public class Service : ITest
    {
        public string Hello(string text)
        {
            ICallback callback = OperationContext.Current.GetCallbackChannel<ICallback>();
            ThreadPool.QueueUserWorkItem(delegate
            {
                callback.OnHello(text);
            });

            return text;
        }
    }
    class MyCallback : ICallback
    {
        AutoResetEvent evt;
        public MyCallback(AutoResetEvent evt)
        {
            this.evt = evt;
        }

        public void OnHello(string text)
        {
            Console.WriteLine("[callback] Headers: ");
            foreach (var header in OperationContext.Current.IncomingMessageHeaders)
            {
                Console.WriteLine("[callback]   {0}", header);
            }

            Console.WriteLine("[callback] OnHello({0})", text);
            evt.Set();
        }
    }
    public static void Test()
    {
        bool useTcp = false;
        string baseAddress = useTcp ? 
            "net.tcp://" + Environment.MachineName + ":8000/Service" :
            "http://" + Environment.MachineName + ":8000/Service";
        ServiceHost host = new ServiceHost(typeof(Service), new Uri(baseAddress));
        Binding binding = useTcp ?
            (Binding)new NetTcpBinding(SecurityMode.None) :
            new WSDualHttpBinding(WSDualHttpSecurityMode.None)
            {
                ClientBaseAddress = new Uri("http://" + Environment.MachineName + ":8888/Client")
            };
        host.AddServiceEndpoint(typeof(ITest), binding, "");
        host.Open();
        Console.WriteLine("Host opened");

        AutoResetEvent evt = new AutoResetEvent(false);
        MyCallback callback = new MyCallback(evt);
        DuplexChannelFactory<ITest> factory = new DuplexChannelFactory<ITest>(
            new InstanceContext(callback),
            binding,
            new EndpointAddress(baseAddress));
        ITest proxy = factory.CreateChannel();

        Console.WriteLine(proxy.Hello("foo bar"));
        evt.WaitOne();

        ((IClientChannel)proxy).Close();
        factory.Close();

        Console.Write("Press ENTER to close the host");
        Console.ReadLine();
        host.Close();
    }
}