自定義消息編碼綁定實現

　　擴展WCF 消息編碼綁定，需實現MessageEncodingBindingElement，MessageEncoder,MessageEncoderFactory.如果希望通過配置的方式應用我們實現的綁定，則還需要實現BindingElementExtensionElement。

　　首先從消息編碼綁定實現開始；實現MessageEncoderBindingElement

 public abstract class CommonMessageEncodingBindingElement : MessageEncodingBindingElement
    {
        protected MessageEncodingBindingElement innerBindingElement;

        protected CommonMessageEncodingBindingElement() : this(new TextMessageEncodingBindingElement())
        {
        }

        protected CommonMessageEncodingBindingElement(
            MessageEncodingBindingElement textMessageEncodingBindingElement)
        {
            innerBindingElement = textMessageEncodingBindingElement;
        }

        public MessageEncodingBindingElement InnerBindingElement
        {
            get { return innerBindingElement; }
            set { innerBindingElement = value; }
        }

        public override MessageVersion MessageVersion
        {
            get { return innerBindingElement.MessageVersion; }
            set { innerBindingElement.MessageVersion = value; }
        }

        public override IChannelFactory<TChannel> BuildChannelFactory<TChannel>(BindingContext context)
        {
            context.BindingParameters.Add(this);
            return context.BuildInnerChannelFactory<TChannel>();
        }


        public override IChannelListener<TChannel> BuildChannelListener<TChannel>(BindingContext context)
        {
            context.BindingParameters.Add(this);
            return context.BuildInnerChannelListener<TChannel>();
        }

        public override bool CanBuildChannelFactory<TChannel>(BindingContext context)
        {
            return innerBindingElement.CanBuildChannelFactory<TChannel>(context);
        }
    }

　　其次；實現MessageEncoder。代碼如下；

public abstract class CommonMessageEncoder:MessageEncoder
    {
        public MessageEncoder encoder;

        protected CommonMessageEncoder(MessageEncoder messageEncoder)
        {
            encoder = messageEncoder;
        }

        public override string ContentType
        {
            get { return encoder.ContentType; }
        }

        public override string MediaType
        {
            get { return encoder.MediaType; }
        }

        public override MessageVersion MessageVersion
        {
            get { return encoder.MessageVersion; }
        }
    }

　　再次；實現ServerMessageEncoderFactory

 internal class ServerMessageEncoderFactory : MessageEncoderFactory
    {
        private readonly MessageEncoder encoder;

        public ServerMessageEncoderFactory(MessageEncoderFactory messageEncoderFactory)
        {
            encoder = new ServerMessageEncoder(messageEncoderFactory.Encoder);
        }

        public override MessageEncoder Encoder
        {
            get { return encoder; }
        }

        public override MessageVersion MessageVersion
        {
            get { return encoder.MessageVersion; }
        }
    }

最后通過配置應用到WCF 。配置實現開始；實現BindingElementExtensionElement.

public class ServerBindingExtension : CommonBindingElementExtensionElement
    {
        public override Type BindingElementType
        {
            get { return typeof (ServerMessageEncodingBindingElement); }
        }

        protected override BindingElement CreateBindingElement()
        {
            ServerMessageEncodingBindingElement serverMessageEncodingBindingElement =
                new ServerMessageEncodingBindingElement();
            ApplyConfiguration(serverMessageEncodingBindingElement);
            return serverMessageEncodingBindingElement;
        }
    }

　服務端配置；

<system.serviceModel>
    <extensions>
      <bindingElementExtensions>
        <add name="myCustomerBinding" type="Hosting.ServerBindingExtension,Hosting"/>
      </bindingElementExtensions>
    </extensions>
    <bindings>
      <customBinding>
        <binding name="customerBinding">
          <myCustomerBinding/>
          <httpTransport/>
        </binding>
      </customBinding>
    </bindings>
    <services>
      <service name="Service.AddService">
        <endpoint address="http://127.0.0.1:8088/AddService" 
                  binding="customBinding" 
                  contract="Contract.IAdd" bindingConfiguration="customerBinding" ></endpoint>
      </service>
    </services>
  </system.serviceModel>

客戶端配置；

<system.serviceModel>
    <extensions>
      <bindingElementExtensions>
        <add name="clientBinding" type="Client.ClientBindingExtension,Client"/>
      </bindingElementExtensions>
      <behaviorExtensions>
        <add name="clientEndpoint" type="Client.ClientMessageInspector,Client"/>
      </behaviorExtensions>
    </extensions>
    <behaviors>
      <endpointBehaviors>
        <behavior>
          <clientEndpoint />
        </behavior>
      </endpointBehaviors>
    </behaviors>
    <bindings>
      <customBinding>
        <binding name="customerBinding">
          <clientBinding />
          <httpTransport></httpTransport>
        </binding>
      </customBinding>
    </bindings>
    <client>
      <endpoint address="http://127.0.0.1:8088/AddService"
                binding="customBinding"
                contract="Contract.IAdd"
                name="customEndpoint" bindingConfiguration="customerBinding"></endpoint>
    </client>
  </system.serviceModel>

服務端運行圖；

　　客戶端調用效果；

代碼；http://download.csdn.net/detail/tyb1222/6842555

posted @ 2014-01-13 13:21 tyb1222 閱讀(752) 評論(0) 收藏舉報

刷新頁面返回頂部

自定義消息編碼綁定實現

公告